// 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:
// Comms reader and writer mixin
// 
//

/**
 @file
*/


#include <nifutl.h>
#include "NI_STD.H"
#include "Ni_Log.h"
#include "bcacontrol.h"

NONSHARABLE_CLASS(CCommReaderV2) : public CActive
/**
@internalComponent
*/
	{
friend class MCommV2;
public:
	CCommReaderV2(MCommV2* aComm, TInt aPriority);
	virtual ~CCommReaderV2();
	virtual void RunL();
	virtual void DoCancel();
private:
	void CompleteNow(TInt aError);
private:
	MCommV2 *iComm;
	};

NONSHARABLE_CLASS(CCommWriterV2) : public CActive
/**
@internalComponent
*/
	{
friend class MCommV2;
public:
	CCommWriterV2(MCommV2* aComm, TInt aPriority);
	virtual ~CCommWriterV2();
	virtual void RunL();
	virtual void DoCancel();
private:
	void CompleteNow(TInt aError);
private:
	MCommV2 *iComm;
	};

#if !defined(__EABI__) && !defined(__X86GCC__)
EXPORT_C MCommV2::MCommV2()
/**
Constructor
*/
	{
	}
#endif

EXPORT_C void MCommV2::CommDelete()
	{
	LOG( NifmanLog::Printf(_L("MCommV2 %08x:\tCommDelete()"), this); )
	delete iCommReader;
	iCommReader = NULL;
	delete iCommWriter;
	iCommWriter = NULL;
	delete iBcaControl;
	iBcaControl = NULL;
	}

	
EXPORT_C TInt MCommV2::CommOpen(const TDesC& aChannelId)
	{
	iChannelId = aChannelId;
	LOG( NifmanLog::Printf(_L("MCommV2 %08x:\tCommOpen('%S')"), this, &aChannelId); )
	TRAPD(err, iBcaControl->StartLoadL(););
	LOG(
		if (err != KErrNone)
			{
			NifmanLog::Printf(_L("MCommV2 %08x:\tCommOpen() returned error %d"), this, err);
			}
	)
	return err;
	}

EXPORT_C void MCommV2::CommClose()
	{
	LOG( NifmanLog::Printf(_L("MCommV2 %08x:\tCommClose()"), this); )
	iCommReader->Cancel();
	iCommWriter->Cancel();
	iBcaControl->Shutdown(KErrNone);
	iChannelId.Zero();
	}

EXPORT_C void MCommV2::CommConstructL(TInt aReadPriority, TInt aWritePriority)
	{
	iCommReader = new (ELeave) CCommReaderV2(this, aReadPriority);
	iCommWriter = new (ELeave) CCommWriterV2(this, aWritePriority);
	iBcaControl = new (ELeave) CScriptBcaControl (this);
	}

EXPORT_C void MCommV2::CommWrite(const TDesC8& aDes)
	{
	__ASSERT_ALWAYS(iCommWriter!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	__ASSERT_ALWAYS(iBca!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	iBca->Write(iCommWriter->iStatus, aDes);
	iCommWriter->SetActive();
	}

EXPORT_C void MCommV2::CommWriteReady()
	{
	__ASSERT_ALWAYS(iCommWriter!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	__ASSERT_ALWAYS(iBca!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	iBca->Write(iCommWriter->iStatus, TPtrC8(NULL, 0));
	iCommWriter->SetActive();
	}

EXPORT_C TBool MCommV2::CommIsWriting() const
	{

	return iCommWriter->IsActive();
	}

EXPORT_C void MCommV2::CommRead(TDes8& aDes)
	{
	__ASSERT_ALWAYS(iCommReader!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	__ASSERT_ALWAYS(iBca!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	iBca->Read(iCommReader->iStatus, aDes);
	iCommReader->SetActive();
	}

EXPORT_C void MCommV2::CommReadOneOrMore(TDes8& aDes)
	{
	__ASSERT_ALWAYS(iCommReader!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	__ASSERT_ALWAYS(iBca!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	iBca->Read(iCommReader->iStatus, aDes);
	iCommReader->SetActive();
	}

EXPORT_C void MCommV2::CommReadReady()
	{
	__ASSERT_ALWAYS(iCommReader!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	iCommReader->SetActive();
	}

EXPORT_C TBool MCommV2::CommIsReading() const
	{

	return iCommReader->IsActive();
	}

EXPORT_C void MCommV2::CommCancel()
	{
	if (iCommWriter)
		iCommWriter->Cancel();
	if (iCommReader)
		iCommReader->Cancel();
	if (iBcaControl)
		{
		iBcaControl->Cancel();
		}
	}

EXPORT_C void MCommV2::CommWriteCancel()
	{
	if (iCommWriter)
		iCommWriter->Cancel();
	}

EXPORT_C void MCommV2::CommReadCancel()
	{
	if (iCommReader)
		iCommReader->Cancel();
	}

EXPORT_C const TDesC& MCommV2::BcaName() 
	{ 
	return BcaStack();
	}

EXPORT_C void MCommV2::SetBca(BasebandChannelAdaptation::MBca* aBca)
	{
	iBca = aBca;
	}
EXPORT_C const TDesC& MCommV2::Port()
	{
	return iChannelId;
	}

//

CCommWriterV2::CCommWriterV2(MCommV2* aComm, TInt aPriority)
	: CActive(aPriority), iComm(aComm)
	{
	CActiveScheduler::Add(this);
	}

CCommWriterV2::~CCommWriterV2()
	{
	Cancel();
	}

void CCommWriterV2::RunL()
	{
	iComm->CommWriteCancel();
	iComm->CommWriteComplete(iStatus.Int());
	}

void CCommWriterV2::DoCancel()
	{
	__ASSERT_ALWAYS(iComm->iBca!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	iComm->iBca->CancelWrite();
	}

void CCommWriterV2::CompleteNow(TInt aError)
	{
	TRequestStatus* statusPtr=&iStatus;
	User::RequestComplete(statusPtr,aError);
	}

//

CCommReaderV2::CCommReaderV2(MCommV2* aComm, TInt aPriority)
	: CActive(aPriority), iComm(aComm)
	{
	CActiveScheduler::Add(this);
	}

CCommReaderV2::~CCommReaderV2()
	{
	Cancel();
	}

void CCommReaderV2::RunL()
	{
	iComm->CommReadCancel();
	iComm->CommReadComplete(iStatus.Int());
	}

void CCommReaderV2::DoCancel()
	{
	__ASSERT_ALWAYS(iComm->iBca!=NULL, NetUtilPanic(ENuPanic_NotConstructed));
	iComm->iBca->CancelRead();
	}

void CCommReaderV2::CompleteNow(TInt aError)
	{
	TRequestStatus* statusPtr=&iStatus;
	User::RequestComplete(statusPtr,aError);
	}