// Copyright (c) 2001-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 <csch_cli.h>

#include <msvapi.h>

#include <msvschedulepackage.h>

#include "SchSendExe.h"

//

// CMsvSendExeActive

//

/**

CMsvSendExeActive Factory Function

@return Newly constructed CMsvSendExeActive

@internalAll

@param				 aSession	Message server session

@param				 aParent	Used to callback on when the operation is complete

@param				 aPackage	Details of what type of operation to exectute

@param				 aMtm		The MTM of the message in aPackage

@param				 aPriority	CActive priority. Defaults to EPriorityStandard

*/

CMsvSendExeActive* CMsvSendExeActive::NewLC(CMsvSession& aSession, CMsvSendExe& aParent, const TMsvSchedulePackage& aPackage, const TUid& aMtm, TInt aPriority)

	{

	CMsvSendExeActive* self = new (ELeave) CMsvSendExeActive(aSession, aParent, aPackage, aMtm, aPriority);

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

/**

CMsvSendExeActive Destructor

@return			

@internalAll

*/

CMsvSendExeActive::~CMsvSendExeActive()

	{

	Cancel();

	delete iTimer;

	delete iOperation;

	delete iSelection;

	}

/**

The CMsvSendExeActive::StartL method

Starts the operation relating to iPackage.

Starts the timer that will poll iOperation's progress

@return			

@internalAll

*/

void CMsvSendExeActive::StartL()

	{

	__ASSERT_DEBUG(iOperation == NULL, gPanic(EObjectNotNull));

	__ASSERT_DEBUG(iTimer == NULL, gPanic(EObjectNotNull));

	iOperation = iSession.TransferCommandL(*iSelection, iPackage.iCommandId, iPackage.iParameter, iStatus);

	//Start the timer that will poll the progress on iOperation

	iTimer = CProgressTimer::NewL(*iOperation, iPackage.iPollProgress);

	iTimer->Start();

	SetActive();

	}

/**

CMsvSendExeActive Constructor

@return			

@internalAll

@param				 aSession	Message server session

@param				 aParent	Used to callback on when the operation is complete

@param				 aPackage	Details of what type of operation to exectute

@param				 aMtm		The MTM of the message in aPackage

@param				 aPriority	CActive priority. Defaults to EPriorityStandard

*/

CMsvSendExeActive::CMsvSendExeActive(CMsvSession& aSession, CMsvSendExe& aParent, const TMsvSchedulePackage& aPackage, const TUid& aMtm, TInt aPriority)

: CActive(aPriority), iSession(aSession), iParent(aParent), iPackage(aPackage), iMtm(aMtm)

	{

	CActiveScheduler::Add(this);

	}

void CMsvSendExeActive::ConstructL()

	{

	iSelection = new (ELeave) CMsvEntrySelection;

	}

void CMsvSendExeActive::RunL()

	{

	if (iTimer)

		iTimer->Cancel();

	iParent.OperationComplete(*this, iStatus.Int());

	}

void CMsvSendExeActive::DoCancel()

	{

	if (iOperation)

		iOperation->Cancel();

	if (iTimer)

		iTimer->Cancel();

	iParent.OperationComplete(*this, KErrCancel);

	}

void CMsvSendExeActive::AppendL(TMsvId aId)

	{

	if (iSelection->Find(aId) == KErrNotFound)

		iSelection->AppendL(aId);

	}

//

// CProgressTimer

//

CProgressTimer* CProgressTimer::NewL(CMsvOperation& aOperation, const TTimeIntervalMicroSeconds32& aPollInterval)

	{

	CProgressTimer* self = new (ELeave) CProgressTimer(aOperation, aPollInterval);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CProgressTimer::CProgressTimer(CMsvOperation& aOperation, const TTimeIntervalMicroSeconds32& aPollInterval)

: CTimer(EPriorityHigh), iOperation(aOperation), iPollInterval(aPollInterval)

	{

	CActiveScheduler::Add(this);

	}

CProgressTimer::~CProgressTimer()

	{

	Cancel();

	}

void CProgressTimer::Start()

	{

	if (iPollInterval.Int() > 0)

		{

		After(iPollInterval);

		}

	}

void CProgressTimer::RunL()

	{

	if (iPollInterval.Int() > 0)

		{

		// Ignore progress errors (we don't care)

		TRAPD(error, iOperation.ProgressL());

		After(iPollInterval);

		}

	}