--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/realtimenetprots/sipfw/SIP/Server/src/CSipCSReceiveQueue.cpp	Tue Feb 02 01:03:15 2010 +0200
@@ -0,0 +1,108 @@
+// 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:
+// Name          : CSipCSReceiveQueue.cpp
+// Part of       : SIPServerCore
+// Version       : SIP/4.0 
+//
+
+
+
+
+#include "CSipCSReceiveQueue.h"
+#include "sipmessage.h"
+
+// -----------------------------------------------------------------------------
+// CSipCSReceiveQueue::CSipCSReceiveQueue
+// -----------------------------------------------------------------------------
+//
+CSipCSReceiveQueue::CSipCSReceiveQueue ()
+	{
+    iReceiveItems.Reset();
+	}	
+
+// -----------------------------------------------------------------------------
+// CSipCSReceiveQueue::~CSipCSReceiveQueue
+// -----------------------------------------------------------------------------
+//
+CSipCSReceiveQueue::~CSipCSReceiveQueue ()
+	{
+	while (iReceiveItems.Count() > 0) 
+        {
+        RemoveFirst();
+        }
+	iReceiveItems.Close();
+	}
+
+// -----------------------------------------------------------------------------
+// CSipCSReceiveQueue::IsEmpty
+// -----------------------------------------------------------------------------
+//
+TBool CSipCSReceiveQueue::IsEmpty () const
+	{ 
+	return (iReceiveItems.Count() == 0); 
+	}
+
+// -----------------------------------------------------------------------------
+// CSipCSReceiveQueue::First
+// -----------------------------------------------------------------------------
+//
+TSipCSReceiveItem& CSipCSReceiveQueue::First ()
+	{
+    __ASSERT_ALWAYS (iReceiveItems.Count() > 0, 
+                     User::Panic(KNullDesC, KErrGeneral));
+    return iReceiveItems[0];
+	}
+
+// -----------------------------------------------------------------------------
+// CSipCSReceiveQueue::AddLast
+// -----------------------------------------------------------------------------
+//
+TInt CSipCSReceiveQueue::AddLast (const TSipCSReceiveItem& aItem)
+    {
+	return iReceiveItems.Append(aItem);
+    }
+    
+// -----------------------------------------------------------------------------
+// CSipCSReceiveQueue::RemoveFirst
+// -----------------------------------------------------------------------------
+//
+void CSipCSReceiveQueue::RemoveFirst ()
+	{
+	if (iReceiveItems.Count() > 0) 
+        {
+        TSipCSReceiveItem& item = iReceiveItems[0];
+        delete item.Headers();
+        delete item.Content();
+	    iReceiveItems.Remove(0);
+        }
+	}
+	
+// -----------------------------------------------------------------------------
+// CSipCSReceiveQueue::RemoveSIPRequestsWith
+// -----------------------------------------------------------------------------
+//
+void CSipCSReceiveQueue::RemoveSIPRequestsWith (TTransactionId aTransactionId)
+	{
+	for (TInt i=iReceiveItems.Count()-1; i>=0; i--)
+		{
+		TSipCSReceiveItem& item = iReceiveItems[i];
+		if (item.Ids().iRequestId ==  aTransactionId && 
+		    item.ContainsSIPRequest())
+			{
+        	delete item.Headers();
+        	delete item.Content();
+	    	iReceiveItems.Remove(i);
+			}
+		}
+	}