// 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);

			}

		}

	}