diff -r 9f5ae1728557 -r db3f5fa34ec7 messagingfw/scheduledsendmtm/test/unit/src/t_schsendexe.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/messagingfw/scheduledsendmtm/test/unit/src/t_schsendexe.cpp	Wed Nov 03 22:41:46 2010 +0530
@@ -0,0 +1,166 @@
+// Copyright (c) 1999-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 "t_schsendexe.h"
+#include <msvids.h>
+#include <msvuids.h>
+
+CTrapCleanup* theCleanup;
+
+void doMainL(RTest& aTest)
+	{
+	CActiveScheduler* scheduler = new (ELeave) CActiveScheduler;
+	CleanupStack::PushL(scheduler);
+	CActiveScheduler::Install( scheduler );
+
+	CSchSendExeTest* schSendTest = CSchSendExeTest::NewL(aTest);
+	CleanupStack::PushL(schSendTest);
+
+	schSendTest->StartL();
+
+	CleanupStack::PopAndDestroy(2); //schSendTest, scheduler
+
+	aTest.Printf(_L("\nWaiting 5 seconds before closing...\n"));
+	User::After(5000000);
+	}
+
+GLDEF_C TInt E32Main()
+	{
+	RTest test(_L("Scheduled Sending Test Harness"));
+	__UHEAP_MARK;
+	test.Title();
+	test.Start(_L("Scheduled Sending Test Harness"));
+	theCleanup = CTrapCleanup::New();
+	test(theCleanup !=NULL);
+	TRAPD(error,doMainL(test));
+	test(error==KErrNone);
+	delete theCleanup;
+	test.Printf(_L("Completed with return code %d"),error);
+	test.End();
+	test.Close();
+	__UHEAP_MARKEND;
+	return KErrNone;
+	}
+
+CSchSendExeTest* CSchSendExeTest::NewL(RTest& aTest)
+	{
+	CSchSendExeTest* self = new (ELeave) CSchSendExeTest(aTest);
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CleanupStack::Pop(); //self
+	return self;
+	}
+
+CSchSendExeTest::CSchSendExeTest(RTest& aTest)
+: CSchSendTestUtils(aTest)
+	{
+	}
+
+void CSchSendExeTest::ShowMenuL()
+	{
+	RunAutoL();
+	}
+
+CSchSendExeTest::~CSchSendExeTest()
+	{
+	}
+
+void CSchSendExeTest::RunAutoL()
+	{
+	TInt nextTest = 0;
+	TestStart(++nextTest, _L("Operation Fail"));
+	TestOperationFailureL();
+	TestFinish(nextTest, KErrNone);
+
+// DEF051316
+	}
+
+void CSchSendExeTest::TestOperationFailureL()
+	{
+	Printf(_L("TestOperationFailure\n"));
+	TTime now;
+	now.HomeTime();
+	TMsvEntry entry;
+	CreateMessageLC(entry, KMsvGlobalOutBoxIndexEntryId, now);
+
+	iSelection->Reset();
+	iSelection->AppendL(entry.Id());
+
+	const TInt KTestOpFailError = -111;
+	TPckgBuf<TInt> pkg(KTestOpFailError);
+	iSchTestActive->TransferCommandSyncL(EScheduleOpFail, *iSelection, pkg, ETrue);
+
+	CSchSendTestWaitForState* wait = CSchSendTestWaitForState::NewL(*this);
+	CleanupStack::PushL(wait);
+
+	wait->Reset();
+	wait->AppendL(KMsvSendStateResend);
+	wait->StartL(*iSelection, 1000000 * 60 * 4); //4 mins
+
+	SetEntryL(entry.Id());
+	entry = Entry();
+	iRTest(entry.iError == KTestOpFailError);
+
+	Printf(_L("Wait completed with %d\n"), wait->iStatus.Int());
+	iRTest(wait->iStatus.Int() == KErrNone);
+
+	CleanupStack::PopAndDestroy(wait);
+	CleanupStack::PopAndDestroy(); //message
+	}
+
+void CSchSendExeTest::TestSessionFailureL()
+	{
+	Printf(_L("TestSessionFailure\n"));
+	TTime now;
+	now.HomeTime();
+	TMsvEntry entry;
+	CreateMessageLC(entry, KMsvGlobalOutBoxIndexEntryId, now);
+
+	iSelection->Reset();
+	iSelection->AppendL(entry.Id());
+
+	// create a semaphore that causes CMsvSession construction to fail
+	RSemaphore moving;
+	User::LeaveIfError(moving.CreateGlobal(KMsvMovingSemaphore,0));
+	CleanupClosePushL(moving);
+
+	iSchTestActive->TransferCommandSyncL(EScheduleAllL, *iSelection, ETrue);
+
+	CSchSendTestWaitForState* wait = CSchSendTestWaitForState::NewL(*this);
+	CleanupStack::PushL(wait);
+
+	Printf(_L("Waiting %d secs to check message scheduled\n"), 5);
+	wait->AppendL(KMsvSendStateScheduled);
+	wait->StartL(*iSelection, 1000000 * 5); //5 secs
+
+	Printf(_L("Wait completed with %d\n"), wait->iStatus.Int());
+	iRTest(wait->iStatus.Int() == KErrNone);
+
+	Printf(_L("Closing Move Semaphore\n"));
+	Printf(_L("Waiting %d secs for message to send\n"), 60 * 2);
+	moving.Close();
+	wait->Reset();
+	wait->AppendL(KMsvSendStateSent);
+	wait->StartL(*iSelection, 1000000 * 60 * 2); //2 mins
+
+	Printf(_L("Wait completed with %d\n"), wait->iStatus.Int());
+	iRTest(wait->iStatus.Int() == KErrNone);
+
+	CleanupStack::PopAndDestroy(wait);
+	CleanupStack::Pop(); //moving
+	CleanupStack::PopAndDestroy(); //message
+	}
+
+