diff -r 000000000000 -r 3553901f7fa8 basebandadaptationplugins/basebandchanneladaptorforc32/c32bca2/src/MBca2Impl.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/basebandadaptationplugins/basebandchanneladaptorforc32/c32bca2/src/MBca2Impl.cpp	Tue Feb 02 01:41:59 2010 +0200
@@ -0,0 +1,300 @@
+// Copyright (c) 2004-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:
+// C32 Baseband Channel Adaptor(BCA) Factory APIs implementation.
+// This file contains all the API implementations of C32BcaFactory for Symbian OS.
+// 
+//
+
+/**
+ @file 
+ @internalComponent
+*/
+#include "MBca2Impl.h"
+#include <networking/bca.h>
+#include <comms-infras/commsbuf.h>
+#include "C32BcaFactory.h"
+
+using namespace BasebandChannelAdaptation;
+using namespace BasebandChannelAdaptation::C32Bca;
+using namespace BasebandChannelAdaptation2;
+using namespace BasebandChannelAdaptation2::C32BcaShim;
+
+MBca2* MBca2FactoryImpl::NewBcaL()
+	{
+	MBca2Impl* instance = new(ELeave) MBca2Impl;
+	CleanupStack::PushL(instance);
+	instance->ConstructL();
+	CleanupStack::Pop(instance);
+	return instance;
+	}
+	
+void MBca2FactoryImpl::Release()
+	{
+	delete this;
+	}
+
+MBca2Impl::MBca2Impl() : iControl(NULL),
+	iBcaParams(NULL),
+	iLowerDataSender(NULL),
+	iReceiver(NULL),
+	iMBca(NULL),
+	iC32BcaFactory(NULL),
+	iRecvBlocked(EFalse)
+	{
+	
+	}
+
+MBca2Impl::~MBca2Impl()
+	{	
+	iReceiver->Cancel();
+	delete iReceiver;
+	delete iLowerDataSender;
+	iMBca->Release();
+	iC32BcaFactory->Release();
+	}
+
+void MBca2Impl::ConstructL()
+	{
+	iC32BcaFactory = new(ELeave) CC32BcaFactory;
+	iMBca = iC32BcaFactory->NewBcaL();
+	iLowerDataSender = MLowerDataSenderImpl::NewL(iMBca);
+	iReceiver = new (ELeave) CReceiver(iMBca);
+	}
+
+TInt MBca2Impl::Open(MUpperControl& aControl, 
+						MUpperDataReceiver& aData, 
+						const TBcaParams& aBcaParams)
+	{
+	iControl = &aControl;
+	iLowerDataSender->SetControl(&aControl);
+	iReceiver->SetParams(&aData,&aBcaParams);
+	iBcaParams = &aBcaParams;
+	return KErrNone;
+	}
+		
+void MBca2Impl::Start()
+	{
+	TRequestStatus status;
+	iMBca->Open(status,iBcaParams->iChannelId);
+	User::WaitForRequest(status);
+	TInt ret = status.Int();
+
+	if (ret != KErrNone && ret != KErrAlreadyExists )
+		{
+		TRequestStatus shutdownStatus;
+		iMBca->Shutdown(shutdownStatus);
+		User::WaitForRequest(shutdownStatus);
+		}
+	else
+		{
+		iControl->StartSending();
+		iReceiver->StartListening();
+		}
+	return;
+	}
+		
+MLowerDataSender& MBca2Impl::GetSender()
+	{
+	return *iLowerDataSender;
+	}
+		
+void MBca2Impl::Close()
+	{
+	iMBca->Close();
+	}
+		
+void MBca2Impl::Release()
+	{	
+	delete this;
+	}
+		
+void MBca2Impl::SetFlowControl(TBlockOption aOption)
+	{
+	if(aOption == EBlockFlow)
+		{
+		iRecvBlocked = ETrue;
+		iReceiver->Cancel();
+		}
+	else if(aOption == EUnblockFlow)
+		{
+		if( iRecvBlocked)
+			{
+			iReceiver->StartListening();
+			}
+		else
+			{
+			iRecvBlocked = EFalse;
+			}
+		}
+	}
+		
+void MBca2Impl::Control(TRequestStatus& aStatus,
+								TUint aOptLevel,
+								TUint aOptName,
+								TDes8& aOpt)
+	{
+	iMBca->Ioctl(aStatus,aOptLevel,aOptName,aOpt);
+	}
+		
+void MBca2Impl::CancelControl()
+	{
+	iMBca->CancelIoctl();
+	}
+
+MLowerDataSenderImpl* MLowerDataSenderImpl::NewL(BasebandChannelAdaptation::MBca* aMBca)
+	{
+	MLowerDataSenderImpl* instance = new (ELeave) MLowerDataSenderImpl;
+	CleanupStack::PushL(instance);
+	instance->ConstructL(aMBca);
+	CleanupStack::Pop(instance);
+	return instance;	 
+	}
+
+MLowerDataSenderImpl::MLowerDataSenderImpl() : iSender(NULL), iControl(NULL), iSendBlocked(EFalse)
+	{
+	
+	}
+
+void MLowerDataSenderImpl::ConstructL(BasebandChannelAdaptation::MBca* aMBca)
+	{
+	iSender = new (ELeave) CSender(aMBca);
+	}
+
+MLowerDataSenderImpl::~MLowerDataSenderImpl()
+	{
+	iSender->Cancel();
+	delete iSender;
+	}
+
+void MLowerDataSenderImpl::SetControl(MUpperControl* aControl)
+	{
+	iControl = aControl;
+	}
+
+MLowerDataSender::TSendResult MLowerDataSenderImpl::Send(RCommsBufChain& aCommsBufChain)
+	{	
+	TRequestStatus status;
+	TInt retSend = iSender->Send(status, aCommsBufChain);
+	if(retSend == -1)
+		{
+		iSendBlocked = ETrue;
+		return ESendBlocked;
+		}	
+	User::WaitForRequest(status);
+	TInt ret = status.Int();
+	if(ret == KErrNone)
+		{
+		if(iSendBlocked)
+			{
+			iControl->StartSending();
+			iSendBlocked = EFalse;
+			}
+		return ESendAccepted;
+		}
+	else
+		{
+		iControl->Error(ret);
+		return ESendBlocked;
+		}
+	}
+
+CReceiver::CReceiver(BasebandChannelAdaptation::MBca* aMBca) : CActive(EPriorityNormal), iMBca(aMBca)
+	{
+	CActiveScheduler::Add(this);
+	}
+
+CReceiver::~CReceiver()
+	{
+	
+	}
+
+void CReceiver::SetParams(MUpperDataReceiver* aDataReceiver, const MBca2::TBcaParams* aBcaParams)
+	{
+	iDataReceiver = aDataReceiver;
+	iBcaParams = aBcaParams;
+	}
+
+void CReceiver::RunL()
+	{	
+	TCommsBufAllocator allocator = const_cast<RCommsBufPond&>(iBcaParams->iCommsBufPond).Allocator();
+	iBufChain.Alloc(iData.Length(),allocator);
+	iBufChain.Write(iData);
+	iDataReceiver->Process(iBufChain);
+	StartListening();
+	}
+
+void CReceiver::DoCancel()
+	{
+	iMBca->CancelRead();
+	}
+
+void CReceiver::StartListening()
+	{
+	// call read on MBca
+	iData.SetMax();
+	iMBca->Read(iStatus,iData);
+	SetActive();
+	}
+
+CSender::CSender(BasebandChannelAdaptation::MBca* aMBca) : CActive(EPriorityNormal), iMBca(aMBca)
+	{
+	CActiveScheduler::Add(this);
+	}
+CSender::~CSender()
+	{
+	
+	}
+
+void CSender::RunL()
+	{
+	User::RequestComplete(iSendRequest, iStatus.Int());
+	}
+
+void CSender::DoCancel()
+	{
+	iMBca->CancelWrite();
+	}
+
+TInt CSender::Send(TRequestStatus& aStatus,RCommsBufChain& aPdu)
+	{
+	if(iStatus == KRequestPending)
+		{
+			return -1;
+		}
+	else
+		{
+		aStatus = KRequestPending;
+		iSendRequest = &aStatus;
+		TBuf8<KMaxIPPacketAndHeader> buffer;
+		if(aPdu.Length() > KMaxIPPacketAndHeader)
+			{
+			// discard packet and return			
+			aPdu.Free();
+			User::RequestComplete(iSendRequest, KErrNone);
+			return 0;
+			}
+		buffer.SetLength(aPdu.Length());
+		aPdu.Read(buffer);
+		aPdu.Free();
+		SendBuffer(buffer);
+		return 0;
+		}
+		
+	}
+void CSender::SendBuffer(const TDesC8& aBuffer)
+	{
+	iMBca->Write(iStatus,aBuffer);
+	SetActive();		
+	}
+