diff -r 9f5ae1728557 -r db3f5fa34ec7 messagingfw/scheduledsendmtm/schedulesendexe/src/SchSendExeActive.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/messagingfw/scheduledsendmtm/schedulesendexe/src/SchSendExeActive.cpp	Wed Nov 03 22:41:46 2010 +0530
@@ -0,0 +1,178 @@
+// 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);
+		}
+	}