/*

* Copyright (c) 2005 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:    Implementation.

*

*/

#include "CTcMCEReceiveQueue.h"

#include "CTcMCEReceived.h"

#include "CTcMCEContext.h"

CTcMCEReceiveQueue* CTcMCEReceiveQueue::NewL( CTcMCEContext& aContext )

	{

	CTcMCEReceiveQueue* self = new (ELeave) CTcMCEReceiveQueue( aContext );

	CleanupStack::PushL( self );

	self->ConstructL();

	CleanupStack::Pop( self );

	return self;	

	}

CTcMCEReceiveQueue::CTcMCEReceiveQueue( CTcMCEContext& aContext ) :

	iReceiveQueue( 1 ),

	iContext( aContext )

	{

	}

void CTcMCEReceiveQueue::ConstructL()

	{

	iTimer = CDeltaTimer::NewL( CActive::EPriorityStandard );

	TCallBack cb( ReceiveTimeout, this );

	iReceiveTimeout.Set( cb );	

	}

CTcMCEReceiveQueue::~CTcMCEReceiveQueue()

	{

	delete iTimer;

	iReceiveQueue.Reset();

	}

// -- Received queue handling -------------------------------------------------

CTcMCEReceived& CTcMCEReceiveQueue::ReceivedItemL( TInt aTimeout )

	{

	if( iReceiveQueue.Count() == 0 )

		{

		iTimer->Queue( aTimeout * KSecondAsMicros, iReceiveTimeout );

		iActiveWait.Start();

		}

	// Check if the queue is still empty (i.e. timeout occurred)

	if( iReceiveQueue.Count() == 0 )

		{

		User::Leave( KErrTimedOut );

		}

	// Get the first (oldest) item from the array

	TBuf8< KTcMaxObjectName > itemName = iReceiveQueue[ 0 ];

	// ..and remove it from the array

	iReceiveQueue.Delete( 0 );

	iReceiveQueue.Compress();

	// Fetch the corresponding object from the registry

	CTcMCEReceived* item = 

		reinterpret_cast<CTcMCEReceived*>

			(iContext.Registry().ObjectPtrL( itemName ));

	return *item;

	}

void CTcMCEReceiveQueue::QueueReceivedL( CTcMCEReceived* aItem )

	{	

	// Add to registry and fetch name

	iContext.Registry().AddObjectL( reinterpret_cast< CBase* >( aItem ) );	

	TBuf8< KTcMaxObjectName > itemName = 

				iContext.Registry().ObjectNameL( aItem );	

	// Add name to queue

	iReceiveQueue.AppendL( itemName );

	if( iActiveWait.IsStarted() )

		{

		iTimer->Remove( iReceiveTimeout );

		iActiveWait.AsyncStop();

		}

	}

TInt CTcMCEReceiveQueue::ReceiveTimeout( TAny* aSelf )

	{

	CTcMCEReceiveQueue& self =

				*reinterpret_cast< CTcMCEReceiveQueue* >( aSelf );

	if( self.iActiveWait.IsStarted() )

		{

		self.iActiveWait.AsyncStop();

		}

	return KErrNone;

	}