// Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of "Eclipse Public License v1.0"
// which accompanies this distribution, and is available
// at the URL "http://www.eclipse.org/legal/epl-v10.html".
//
// Initial Contributors:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
//

#include "es_commsbuf_internal.h"
#include <comms-infras/commsbufpondop.h>
#include "commsbufasyncreqinternal.h"
#include "commsbufpondintf.h"
 
EXPORT_C CCommsBufAsyncRequest::CCommsBufAsyncRequest(TCommsBufAllocator& aAllocator)
:iAllocator(aAllocator)
    {
    iLink.iPrev = &iLink;
    iLink.iNext = &iLink;    
    }
 
EXPORT_C CCommsBufAsyncRequest::~CCommsBufAsyncRequest()
    {
    
    }

void CCommsBufAsyncRequest::Alloc(RCommsBufChain& aChain, TInt aSize, TInt aMinSize, TInt aMaxSize, TRequestStatus& aStatus)
    {
    iSize = aSize;
    iMinSize = aMinSize;
    iMaxSize = aMaxSize;
    iChain = &aChain;
    iStatusPtr = &aStatus;
    *iStatusPtr = KRequestPending;
    // Try to satify the request syncronously
    TInt err = aChain.Alloc(iSize, iAllocator);
    if (err==KErrNone)
        {
#ifdef __CFLOG_ACTIVE
        __CFLOG_2(KSubsysMBufMgr, KSubsysMBufMgrAsyncAlloc, _L8("RMBufAsyncRequest %x:\tAlloc(aLength %d) request satisfied immediately"), this, aLength);
#endif
        User::RequestComplete(iStatusPtr, KErrNone);
        return;
        }

    // Sync alloc failed, so setup the async alloc request
    TThreadId id = RThread().Id();
    TInt ret = iThread.Open(id);
    if(ret == KErrNone)
        {
#ifdef __CFLOG_ACTIVE
        __CFLOG_2(KSubsysMBufMgr, KSubsysMBufMgrAsyncAlloc, _L8("RCommsBufAsyncRequest %x:\tAlloc(aLength %d) starting request"), this, aSize);
#endif
        iAllocator.iPond.StartRequest(*this);
        }
    else
        {
#ifdef __CFLOG_ACTIVE
        __CFLOG_3(KSubsysMBufMgr, KSubsysMBufMgrAsyncAlloc, _L8("RCommsBufAsyncRequest %x:\tAlloc(aLength %d) failed with %d"), this, aSize, ret);
#endif
        }    
    }

void CCommsBufAsyncRequest::Cancel()
    {
    iAllocator.iPond.CancelRequest(*this);
    }
    
EXPORT_C void CCommsBufAsyncRequest::Complete(TInt aCode)
    {
#ifdef __CFLOG_ACTIVE
    __CFLOG_2(KSubsysMBufMgr, KSubsysMBufMgrAsyncAlloc, _L8("RCommsBufAsyncRequest %x:\tComplete(aCode %d)"), this, aCode);
#endif
    iLink.Deque();
    if (aCode==KErrNone)
        {
        // In future we may have another smarter way of doing this.
        // Currently RCommsBufQ is internal
        RCommsBufChain chain(iBufQ.First());       
        iChain->Assign(chain);
        iBufQ.Init();
        }
    else
        {
        iBufQ.Free();  
        }
        
    iThread.RequestComplete(iStatusPtr, aCode);
    iThread.Close();  
    }