bthci/hci2implementations/hctls/bcsp/inc/hctlbcspsequencer.h
changeset 0 29b1cd4cb562
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/bthci/hci2implementations/hctls/bcsp/inc/hctlbcspsequencer.h	Fri Jan 15 08:13:17 2010 +0200
@@ -0,0 +1,103 @@
+// 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