--- a/telephonyserverplugins/ctsydispatchlayer/src/requestqueueoneshot.cpp	Mon May 03 13:37:20 2010 +0300
+++ b/telephonyserverplugins/ctsydispatchlayer/src/requestqueueoneshot.cpp	Thu May 06 15:10:38 2010 +0100
@@ -1,139 +1,139 @@
-// Copyright (c) 2008-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:
-//
-
-#include "requestqueueoneshot.h"
-#include "mdispatchercallback.h"
-#include <ctsy/ltsy/ltsylogger.h>
-#include "ctsydispatcherpanic.h"
-#include <ctsy/pluginapi/cmmdatapackage.h>
-
-const TInt KNoIpc = -1;
-
-CRequestQueueOneShot::TIpcDataPackage::TIpcDataPackage()
-	: iIpc(KNoIpc), 
-	  iDataPackage(NULL), 
-	  iResultCode(KErrNone), 
-	  iCleanupOnly(EFalse), 
-	  iDispatcherCallback(NULL) ,
-	  iLink()
-	{
-	} // CRequestQueueOneShot::TIpcDataPackage::TIpcDataPackage
-
-CRequestQueueOneShot::TIpcDataPackage::~TIpcDataPackage()
-	{
-	delete iDataPackage;
-	iDataPackage = NULL;
-	} // CRequestQueueOneShot::TIpcDataPackage::~TIpcDataPackage
-
-CRequestQueueOneShot::CRequestQueueOneShot()
-	: CAsyncOneShot(CActive::EPriorityStandard),
-	  iIpcQueue(_FOFF(TIpcDataPackage,iLink))
-	{
-	} // CRequestQueueOneShot::CRequestQueueOneShot
-
-
-CRequestQueueOneShot::~CRequestQueueOneShot()
-	{
-	TSYLOGENTRYEXIT;
-	
-	Cancel();
-
-	TIpcDataPackage* ipcDataPackage;
-	while (!iIpcQueue.IsEmpty())
-		{
-		ipcDataPackage = iIpcQueue.First();
-		iIpcQueue.Remove(*ipcDataPackage);
-		ipcDataPackage->iCleanupOnly = ETrue;
-		// Callback to dispatcher to ensure that dispatcher cleans up any heap data
-		// in the CMmDataPackage inside the TIpcDataPackage.
-		ipcDataPackage->iDispatcherCallback->CallbackSync(*ipcDataPackage);
-		}
-	
-	} // CRequestQueueOneShot::~CRequestQueueOneShot
-
-
-CRequestQueueOneShot* CRequestQueueOneShot::NewLC()
-	{
-	CRequestQueueOneShot* self = new (ELeave)CRequestQueueOneShot();
-	CleanupStack::PushL (self);
-	self->ConstructL();
-	return self;
-	} // CRequestQueueOneShot::NewLC
-
-
-CRequestQueueOneShot* CRequestQueueOneShot::NewL()
-	{
-	TSYLOGENTRYEXIT;
-	CRequestQueueOneShot* self = CRequestQueueOneShot::NewLC();
-	CleanupStack::Pop(self);
-	return self;
-	} // CRequestQueueOneShot::NewL
-
-
-void CRequestQueueOneShot::ConstructL()
-	{
-	} // CRequestQueueOneShot::ConstructL
-
-
-void CRequestQueueOneShot::QueueRequest(TIpcDataPackage& aIpcDataPackage)
-/**
- * Add the request to the queue.
- * 
- * @param aIpcDataPackage The encapsulated request to add to the queue.
- */
-	{
-	TSYLOGENTRYEXITARGS(_L8("IPC=%d,err=%d"), aIpcDataPackage.iIpc, aIpcDataPackage.iResultCode);
-
-	__ASSERT_DEBUG(aIpcDataPackage.iDispatcherCallback != NULL, CtsyDispatcherPanic(EInvalidNullPtr)); 
-	aIpcDataPackage.iCleanupOnly = EFalse;
-	iIpcQueue.AddLast(aIpcDataPackage);
-	
-	// This object is only active if there is something in the queue
-	if (!IsActive())
-		{
-		Call();
-		}
-	
-	} // CRequestQueueOneShot::QueueRequest
-
-
-void CRequestQueueOneShot::DoCancel()
-	{
-	} // CRequestQueueOneShot::DoCancel
-
-
-void CRequestQueueOneShot::RunL()
-/**
- * Completes the request at the head of the queue.
- */
-	{
-	TSYLOGENTRYEXIT;
-	
-	if (iStatus == KErrNone)
-		{
-		__ASSERT_DEBUG(!iIpcQueue.IsEmpty(), CtsyDispatcherPanic(ERequestNotFound));
-		TIpcDataPackage* ipcDataPackage = iIpcQueue.First();
-		iIpcQueue.Remove(*ipcDataPackage);
-		ipcDataPackage->iDispatcherCallback->CallbackSync(*ipcDataPackage);
-		}
-	
-	if (!iIpcQueue.IsEmpty())
-		{
-		Call(); // Restart active object to process next request at the head of the queue
-		}
-	
-	} // CRequestQueueOneShot::RunL
-
-
+// Copyright (c) 2008-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:
+//
+
+#include "requestqueueoneshot.h"
+#include "mdispatchercallback.h"
+#include <ctsy/ltsy/ltsylogger.h>
+#include "ctsydispatcherpanic.h"
+#include <ctsy/pluginapi/cmmdatapackage.h>
+
+const TInt KNoIpc = -1;
+
+CRequestQueueOneShot::TIpcDataPackage::TIpcDataPackage()
+	: iIpc(KNoIpc), 
+	  iDataPackage(NULL), 
+	  iResultCode(KErrNone), 
+	  iCleanupOnly(EFalse), 
+	  iDispatcherCallback(NULL) ,
+	  iLink()
+	{
+	} // CRequestQueueOneShot::TIpcDataPackage::TIpcDataPackage
+
+CRequestQueueOneShot::TIpcDataPackage::~TIpcDataPackage()
+	{
+	delete iDataPackage;
+	iDataPackage = NULL;
+	} // CRequestQueueOneShot::TIpcDataPackage::~TIpcDataPackage
+
+CRequestQueueOneShot::CRequestQueueOneShot()
+	: CAsyncOneShot(CActive::EPriorityStandard),
+	  iIpcQueue(_FOFF(TIpcDataPackage,iLink))
+	{
+	} // CRequestQueueOneShot::CRequestQueueOneShot
+
+
+CRequestQueueOneShot::~CRequestQueueOneShot()
+	{
+	TSYLOGENTRYEXIT;
+	
+	Cancel();
+
+	TIpcDataPackage* ipcDataPackage;
+	while (!iIpcQueue.IsEmpty())
+		{
+		ipcDataPackage = iIpcQueue.First();
+		iIpcQueue.Remove(*ipcDataPackage);
+		ipcDataPackage->iCleanupOnly = ETrue;
+		// Callback to dispatcher to ensure that dispatcher cleans up any heap data
+		// in the CMmDataPackage inside the TIpcDataPackage.
+		ipcDataPackage->iDispatcherCallback->CallbackSync(*ipcDataPackage);
+		}
+	
+	} // CRequestQueueOneShot::~CRequestQueueOneShot
+
+
+CRequestQueueOneShot* CRequestQueueOneShot::NewLC()
+	{
+	CRequestQueueOneShot* self = new (ELeave)CRequestQueueOneShot();
+	CleanupStack::PushL (self);
+	self->ConstructL();
+	return self;
+	} // CRequestQueueOneShot::NewLC
+
+
+CRequestQueueOneShot* CRequestQueueOneShot::NewL()
+	{
+	TSYLOGENTRYEXIT;
+	CRequestQueueOneShot* self = CRequestQueueOneShot::NewLC();
+	CleanupStack::Pop(self);
+	return self;
+	} // CRequestQueueOneShot::NewL
+
+
+void CRequestQueueOneShot::ConstructL()
+	{
+	} // CRequestQueueOneShot::ConstructL
+
+
+void CRequestQueueOneShot::QueueRequest(TIpcDataPackage& aIpcDataPackage)
+/**
+ * Add the request to the queue.
+ * 
+ * @param aIpcDataPackage The encapsulated request to add to the queue.
+ */
+	{
+	TSYLOGENTRYEXITARGS(_L8("IPC=%d,err=%d"), aIpcDataPackage.iIpc, aIpcDataPackage.iResultCode);
+
+	__ASSERT_DEBUG(aIpcDataPackage.iDispatcherCallback != NULL, CtsyDispatcherPanic(EInvalidNullPtr)); 
+	aIpcDataPackage.iCleanupOnly = EFalse;
+	iIpcQueue.AddLast(aIpcDataPackage);
+	
+	// This object is only active if there is something in the queue
+	if (!IsActive())
+		{
+		Call();
+		}
+	
+	} // CRequestQueueOneShot::QueueRequest
+
+
+void CRequestQueueOneShot::DoCancel()
+	{
+	} // CRequestQueueOneShot::DoCancel
+
+
+void CRequestQueueOneShot::RunL()
+/**
+ * Completes the request at the head of the queue.
+ */
+	{
+	TSYLOGENTRYEXIT;
+	
+	if (iStatus == KErrNone)
+		{
+		__ASSERT_DEBUG(!iIpcQueue.IsEmpty(), CtsyDispatcherPanic(ERequestNotFound));
+		TIpcDataPackage* ipcDataPackage = iIpcQueue.First();
+		iIpcQueue.Remove(*ipcDataPackage);
+		ipcDataPackage->iDispatcherCallback->CallbackSync(*ipcDataPackage);
+		}
+	
+	if (!iIpcQueue.IsEmpty())
+		{
+		Call(); // Restart active object to process next request at the head of the queue
+		}
+	
+	} // CRequestQueueOneShot::RunL
+
+