/*

* Copyright (c) 2005-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: 

*

*/

/********************************************************************************

 *

 * Stat Packetisation Transport

 *

 *******************************************************************************/

#ifndef __STATPACKETISATION_H__

#define __STATPACKETISATION_H__

/********************************************************************************

 *

 * System Includes

 *

 *******************************************************************************/

/********************************************************************************

 *

 * Local Includes

 *

 *******************************************************************************/

#include "stat_interfaces.h"

/********************************************************************************

 *

 * Definitions

 *

 *******************************************************************************/

#define KIDSize				4

#define KLengthSize			4

#define KHeaderSize			(KIDSize + KLengthSize)

/********************************************************************************

 *

 * Classes

 *

 *******************************************************************************/

class CStatTransportPacketisation : public CBase, public MStatApiTransport, public MNotifyStatTransport

{

public:

	// construction

	static CStatTransportPacketisation *NewL( MNotifyStatEngine *aStatEngine, MStatNetwork *aStatNetwork, TUint aPacketSize );

	CStatTransportPacketisation();

	virtual ~CStatTransportPacketisation();

	// from MStatApiTransport

	TInt InitialiseL( void );

	TInt ConnectL( TDesC *aRemoteHost );

	TInt RequestSend( const TUint aCommand, MDataSupplier *const aDataSupplier);

	TInt RequestReceive( void );

	TInt Disconnect( void );

	TInt Release( void );

	TText8 *Error( void );

	// from MNotifyStatTransport

	void HandleInitialise( TInt aResult );

	void HandleConnect( TInt aResult );

	void HandleSend( TInt aResult );

	void HandleReceive( TInt aResult, TDesC8 *aData, TUint aDataLength );

	void HandleDisconnect( TInt aResult );

	void HandleRelease( TInt aResult );

	void HandleError( TInt aError, void *aErrorData );

	void HandleInfo( const TDesC *aInfo );

private:

	// private helper functions

	void ConstructL( MNotifyStatEngine *aStatEngine, MStatNetwork *aStatNetwork, TUint aPacketSize );

	void SendHeaderPacket( TUint aCommand, TUint aDataLength );

	void SendAckPacket( TUint aCommand );

	void BuildHeader( TUint aCommand, TUint aDataLength );

	void NotifyEngineSend( TUint aResult );

	void NotifyEngineReceive( TUint aResult );

private:

	// status enums

	enum TSendStatus { ESendIdle, ESendingInitialHeader, ESendingFragmentHeader, ESendingFragmentData, ESendingFragmentAck };

	enum TReceiveStatus { EReceiveIdle, EReceivingInitialHeader, EReceivingFragmentHeader, EReceivingData, EReceivingFragmentAck };

private:	

	// general members

	MNotifyStatEngine *iStatEngine;

	MStatNetwork *iStatNetwork;

	TCommStatus iTransportStatus;

	TSendStatus iSendStatus;

	TReceiveStatus iRecvStatus;

	TUint iDataPacketSize;

	// send buffers

	TBuf8<KHeaderSize> iSendHeader;

	HBufC8 *iSendFragment;

	TUint iSendCommand;

	TUint iSendDataLength;

	TUint iSendDataWritten;

	TUint iSendDataAcknowledged;

	// receive buffers

	TUint iRecvCommand;

	TUint iRecvDataLength;

	TUint iRecvDataReceived;

	TUint iRecvDataAcknowledged;

	MDataConsumer *iDataConsumer;	// The data consumer is 

									// use to pass data from the

									// transport layer to the 

									// command decoder.

									// Each specific object is

									// valid for the context of a 

									// single command (and 

									// destroyed).

	MDataSupplier *iDataSupplier;	// This is owned by other

									// objects and we are passed

									// a pointer for our own use

									// but we do not maintain this.

};

#endif // __STATTCPIP_H__