/*

* 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