/*

 * Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).

 * All rights reserved.

 * This component and the accompanying materials are made available

 * under the terms of the License "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:

 *

 */

 #if (!defined __ACTIVEIO_H__)

 #define __ACTIVEIO_H__

 #include <e32base.h>

 class CIOBuffer : public CBase

 	{

 public:

 	~CIOBuffer();

 	HBufC8*	Data() const;

 	void FreeData();

 	TPtr8& Ptr();

 	void Assign(HBufC8* aBuffer = NULL);

     static CIOBuffer* NewL(HBufC8* aBuf = NULL);

     static CIOBuffer* NewL(const TInt aSize);

 	static TInt LinkOffset();

 private:

 	CIOBuffer();

 	void ConstructL(const TInt aSize);

 	void ConstructL(HBufC8* aBuffer);

 	TSglQueLink iLink;

 	HBufC8* iBuf;

 	TPtr8 iBufPtr;

 	};

 ///////

 // Pure Abstract 'M' interface classes that CDemoControl derives from

 class MWriterNotify

 	{

 public:

 	virtual void WriteCompleteL(const TInt aStatus) = 0;

 	};

 class MReaderNotify

 	{

 public:

 	virtual void ReadCompleteL(const TInt aStatus) = 0;

 	};

 ///////

 class CDemoWriter : public CActive

 // Active object class for writing to the server

 	{

 public:

 	~CDemoWriter();

 	static CDemoWriter* NewL(MWriterNotify& aNotify,RBusDevEthernet& aCard);

 	void WriteL(const TDesC8& aBuffer);

 	void RunL();

 	void DoCancel();

 private:

 	// Construct with pointer to the notifier and reference to the server session

 	void ConstructL(MWriterNotify& aNotify,RBusDevEthernet& aCard);

 	CDemoWriter(TInt aPriority) : CActive(aPriority){};

 private:

 	RBusDevEthernet *iCard;

 	MWriterNotify* iNotify;

 	};

 class CDemoReader : public CActive

 	{

 public:

 	~CDemoReader();

 	static CDemoReader* NewL(MReaderNotify& aNotify,RBusDevEthernet& aCard);

 	void RunL();

 	void DoCancel();

 	void ReadL(TDes8& aBuffer);

 private:

 	void ConstructL(MReaderNotify& aNotify,RBusDevEthernet& aCard);

 	CDemoReader(TInt aPriority) : CActive(aPriority){};

 private:

 	MReaderNotify* iNotify;

 	RBusDevEthernet *iCard;

 	};

 // C Class derived fron CActive

 // CActive derived from CBase

 // See PSP Chapter 18 Active Objects

 class CDemoControl : public CActive , public MReaderNotify , public MWriterNotify

 	{

 public:

 	~CDemoControl();

 	static CDemoControl* NewLC();

 	// Mandatory Overrides of CActive pure virtuals

 	void RunL();

 	void DoCancel();

 	static TInt Callback(TAny* aCtrl);

 	void RequestCharacter();

 	virtual void WriteCompleteL(const TInt aStatus);

 	virtual void ReadCompleteL(const TInt aStatus);

 	void ReadAndSetDestMacL();

 	void ReadAndDisplaySettings();

 	CIOBuffer* CreateRandomPacketL(TInt aOffset);

 	void SendAndCompareEchoL();

 	void CompareEcho();

 	void HandleWriteCompleteSndCmpEchoModeL();

 	void HandleReadCompleteSndCmpEchoModeL();

 private:

 	void ConstructL();

 	CDemoControl(TInt aPriority) : CActive(aPriority){};

 	void ProcessKeyPress(TChar aChar);

 	void HelpText() const;

 	void StartCardL();

 	void StopCard();

 	void EchoL();

 	void PumpL();

 	void ReadL();

 	void StopL();

 	void PrintError(TChar aChar);

 	void EmptyWriteQueue();

 	void HandleWriteCompleteEchoModeL();

 	void HandleReadCompleteEchoModeL();

 	void HandleWriteCompletePumpModeL();

 	void HandleReadCompletePumpModeL();

 	void HandleReadCompleteReadModeL();

 	void FlipMacAddresses(TDes8& aBuf);

 	CIOBuffer*  CreateSendPacketL();

 private:

 	enum TIfState {EIdle,EEcho,ERead,EPump,ESendAndCmpEcho};

 	TIfState iIfState;

 	CDemoWriter* iWriter;

 	CDemoReader* iReader;

 	TInt		iPacketsWritten;

 	TInt		iPacketsRead;

 	CPeriodic*	iTimer;

 	TBuf8<1600> iReadBuffer;

 	RBusDevEthernet iCard;

 	TBuf8<32>	iConfig;

 	TSglQue<CIOBuffer> iWriteQueue;

 	TBool iSendAndEchoSame;

 	TInt iIntRandomOffset;

 	TInt64 iIntSeed;

 	static TInt iSendAndEchoCmpCounter;

 	};

 #endif