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