--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/accessoryservices/remotecontrolfw/server/src/messagequeue.cpp	Tue Feb 02 00:53:00 2010 +0200
@@ -0,0 +1,178 @@
+// 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
+	}