--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mmserv/voipaudioservices/VoIPServer/src/VoIPQueueHandlerSrv.cpp	Tue Feb 02 01:08:46 2010 +0200
@@ -0,0 +1,135 @@
+/*
+ * Copyright (c) 2007-2008 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:  Implements message queue handler for handling messages
+ *                passed between VoIPAudioServices threads.
+ *
+ */
+
+#include <voipaudiocommon.h>
+#include "VoIPSharedData.h"
+#include "VoIPQueueHandlerSrv.h"
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::NewL
+// Symbian constructor
+// ----------------------------------------------------------------------------
+//
+CQueueHandlerSrv* CQueueHandlerSrv::NewL(MQueueHandlerObserverSrv* aObserver,
+        RMsgQueue<TVoIPMsgBuf>* aMsgQueue)
+    {
+    CQueueHandlerSrv* self = new (ELeave) CQueueHandlerSrv(aMsgQueue);
+    CleanupStack::PushL(self);
+    self->ConstructL(aObserver);
+    CleanupStack::Pop(self);
+    return self;
+    }
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::ConstructL
+// Second phase constructor.
+// ----------------------------------------------------------------------------
+//
+void CQueueHandlerSrv::ConstructL(MQueueHandlerObserverSrv* aObserver)
+    {
+    iObserver = aObserver;
+    }
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::~CQueueHandlerSrv
+// Destructor.
+// ----------------------------------------------------------------------------
+//
+CQueueHandlerSrv::~CQueueHandlerSrv()
+    {
+    Cancel();
+    }
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::~CQueueHandlerSrv
+// Destructor.
+// ----------------------------------------------------------------------------
+//
+CQueueHandlerSrv::CQueueHandlerSrv(RMsgQueue<TVoIPMsgBuf>* aMsgQueue) :
+    CActive(CActive::EPriorityStandard),
+    //  CActive(CActive::EPriorityHigh),
+    iMsgQueue(aMsgQueue)
+    {
+    CActiveScheduler::Add(this);
+    }
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::Start
+// Start listening for events on queue 0.
+// ----------------------------------------------------------------------------
+//
+void CQueueHandlerSrv::Start()
+    {
+    if (!IsActive())
+        {
+        iMsgQueue->NotifyDataAvailable(iStatus);
+        SetActive();
+        }
+    }
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::DoCancel
+// Cancel outstanding request
+// ----------------------------------------------------------------------------
+//
+void CQueueHandlerSrv::DoCancel()
+    {
+    iMsgQueue->CancelDataAvailable();
+    }
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::RunL
+// Process requests.
+// ----------------------------------------------------------------------------
+//
+void CQueueHandlerSrv::RunL()
+    {
+    TVoIPMsgBuf msgBuf;
+    TInt err = iMsgQueue->Receive(msgBuf);
+
+    if (err == KErrNone)
+        {
+        iObserver->Event(msgBuf.iRequest, msgBuf.iStatus);
+        }
+
+    Start();
+    }
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::RunError
+// Process requests.
+// ----------------------------------------------------------------------------
+//
+TInt CQueueHandlerSrv::RunError(TInt aError)
+    {
+    // RunL can actually leave if any iObserver->Event leave is not trapped
+    //    iObserver->Event(ECmdGeneralError, aError);
+    return aError;
+    }
+
+// ----------------------------------------------------------------------------
+// CQueueHandlerSrv::Status
+// Return request status.
+// ----------------------------------------------------------------------------
+//
+TRequestStatus* CQueueHandlerSrv::Status()
+    {
+    return &iStatus;
+    }
+
+// End of File