epoc32/include/sbque.h
branchSymbian2
changeset 2 2fe1408b6811
child 4 837f303aceeb
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/epoc32/include/sbque.h	Tue Mar 16 16:12:26 2010 +0000
@@ -0,0 +1,79 @@
+// Copyright (c) 2004-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 "Symbian Foundation License v1.0" to Symbian Foundation members and "Symbian Foundation End User License Agreement v1.0" to non-members
+// which accompanies this distribution, and is available
+// at the URL "http://www.symbianfoundation.org/legal/licencesv10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+// sbque.h - TCP sequence block queue
+// Defines a queue for keeping tabs on contiguous blocks of sequence numbers.
+//
+
+
+
+/**
+ @file sbque.h
+ @publishedAll
+ @released
+*/
+
+#ifndef __SBQUE_H__
+#define __SBQUE_H__
+
+#include "tcpseq.h"
+
+/** Sequence Block.
+@publishedAll
+@released
+*/
+class SequenceBlock
+	{
+  	friend class SequenceBlockQueue;
+
+private:
+
+    SequenceBlock(TTcpSeqNum aLeft, TTcpSeqNum aRight) : iLeft(aLeft), iRight(aRight) {}
+    TDblQueLink iLink;
+
+public:
+
+    TTcpSeqNum  iLeft;
+    TTcpSeqNum  iRight;
+	};
+
+/** Sequence Block Queue.
+@publishedAll
+@released
+*/
+class SequenceBlockQueue : public TDblQue<SequenceBlock>
+	{
+ public:
+    SequenceBlockQueue() : TDblQue<SequenceBlock>(_FOFF(SequenceBlock, iLink)) { iCount = 0; iOrdered = ETrue; }
+    inline ~SequenceBlockQueue() { Clear(); }
+    IMPORT_C SequenceBlock *AddOrdered(TTcpSeqNum aLeft, TTcpSeqNum aRight);
+    IMPORT_C SequenceBlock *AddUnordered(TTcpSeqNum aLeft, TTcpSeqNum aRight);
+    inline SequenceBlock *AddOrdered(const SequenceBlock *aBlock) { return AddOrdered(aBlock->iLeft, aBlock->iRight); }
+    inline SequenceBlock *AddUnordered(const SequenceBlock *aBlock) { return AddUnordered(aBlock->iLeft, aBlock->iRight); }
+    IMPORT_C SequenceBlock *Find(TTcpSeqNum aSeq);
+    IMPORT_C TInt FindGap(TTcpSeqNum& aLeft, TTcpSeqNum& aRight);
+    IMPORT_C void Prune(TTcpSeqNum aLeft);
+    IMPORT_C void Limit(TInt aCount);
+    IMPORT_C void Clear();
+    inline TInt Count() const { return iCount; }
+    inline TInt ByteCount() const { return iBytes; }
+
+private:
+    TInt iCount;
+    TInt iBytes;
+    TBool iOrdered;
+	};
+
+typedef TDblQueIter<SequenceBlock> SequenceBlockQueueIter;
+
+#endif