// Copyright (c) 1997-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:

// Buffer Manager for Protocols(ASync alloc)

// 

//

/**

 @file

 @internalComponent

*/

#include <es_mbman.h>

#include <cflog.h>

//

// ASYNC ALLOCATOR SUPPORT

//

#ifdef __CFLOG_ACTIVE

__CFLOG_STMT(_LIT8(KSubsysMBufMgrAsyncAlloc, "AsyncAlloc"));

__CFLOG_STMT(_LIT8(KSubsysMBufMgr, "MBufMgr");) // subsystem name

#endif

/**

Constructor inisialiser.

*/

EXPORT_C RMBufAsyncRequest::RMBufAsyncRequest()

: iLength(0),

  iChain(NULL),

  iStatusPtr(NULL),

  iLogger(0)

	{

	iMBufs.Init();

	iLink.iPrev = &iLink;

	iLink.iNext = &iLink;

	}

/**

Destructor.

*/

EXPORT_C RMBufAsyncRequest::~RMBufAsyncRequest()

	{

	}

/**

Allocates memory for a MBuf Chain

- refer RMBufChain::AllocL notes regarding the deliberate decision not to provide an overloaded min/max mbuf size variant

@param aChain The chain

@param aLenth The length of the chain

@param aStatus KErrNone if successful.

*/

EXPORT_C void RMBufAsyncRequest::Alloc(RMBufChain& aChain, TInt aLength, TRequestStatus& aStatus)

	{

	iLength = aLength;

	iChain = &aChain;

	iStatusPtr = &aStatus;

	*iStatusPtr = KRequestPending;

	// Try to satify the request syncronously

	TInt err = aChain.Alloc(aLength);

	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("RMBufAsyncRequest %x:\tAlloc(aLength %d) starting request"), this, aLength);

#endif

		CMBufManager::Context()->StartRequest(*this);

		}

	else

		{

#ifdef __CFLOG_ACTIVE

		__CFLOG_3(KSubsysMBufMgr, KSubsysMBufMgrAsyncAlloc, _L8("RMBufAsyncRequest %x:\tAlloc(aLength %d) failed with %d"), this, aLength, ret);

#endif

		}

	}

/**

Cancels outstanding request.

*/

EXPORT_C void RMBufAsyncRequest::Cancel()

	{

#ifdef __CFLOG_ACTIVE

	__CFLOG_1(KSubsysMBufMgr, KSubsysMBufMgrAsyncAlloc, _L8("RMBufAsyncRequest %x:\tCancel()"), this);

#endif

	CMBufManager::Context()->CancelRequest(*this);

	}

/**

Completes the request.

@param aCode The completion code (status).

*/

void RMBufAsyncRequest::Complete(TInt aCode)

	{

#ifdef __CFLOG_ACTIVE

	__CFLOG_2(KSubsysMBufMgr, KSubsysMBufMgrAsyncAlloc, _L8("RMBufAsyncRequest %x:\tComplete(aCode %d)"), this, aCode);

#endif

	iLink.Deque();

	if (aCode==KErrNone)

		iChain->Assign(iMBufs);

	else

		iMBufs.Free();

	iThread.RequestComplete(iStatusPtr, aCode);

	iThread.Close();

	}