/*

* Copyright (c) 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:  CHtiMessageQueue implementation

*

*/

#include "HtiMessageQueue.h"

CHtiMessageQueue* CHtiMessageQueue::NewL()

    {

    return new (ELeave) CHtiMessageQueue;

    }

CHtiMessageQueue::CHtiMessageQueue():

    iQueue( CHtiMessage::iLinkOffset ),

    iMemoryAllocated( 0 ),

    iQueueIter( iQueue ),

    iIsFirst ( ETrue )

    {

    }

CHtiMessageQueue::~CHtiMessageQueue()

    {

    RemoveAll();

    }

void CHtiMessageQueue::RemoveAll()

    {

    if ( !IsEmpty() )

        {

        CHtiMessage* msg;

        iQueueIter.SetToFirst();

        while ( ( msg = iQueueIter++ ) != NULL )

            {

            iQueue.Remove( *msg );

            delete msg;

            }

        }

        iMemoryAllocated = 0;

    }

CHtiMessage* CHtiMessageQueue::Remove()

    {

    CHtiMessage* msg = NULL;

    if ( !IsEmpty() )

        {

        msg = iQueue.First();

        iQueue.Remove( *msg );

        iMemoryAllocated -= msg->Size();

        }

    return msg;

    }

CHtiMessage* CHtiMessageQueue::Remove( CHtiMessage* aMsg)

    {

    if ( aMsg && !IsEmpty() )

        {

        iQueue.Remove( *aMsg );

        iMemoryAllocated -= aMsg->Size();

        return aMsg;

        }

    return NULL;

    }

void CHtiMessageQueue::StartServiceIteration()

    {

    if ( !IsEmpty() )

        {

        iQueueIter.SetToFirst();

        iIsFirst = ETrue;

        }

    }

CHtiMessage* CHtiMessageQueue::GetNext()

    {

    CHtiMessage* msg = NULL;

    if ( !IsEmpty() )

        {

        while ( ( msg = iQueueIter++ ) != NULL )

            {

            if ( iIsFirst )

                {

                iIsFirst = EFalse;

                iLastServiceUid = msg->DestinationServiceUid();

                return msg;

                }

            else if ( msg->DestinationServiceUid() != iLastServiceUid )

                {

                iLastServiceUid = msg->DestinationServiceUid();

                return msg;

                }

            }

        }

    return msg;

    }

void CHtiMessageQueue::Add( CHtiMessage& aMessage )

    {

    iQueue.AddLast( aMessage );

    iMemoryAllocated += aMessage.Size();

    }

TBool CHtiMessageQueue::IsEmpty() const

    {

    return iQueue.IsEmpty();

    }

TInt CHtiMessageQueue::QueueSize() const

    {

    return iMemoryAllocated;

    }