--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/commsfwutils/commsbufs/version1/mbufmgr/src/MB_ASY.CPP	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,125 @@
+// 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();
+	}
+