// Copyright (c) 2007-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 "testandstopper.h"

void CTestAndStopper::RunL()

	{

	if( !iRunning )

		{

		iRunning = ETrue;	

		DoStartsL();	

		SetActive();

		TRequestStatus* trs = &iStatus;

		User::RequestComplete( trs, KErrNone );

		}

	else if( !iFinish )

		{

		iFinish = ETrue;

		SetActive();

		iTimer.After( iStatus, iTimeout );

		}

	else

		{

		CActiveScheduler::Stop();

		}

	}

void CTestAndStopper::DoStartsL()

	{

	if( iStartupProperties.IsMonitoringRequired() )

		{

		iSsmStartSafe.StartAndMonitorL( iStartupProperties, iProcess );

		}

	else

		{

		iSsmStartSafe.StartL( iStartupProperties, iProcess );

		}	

	}

TInt CTestAndStopper::RunError( TInt aError )

	{

	if( iSsTestAsyncNotifier )

		{

		iSsTestAsyncNotifier->SsTestNotify( aError );

		}

	if( !iFinish )

		{

		// Need to go round once more to stop the sched.

		iFinish = ETrue;

		SetActive();

		iTimer.After( iStatus, iTimeout );

		}	

	return KErrNone;

	}

void CTestAndStopper::DoCancel()

	{

	iTimer.Close();

	iRunning = EFalse;

	iFinish = EFalse;

	}

CTestAndStopper::CTestAndStopper( CSsmStartSafe& aSsmStartSafe, 

								  const CSsmStartupProperties& aStartupProperties, 

								  RProcess& aProcess,

								  TInt aTimeout,

								  MSsTestAsyncNotifier* aSsTestAsyncNotifier )

: CActive( EPriorityStandard), 

  iSsmStartSafe( aSsmStartSafe ), 

  iStartupProperties( aStartupProperties ), 

  iProcess( aProcess ),

  iTimeout( aTimeout ),

  iSsTestAsyncNotifier( aSsTestAsyncNotifier )

	{

	CActiveScheduler::Add( this );

	SetActive();

	iTimer.CreateLocal();

	iTimer.After( iStatus, 1000000 ); // TKAS May not need this delay.

	}

CTestAndStopper::~CTestAndStopper()

	{

	Cancel();

	iTimer.Close();

	}

//

// Similar to above n=but used for making duff starts to test errors

//

//

void CDuffTestAndStopper::RunL()

	{

	if( !iRunning )

		{

		iRunning = ETrue;	

		DoStartsL();	

		SetActive();

		TRequestStatus* trs = &iStatus;

		User::RequestComplete( trs, KErrNone );

		}

	else if( !iFinish )

		{

		iFinish = ETrue;

		SetActive();

		iTimer.After( iStatus, iTimeout );

		}

	else

		{

		CActiveScheduler::Stop();

		}

	}

void CDuffTestAndStopper::DoStartsL()

	{

	// Call S&M even though monitoring may not be specified

	iSsmStartSafe.StartAndMonitorL( iStartupProperties, iProcess );

	}

TInt CDuffTestAndStopper::RunError( TInt aError )

	{

	if( iSsTestAsyncNotifier )

		{

		iSsTestAsyncNotifier->SsTestNotify( aError );

		}

	if( !iFinish )

		{

		// Need to go round once more to stop the sched.

		iFinish = ETrue;

		SetActive();

		iTimer.After( iStatus, iTimeout );

		}	

	return KErrNone;

	}

void CDuffTestAndStopper::DoCancel()

	{

	iTimer.Close();

	iRunning = EFalse;

	iFinish = EFalse;

	}

CDuffTestAndStopper::CDuffTestAndStopper( CSsmStartSafe& aSsmStartSafe, 

								  const CSsmStartupProperties& aStartupProperties, 

								  RProcess& aProcess,

								  TInt aTimeout,

								  MSsTestAsyncNotifier* aSsTestAsyncNotifier )

: CActive( EPriorityStandard), 

  iSsmStartSafe( aSsmStartSafe ), 

  iStartupProperties( aStartupProperties ), 

  iProcess( aProcess ),

  iTimeout( aTimeout ),

  iSsTestAsyncNotifier( aSsTestAsyncNotifier )

	{

	CActiveScheduler::Add( this );

	SetActive();

	iTimer.CreateLocal();

	iTimer.After( iStatus, 1000000 ); // TKAS May not need this delay.

	}

CDuffTestAndStopper::~CDuffTestAndStopper()

	{

	Cancel();

	iTimer.Close();

	}

//

// Test two sync calls. Currently starts two of the same iStarupProperties

//

// Should give this an array of RProcess to start an arbitrary number of instances

//

void CTestTwoAndStopper::RunL()

	{

	if( !iRunning )

		{

		iRunning = ETrue;	

		DoStartsL();	

		SetActive();

		TRequestStatus* trs = &iStatus;

		User::RequestComplete( trs, KErrNone );

		}

	else if( !iFinish )

		{

		iFinish = ETrue;

		SetActive();

		iTimer.After( iStatus, iTimeout );

		}

	else

		{

		CActiveScheduler::Stop();

		}

	}

void CTestTwoAndStopper::DoStartsL()

	{

	if( iStartupProperties.IsMonitoringRequired() )

		{

		iSsmStartSafe.StartAndMonitorL( iStartupProperties, iProcess_0 );

		iSsmStartSafe.StartAndMonitorL( iStartupProperties, iProcess_1 );

		}

	else

		{

		iSsmStartSafe.StartL( iStartupProperties, iProcess_0 );

		iSsmStartSafe.StartL( iStartupProperties, iProcess_1 );

		}	

	}

TInt CTestTwoAndStopper::RunError( TInt aError )

	{

	if( iSsTestAsyncNotifier )

		{

		iSsTestAsyncNotifier->SsTestNotify( aError );

		}

	if( !iFinish )

		{

		// Need to go round once more to stop the sched.

		iFinish = ETrue;

		SetActive();

		iTimer.After( iStatus, iTimeout );

		}	

	return KErrNone;

	}

void CTestTwoAndStopper::DoCancel()

	{

	iTimer.Close();

	iRunning = EFalse;

	iFinish = EFalse;

	}

CTestTwoAndStopper::CTestTwoAndStopper( CSsmStartSafe& aSsmStartSafe, 

								  const CSsmStartupProperties& aStartupProperties, 

								  RProcess& aProcess_0, RProcess& aProcess_1,

								  TInt aTimeout,

								  MSsTestAsyncNotifier* aSsTestAsyncNotifier )

: CActive( EPriorityStandard), 

  iSsmStartSafe( aSsmStartSafe ), 

  iStartupProperties( aStartupProperties ), 

  iProcess_0( aProcess_0 ),

  iProcess_1( aProcess_1 ),

  iTimeout( aTimeout ),

  iSsTestAsyncNotifier( aSsTestAsyncNotifier )

	{

	CActiveScheduler::Add( this );

	SetActive();

	iTimer.CreateLocal();

	iTimer.After( iStatus, 1000000 ); // TKAS May not need this delay.

	}

CTestTwoAndStopper::~CTestTwoAndStopper()

	{

	Cancel();

	iTimer.Close();

	}