// 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 <e32const.h>

#include "ssmdeferreddeleter.h"
#include "ssmcommandlistimpl.h"
#include <ssm/ssmcommand.h>
#include "ssmdebug.h"
#include "ssmpanic.h"

#ifdef _DEBUG
const TInt KMilliSecondsInOneSecond = 1000000;
const TInt KMilliSecondsInFiveSeconds = 5000000;
#endif

CSsmDeferredDeleter* CSsmDeferredDeleter::NewL()
	{
	CSsmDeferredDeleter* self = new (ELeave) CSsmDeferredDeleter;
#ifdef _DEBUG
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
#endif
	return self;
	}

CSsmDeferredDeleter::~CSsmDeferredDeleter()
	{
	Cancel();
	delete iCommandList;
#ifdef _DEBUG
	DEBUGPRINT1A("All deferred commands completed and command list is deleted.");
	delete iTimer;
#endif
	}

void CSsmDeferredDeleter::RunL()
	{
	TInt indexOfPendingCommand = iCommandList->PendingCommandIndex();
	if (KErrNotFound == indexOfPendingCommand)
		{
		// all commands are finished
		delete this;
		}
	else
		{
		//register for pending command
		SetActive();
		MSsmCommand* cmd = (MSsmCommand*)((*iCommandList)[indexOfPendingCommand]);
		// if cmd is NULL then this object would register for next pending command when RunL() is called next time.
		if (cmd)
			{
			cmd->RegisterCompletionObserver(iStatus);
			}
		}
	}

void CSsmDeferredDeleter::DoCancel()
	{
#ifdef _DEBUG
	if (iTimer)
		{
		iTimer->Cancel();
		}
#endif	
	}

CSsmDeferredDeleter::CSsmDeferredDeleter()
	: CActive(EPriorityIdle)
	{
	}

/**
@panic ECmdNullPtr if the information used to create command is null
*/
void CSsmDeferredDeleter::DeferredDelete(CSsmCommandListImpl* aCommandList)
	{
	__ASSERT_DEBUG(aCommandList, PanicNow(KPanicDeferredDeleter, ECmdNullPtr));
	iCommandList = aCommandList;
	CActiveScheduler::Add(this);
	SetActive();
	TRequestStatus* status = &iStatus;
	User::RequestComplete(status, KErrNone);
	}

#ifdef _DEBUG
TInt CSsmDeferredDeleter::TimeoutCallback(TAny* aSelf)
	{
	if (aSelf)
		{
		static_cast<CSsmDeferredDeleter*>(aSelf)->PrintWarning();
		}
	return KErrNone;
	}

void CSsmDeferredDeleter::PrintWarning()
	{
	DEBUGPRINT1A("Warning: Deferred deleter is waiting for pending command!!!");
	}

void CSsmDeferredDeleter::ConstructL()
	{
	if (IsAdded())
		{
		iTimer = CPeriodic::NewL(EPriorityNormal);
		iTimer->Start(KMilliSecondsInFiveSeconds, KMilliSecondsInOneSecond, TCallBack(CSsmDeferredDeleter::TimeoutCallback, this));
		}
	}


#endif