// Copyright (c) 2006-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:
//

/**
 @file
 @internalComponent
*/


#ifndef HCTLBCSPSEQUENCER_H
#define HCTLBCSPSEQUENCER_H

#include <e32base.h>

class CDelay;
class CHCTLBcsp;
class RBusDevComm;
class CHCTLBcspFrameQueue;
class CHCTLBcspSender;
class CRxHctlBcspFrame;

NONSHARABLE_CLASS(CHCTLBcspSequencer) :public CBase
/**
CHCTLBcspSequencer
Provides the Sequencing layer as described in the BCSP Spec. this permits reliable retransmission
of ACL and Command Data and in the final version of BCSP a windowing mechanism allowing multiple 
frames < 7 to be transmitted without acknowledgment for each individual frame.
  	
This class is not intended for derivation.
*/
	{
public:
	static CHCTLBcspSequencer* NewL(CHCTLBcsp& aHCTLbcsp, RBusDevComm& aPort,CHCTLBcspFrameQueue& aBcspFrameQueue);
	~CHCTLBcspSequencer();
	
	void WakeUp();			// Set the state machine to ESending and then in Entry() does the same as SendNextPacket()
	void SendNextPacket();	// Gets next packet from iBcspFrameQueue and Sends it directly to the UART
	void HandleRxAck();		// Triggers removal of Acked frames
	void SendPacket(TDesC8* aFrame, TBool aIsReliable);

	TInt SendQueuedFrame();

	void HandleRx(CRxHctlBcspFrame* aFrame);
	
	TUint8 TxAck() const;
	void ResendState();
	void HandleRxAckTimeout();

 	//BCSP peer reset functions
 	void Reset();
 	void HandlePeerReset();

private:
	CHCTLBcspSequencer(CHCTLBcsp& aHCTLbcsp, CHCTLBcspFrameQueue& aBcspFrameQueue);
    void ConstructL(RBusDevComm& aPort);
	void UpdateTxAckVal();
	void StartRxAckTimer();
	void StartTxAckTimer();
	void TxAckMsg();
	
	static TInt TxTimeout(TAny* aThis);
	static TInt RxTimeout(TAny* aThis);

private:
	enum TBcspRelRxState
		{
		EIdle,
		EReceiving
		};

	TUint8 iRxAck;	//Updated by HandleRx()
	TUint8 iRxSeq;
	TUint8 iRxSeqExpected;
	TUint8 iRxSeqLast;
	TUint8 iPacketAvail;

	TUint8 iTxAck;

	TBcspRelRxState iRelRxState;

	TUint8 iRxTimeoutCount;
	CDelay* iRxAckTimer;
	CDelay* iTxAckTimer;

	CHCTLBcsp& iHctlBcsp;
	CHCTLBcspFrameQueue& iFrameQueue;

	CHCTLBcspSender* iSender;
	};
	
#endif // HCTLBCSPSEQUENCER_H