// 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 "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:

//

/**

 @file

 @internalComponent

*/

#include <bluetooth/logger.h>

#include "messagequeue.h"

#include "utils.h"

#include "remconmessage.h"

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, LOG_COMPONENT_REMCON_SERVER);

#endif

#ifdef _DEBUG

PANICCATEGORY("msgqueue");

#endif

CMessageQueue* CMessageQueue::NewL()

	{

	LOG_STATIC_FUNC

	return new(ELeave) CMessageQueue();

	}

CMessageQueue::CMessageQueue()

:	iQueue(_FOFF(CRemConMessage, iLink)),

	iIter(iQueue)

	{

	LOG_FUNC

	}

CMessageQueue::~CMessageQueue()

	{

	LOG_FUNC;

	LogQueue();

	iIter.SetToFirst(); 

	CRemConMessage* msg;

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

		{

		iQueue.Remove(*msg);

		--iCount;

		delete msg;

		}

	LogQueue();

	}

TSglQueIter<CRemConMessage>& CMessageQueue::SetToFirst()

	{

	LOG_FUNC;

	iIter.SetToFirst();

	return iIter;

	}

void CMessageQueue::Append(CRemConMessage& aMsg)

	{

	LOG_FUNC;

	LogQueue();

	iQueue.AddLast(aMsg);

	++iCount;

	LogQueue();

	}

void CMessageQueue::RemoveAndDestroy(CRemConMessage& aMsg)

	{

	LOG_FUNC;

	LOG1(_L("\t&aMsg = [0x%08x]"), &aMsg);

	Remove(aMsg);

	delete &aMsg;

	}

void CMessageQueue::RemoveAndDestroy(TUint aSessionId)

	{

	LOG_FUNC;

	LOG1(_L("\taSessionId = %d"), aSessionId);

	TSglQueIter<CRemConMessage> iter(iQueue);

	CRemConMessage* msg;

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

		{

		if ( msg->SessionId() == aSessionId )

			{

			RemoveAndDestroy(*msg);

			}

		}

	}

void CMessageQueue::Remove(CRemConMessage& aMsg)

	{

	LOG_FUNC;

	LOG1(_L("\t&aMsg = [0x%08x]"), &aMsg);

	LogQueue();

	iQueue.Remove(aMsg);

	--iCount;

	LogQueue();

	}

CRemConMessage& CMessageQueue::First()

	{

	LOG_FUNC;

	CRemConMessage* msg = iQueue.First();

	ASSERT_DEBUG(msg);

	return *msg;

	}

CRemConMessage* CMessageQueue::Message(TUint aTransactionId)

	{

	LOG_FUNC;

	LOG1(_L("\taTransactionId = %d"), aTransactionId);

	TSglQueIter<CRemConMessage> iter(iQueue);

	CRemConMessage* msg;

	CRemConMessage* ret = NULL;

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

		{

		if ( msg->TransactionId() == aTransactionId )

			{

			ret = msg;

			break;

			}

		}

	return ret;

	}

void CMessageQueue::LogQueue() const

	{

#ifdef __FLOG_ACTIVE

	LOG2(_L("\tthis = 0x%08x, iCount = %d"), this, iCount);

	// Make our own local iterator so we don't interfere with one the client 

	// may be relying on.

	TSglQueIter<CRemConMessage> iter(const_cast<CMessageQueue*>(this)->iQueue);

	CRemConMessage* msg;

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

		{

		LOG4(_L("\t\tmsg [0x%08x], Addr.BearerUid = 0x%08x, MsgType = %d, InterfaceUid = 0x%08x,"),

			msg,

			msg->Addr().BearerUid(),

			msg->MsgType(),

			msg->InterfaceUid()

			);

		LOG3(_L("\t\tOperationId = 0x%02x, SessionId = %d, TransactionId = %d"),

			msg->OperationId(),

			msg->SessionId(),

			msg->TransactionId()

			);

		// This logging code left in for maintenance.

		//LOG1(_L("\t\tOperationData = \"%S\""), &msg->OperationData());

		}

#endif // __FLOG_ACTIVE

	}