// 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"

class CCommLinkStatus;

NONSHARABLE_CLASS(CCommReader) : public CActive

/**

@internalComponent

*/

	{

friend class MComm;

friend class CCommLinkStatus;

public:

	CCommReader(MComm* aComm, TInt aPriority);

	virtual ~CCommReader();

	virtual void RunL();

	virtual void DoCancel();

private:

	void CompleteNow(TInt aError);

private:

	MComm *iComm;

	};

NONSHARABLE_CLASS(CCommWriter) : public CActive

/**

@internalComponent

*/

	{

friend class MComm;

friend class CCommLinkStatus;

public:

	CCommWriter(MComm* aComm, TInt aPriority);

	virtual ~CCommWriter();

	virtual void RunL();

	virtual void DoCancel();

private:

	void CompleteNow(TInt aError);

private:

	MComm *iComm;

	};

NONSHARABLE_CLASS(CCommLinkStatus) : public CActive

/**

@internalComponent

*/

	{

friend class MComm;

public:

	CCommLinkStatus(MComm* aComm);

	virtual ~CCommLinkStatus();

	virtual void RunL();

	virtual void DoCancel();

	virtual void NotifyDisconnect();

	virtual void SetRole(TCommRole aRole);

private:

	MComm *iComm;

	TUint iSignals;

	TUint iSavedSignalState;

	TCommRole iRole;

	TUint iNotifyChangeSignalMask;

	};

#if !defined(__EABI__) && !defined(__X86GCC__)

EXPORT_C MComm::MComm()

/**

Constructor

*/

	{

	}

#endif

EXPORT_C void MComm::CommDelete()

	{

	delete iCommReader;

	delete iCommWriter;

	delete iCommLinkStatus;

	iCommPort.Close();

	iCommServer.Close();

	}

EXPORT_C TInt MComm::CommOpen(const TDesC& aDll, const TDesC& aName, TCommAccess aMode)

	{

	return CommOpen(aDll, aName, aMode, ECommRoleDTE);

	}

EXPORT_C TInt MComm::CommOpen(const TDesC& aDll, const TDesC& aName, TCommAccess aMode, TCommRole aRole)

	{

	LOG( NifmanLog::Printf(_L("MComm:\t\t\tOpening CSY '%S' Port '%S' Role '%d'"), &aDll, &aName, aRole); )

	__ASSERT_ALWAYS(iCommLinkStatus!=NULL, NetUtilPanic(ENuPanic_NotConstructed));

    iCommLinkStatus->SetRole(aRole);

	TInt err;

	if (err = iCommServer.Connect(), err!=KErrNone)

		{

		LOG( NifmanLog::Printf(_L("MComm:\t\t\tConnect failed (error is %d)"), err); )

		return err;

		}

	if (aDll.Length()>0)

		{

		if (err = iCommServer.LoadCommModule(aDll), err!=KErrNone)

			{

			LOG( NifmanLog::Printf(_L("MComm:\t\t\tCould not open CSY '%S' (error is %d)"), &aDll, err); )

			iCommServer.Close();

			return err;

			}

		}

	if (err = iCommPort.Open(iCommServer, aName, aMode, aRole), err!=KErrNone)

		{

		LOG( NifmanLog::Printf(_L("MComm:\t\t\tCould not open Port '%S' (error is %d)"), &aName, err); )

		iCommServer.Close();

		return err;

		}

	return KErrNone;

	}

EXPORT_C TInt MComm::CommOpen(const TDesC& aName, TCommAccess aMode)

	{

	LOG( NifmanLog::Printf(_L("MComm:\t\t\tOpening Port '%S'"), &aName); )

	TInt err;

	if (err = iCommServer.Connect(), err!=KErrNone)

		return err;

	if (err = iCommPort.Open(iCommServer, aName, aMode), err!=KErrNone)

		{

		LOG( NifmanLog::Printf(_L("MComm:\t\t\tCould not open Port '%S' (error is %d)"), &aName, err); )

		iCommServer.Close();

		return err;

		}

	return KErrNone;

	}

EXPORT_C void MComm::CommClose()

	{

	iCommReader->Cancel();

	iCommWriter->Cancel();

	iCommLinkStatus->Cancel();

	iCommPort.Close();

	iCommServer.Close();

	}

EXPORT_C void MComm::CommConstructL(TInt aReadPriority, TInt aWritePriority)

	{

	iCommReader = new (ELeave) CCommReader(this, aReadPriority);

	iCommWriter = new (ELeave) CCommWriter(this, aWritePriority);

	iCommLinkStatus = new (ELeave) CCommLinkStatus(this);

	}

EXPORT_C void MComm::CommWrite(const TDesC8& aDes)

	{

	__ASSERT_ALWAYS(iCommWriter!=NULL, NetUtilPanic(ENuPanic_NotConstructed));

	iCommPort.Write(iCommWriter->iStatus, aDes);

	iCommWriter->SetActive();

	iCommLinkStatus->NotifyDisconnect();

	}

EXPORT_C void MComm::CommWriteReady()

	{

	__ASSERT_ALWAYS(iCommWriter!=NULL, NetUtilPanic(ENuPanic_NotConstructed));

	iCommPort.Write(iCommWriter->iStatus, TPtrC8(NULL, 0));

	iCommWriter->SetActive();

	iCommLinkStatus->NotifyDisconnect();

	}

EXPORT_C TBool MComm::CommIsWriting() const

	{

	return iCommWriter->IsActive();

	}

EXPORT_C void MComm::CommRead(TDes8& aDes)

	{

	__ASSERT_ALWAYS(iCommReader!=NULL, NetUtilPanic(ENuPanic_NotConstructed));

	iCommPort.Read(iCommReader->iStatus, aDes, aDes.Length());

	iCommReader->SetActive();

	iCommLinkStatus->NotifyDisconnect();

	}

EXPORT_C void MComm::CommReadOneOrMore(TDes8& aDes)

	{

	__ASSERT_ALWAYS(iCommReader!=NULL, NetUtilPanic(ENuPanic_NotConstructed));

	iCommPort.ReadOneOrMore(iCommReader->iStatus, aDes);

	iCommReader->SetActive();

	iCommLinkStatus->NotifyDisconnect();

	}

EXPORT_C void MComm::CommReadReady()

	{

	__ASSERT_ALWAYS(iCommReader!=NULL, NetUtilPanic(ENuPanic_NotConstructed));

	iCommReader->SetActive();

	iCommLinkStatus->NotifyDisconnect();

	}

EXPORT_C TBool MComm::CommIsReading() const

	{

	return iCommReader->IsActive();

	}

EXPORT_C void MComm::CommCancel()

	{

	if (iCommWriter)

		iCommWriter->Cancel();

	if (iCommReader)

		iCommReader->Cancel();

	if (iCommLinkStatus)

		iCommLinkStatus->Cancel();

	}

EXPORT_C void MComm::CommWriteCancel()

	{

	if (iCommWriter)

		iCommWriter->Cancel();

	}

EXPORT_C void MComm::CommReadCancel()

	{

	if (iCommReader)

		iCommReader->Cancel();

	}

//

CCommWriter::CCommWriter(MComm* aComm, TInt aPriority)

	: CActive(aPriority), iComm(aComm)

	{

	CActiveScheduler::Add(this);

	}

CCommWriter::~CCommWriter()

	{

	Cancel();

	}

void CCommWriter::RunL()

	{

	iComm->CommWriteCancel();

	iComm->CommWriteComplete(iStatus.Int());

	}

void CCommWriter::DoCancel()

	{

	iComm->iCommPort.WriteCancel();

	}

void CCommWriter::CompleteNow(TInt aError)

	{

	TRequestStatus* statusPtr=&iStatus;

	User::RequestComplete(statusPtr,aError);

	}

//

CCommReader::CCommReader(MComm* aComm, TInt aPriority)

	: CActive(aPriority), iComm(aComm)

	{

	CActiveScheduler::Add(this);

	}

CCommReader::~CCommReader()

	{

	Cancel();

	}

void CCommReader::RunL()

	{

	iComm->CommReadCancel();

	iComm->CommReadComplete(iStatus.Int());

	}

void CCommReader::DoCancel()

	{

	iComm->iCommPort.ReadCancel();

	}

void CCommReader::CompleteNow(TInt aError)

	{

	TRequestStatus* statusPtr=&iStatus;

	User::RequestComplete(statusPtr,aError);

	}

//

CCommLinkStatus::CCommLinkStatus(MComm* aComm)

	: CActive(EPriorityHigh), iComm(aComm)

	{

	iRole = ECommRoleDTE;

	iNotifyChangeSignalMask = KSignalDCD; // Defaults to KSignalDCD

	CActiveScheduler::Add(this);

	}

CCommLinkStatus::~CCommLinkStatus()

	{

	Cancel();

	}

void CCommLinkStatus::SetRole(TCommRole aRole)

    {

    iRole = aRole;

	if (iRole==ECommRoleDCE)

	    {

	    iNotifyChangeSignalMask = KSignalDTR;

	    }

	else

	    {

	    iNotifyChangeSignalMask = KSignalDCD; // Defaults to KSignalDCD

	    }

    }

void CCommLinkStatus::NotifyDisconnect()

	{

	if(IsActive())	// if we have already set up notification

		return;		// there is nothing to do now

	// get the current state of the line so when we get notification we can tell if it really has changed	

	iSavedSignalState = iComm->iCommPort.Signals (iNotifyChangeSignalMask) & iNotifyChangeSignalMask ;

	iComm->iCommPort.NotifySignalChange(iStatus, iSignals, iNotifyChangeSignalMask);

	SetActive();

	}

void CCommLinkStatus::RunL()

	{

	// We should only tear down the connection if DCD/DTR (depending on role) is low.

	//   and if the signal has changed (i.e. it was high)

	if (!(iNotifyChangeSignalMask & iSignals) && (iNotifyChangeSignalMask & iSavedSignalState)) 

		{

		if (iComm->CommIsReading())

			{

			iComm->CommReadCancel();

			iComm->CommReadComplete(KErrCommsLineFail);

			}

		if (iComm->CommIsWriting())

			{

			iComm->CommWriteCancel();

			iComm->CommWriteComplete(KErrCommsLineFail);

			}

		}

		iSavedSignalState = iSignals & iNotifyChangeSignalMask ;	// update saved state

	}

void CCommLinkStatus::DoCancel()

	{

	iComm->iCommPort.NotifySignalChangeCancel();

	}