// Copyright (c) 2002-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:
// wins/specific/winscomm.h
// 
//

#ifndef __M32COMM_H__
#define __M32COMM_H__
#include <platform.h>
//#include <kpower.h>
#include <d32comm.h>
#include <e32ver.h>
//
const TInt KCommsMajorVersionNumber=1;
const TInt KCommsMinorVersionNumber=1;
const TInt KCommsBuildVersionNumber=KE32BuildVersionNumber;

//
enum TStopMode {EStopNormal,EStopPwrDown,EStopEmergency};
//
//
class DChannelComm;
class DComm : public DBase
	{
public:
	virtual TInt Start() =0;
	virtual void Stop(TStopMode aMode) =0;
	virtual void Break(TBool aState) =0;
	virtual void Write(DThread*,TAny*,TInt) = 0;
	virtual void Read(DThread*,TAny*,TInt) = 0;
	virtual void NotifySignals(DThread*, TInt) = 0;
	virtual void NotifyDataAvailable() = 0;
	virtual TUint Signals() const =0;
	virtual void SetSignals(TUint aSetMask,TUint aClearMask) =0;
	virtual TInt ValidateConfig(const TCommConfigV01 &aConfig) const =0;
	virtual void Configure(TCommConfigV01 &aConfig) =0;
	virtual void Caps(TDes8 &aCaps) const =0;
	virtual void CheckConfig(TCommConfigV01& aConfig)=0;
	virtual TDfcQue* DfcQ(TInt aUnit)=0;
	inline void SetCurrent(TInt aCurrent);
	inline TBool Transmitting();
	virtual TInt RxCount() =0;
	virtual void ResetBuffers(TBool) = 0;
	virtual TInt SetRxBufferSize(TInt aSize) = 0;
	virtual TInt RxBufferSize() =0;
	virtual TDes8* RxBuffer() =0;
	virtual TBool AreAnyPending() = 0;
	virtual void ReadCancel() = 0;
	virtual void WriteCancel() = 0;
	virtual void SignalChangeCancel() = 0;

public:
	DChannelComm *iLdd;
	TBool iTransmitting;
	TUint8 * iInBufPtr;
	TUint8 * iOutBufPtr;

	};


class DDeviceComm : public DLogicalDevice
	{
public:
	DDeviceComm();
	virtual TInt Install();
	virtual void GetCaps(TDes8 &aDes) const;
	virtual TInt Create(DLogicalChannelBase*& aChannel);
	};

//class DCommPowerHandler;
class DChannelComm : public DLogicalChannel
	{
public:
	enum TState {EOpen,EActive,EClosed};
	enum TRequest {ERx=1, ETx=2, ESigChg=4, ERxDA=8, EAll=0xff};

	DChannelComm();
	~DChannelComm();
	inline void SetStatus(TState aStatus);
	TInt TurnaroundSet(TUint aNewTurnaroundMilliSeconds);
	TBool TurnaroundStopTimer();
	TInt TurnaroundClear();
	static void TurnaroundStartDfc(TAny* aSelf);
	void TurnaroundStartDfcImplementation(TBool inIsr);
	static void TurnaroundTimeout(TAny* aSelf);
	void TurnaroundTimeoutImplementation(void);

protected:
	virtual TInt DoCreate(TInt aUnit, const TDesC8* aInfo, const TVersion& aVer);
	virtual void HandleMsg(TMessageBase* aMsg);
	void DoCancel(TInt aMask);
	TInt DoControl(TInt aId, TAny* a1, TAny* a2);
	TInt DoRequest(TInt aId, TRequestStatus* aStatus, TAny* a1, TAny* a2);
	void Start();
	void Shutdown();
	void BreakOn();
	void BreakOff();
	void ResetBuffers(TBool aResetTx);
	void DoCompleteRx();
	void DoCompleteTx();
	void DoSignalNotify();
	void DoRxDataAvailable();
	void Complete(TInt aMask, TInt aReason);
	inline void CompleteRead()	{ iRxCompleteDfc.Add(); }
	inline void CompleteWrite() { iTxCompleteDfc.Add(); }
protected:
	inline void Write(DThread* aT, TAny* aP, TInt aL) {((DComm*)iPdd)->Write(aT, aP,aL);}
	inline void Read(DThread* aT, TAny* aP, TInt aL) {((DComm*)iPdd)->Read(aT, aP,aL);}
	inline void NotifySignals(DThread* aThread, TInt aMask) {((DComm*)iPdd)->NotifySignals(aThread, aMask);}
	inline void NotifyDataAvailable() {((DComm*)iPdd)->NotifyDataAvailable(); }
	inline TInt PddStart();
	inline void Stop(TStopMode aMode);
	inline void PddBreak(TBool aState);
	inline TUint Signals() const;
	inline void SetSignals(TUint aSetMask,TUint aClearMask);
	inline TInt ValidateConfig(const TCommConfigV01 &aConfig) const;
	inline void PddConfigure(TCommConfigV01 &aConfig);
	inline void PddCaps(TDes8 &aCaps) const;
	inline void PddCheckConfig(TCommConfigV01& aConfig);
	inline TBool Transmitting();
	inline TInt BufferSize();
	inline void ReadCancel();
	inline void WriteCancel();
	inline void SignalChangeCancel();
private:
//	static void PowerUpDfc(TAny* aPtr);
//	static void PowerDownDfc(TAny* aPtr);
	static void CompleteRxDfc(TAny* aPtr);
	static void CompleteTxDfc(TAny* aPtr);
	static void SignalNotifyDfc(TAny* aPtr);
	static void RxDataAvailableDfc(TAny* aPtr);
	inline TInt RxCount();
	inline TInt RxBufferSize();
	inline TDes8* RxBuffer();
	inline TInt SetRxBufferSize(TInt aSize);
	inline TBool AreAnyPending() const;
//	void UpdateSignals();
	void UpdateAndProcessSignals();
	void InitiateRead(TAny* aRxDes, TInt aLength);
	void InitiateWrite(TAny* aTxDes, TInt aLength);
	void InitiateNotifySignals(TAny* aResult, TInt aMask);
	void NotifyReadDataAvailable();
//	TUint FailSignals(TUint aHandshake);
//	TUint HoldSignals(TUint aHandshake);
//	TUint FlowControlSignals(TUint aHandshake);
//	TUint AutoSignals(TUint aHandshake);
	TInt SetConfig(TCommConfigV01& aConfig);
//	void CheckOutputHeld();
//	void ReleaseBuffers();

	// Min Turnaround time between Rx and Tx
	TUint		iTurnaroundMicroSeconds;		// delay after a receive before transmission in us
	TUint		iTurnaroundMinMilliSeconds;		// delay after a receive before transmission in ms
	TBool		iTurnaroundTimerRunning;		// a receive has started the timer
	TBool		iTurnaroundTransmitDelayed;		// a transmission is held until time elapses after a receive
	NTimer		iTurnaroundTimer;				// used to delay transmission after a receive
	TDfc		iTurnaroundDfc;					// used in interrupt space, to trigger a call in user space

	TAny*		iTurnaroundTxDesPtr;			// client descriptor awaiting transmission
	TInt		iTurnaroundTxDesLength;			// initial size of tx descriptor

public:
	// Port configuration
	TCommConfigV01 iConfig;

	// General items
	DThread* iClient;
	TAny* iClientDestPtr;
//	DCommPowerHandler* iPowerHandler;
//	TDfc iPowerUpDfc;
//	TDfc iPowerDownDfc;
//	TUint32 iPowerDownMask;
	TState iStatus;
	TDfc iRxCompleteDfc;
	TDfc iTxCompleteDfc;
	TDfc iRxDataAvailableDfc;
	TDfc iSigNotifyDfc;
	TUint iFlags;				//
	TUint iSignals;				// State of handshake lines
//	TUint iFailSignals;			// 1 bit means line low causes line fail error
//	TUint iHoldSignals;			// 1 bit means line low halts TX
//	TUint iFlowControlSignals;	// 1 bit means signal is used for RX flow control
//	TUint iAutoSignals;			// 1 bit means signal is high when channel is open
	TBool iShutdown;			// ETrue means device is being closed
	TBool iMsgHeld;				// ETrue means a message has been held up waiting power on

	// RX client related items
	TInt iRxError;
	TRequestStatus* iRxStatus;


	// TX client related items
	TInt iTxError;
	TRequestStatus* iTxStatus;

	// DataAvailable client related items
	TInt iRxDAError;
	TRequestStatus* iRxDAStatus;

	// Signal change notification
	TInt iSignalError;
	TRequestStatus* iSignalStatus;	
	TUint* iClientSignalResultPtr;	//ptr to uint in client address space
	TUint iSignalResult;			//holds result of the signal (in Symbian OS values)
	};

//class DCommPowerHandler : public DPowerHandler
//	{
//public:
//	DCommPowerHandler(DChannelComm* aChannel);
//	virtual TInt DoPowerUp();
//	virtual void DoPowerDown(TUint32 aPowerDownMask);
//	virtual void DoEmergencyPowerDown();
//public:
//	DChannelComm* iChannel;
//	};

#include "winscomm.inl"

#endif