/*
* Copyright (c) 2005-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:  
* Definitions of classes local to TestExecuteUtils
*
*/



/**
 @file TestExecuteServerUtils.h
*/

#if (!defined __SERVER_UTILS_H__)
#define __SERVER_UTILS_H__
#include <test/testexecuteserverbase.h>
#include <test/testexecutestepbase.h>

class CActiveBase : public CActive
/**
@internalTechnology
@test
*/
	{
public:
	inline 	TRequestStatus& Status();
	inline 	void SetActive();
	inline	void Kick();
	inline	void Prime();
	inline	void Complete(TInt aCode);
	inline	virtual ~CActiveBase();
	inline  TDes& Error();
	inline TBool& TimedOut();
protected:
	inline	CActiveBase();
	TBuf<KMaxTestExecuteNameLength> iError;
	TBool iTimeOut;
	};

class CControlBase : public CActiveBase
/**
@internalTechnology
@test
*/
	{
public:
	inline CControlBase(CTestServer& aServer);
	inline void DoCancel();
	virtual void Stop() =0;
	inline CTestServer& Server();
	inline TDes& Args();
	inline RMessage2& Message();
	inline RThread& WorkerThread();
private:
	CTestServer&						iServer;
	RMessage2							iMessage;
	RThread								iWorkerThread;
	TBuf<KMaxTestExecuteCommandLength>	iArgs;
	};
	
	
class CStepControlBase : public CControlBase
/**
@internalTechnology
@test
*/
	{
public:
	inline CStepControlBase(CTestServer& aServer);
	virtual void StartL(const RMessage2& aMessage,const TDesC& aStepArgs) = 0;
	inline TDes& StepName();
private:
	RMessage2 iMessage;
	RThread iWorkerThread;
	TBuf<KMaxTestStepNameLength> iStepName;
	};

class CBlockControlBase : public CControlBase
/**
@internalTechnology
@test
*/
	{
public:
	inline CBlockControlBase(CTestServer& aServer);
	~CBlockControlBase();
	virtual void StartL(const RMessage2& aMessage,const TDesC& aArgs, const TDesC8& aBlockArrayPtr) = 0;
	virtual TTEFItemArray*	BlockArray() const;

protected:
	virtual void			CreateBlockArrayL( const TDesC8& aBlockArrayPtr );
	virtual HBufC8*			CreateBlockArrayPckgLC();
	
private:
	TTEFItemArray*						iBlockArray;
	RMessage2							iMessage;
	RThread								iWorkerThread;
	TBuf<KMaxTestExecuteCommandLength>	iBlockArgs;
	};

class CStepControl : public CStepControlBase
/**
@internalTechnology
@test
*/
	{
public:
	CStepControl(CTestServer& aServer, const TDesC& aStepName);
	void RunL();
	void StartL(const RMessage2& aMessage,const TDesC& aStepArgs);
	void Stop();
	~CStepControl();
private:
	};

class CBlockControl : public CBlockControlBase
/**
@internalTechnology
@test
*/
	{
public:
	CBlockControl(CTestServer& aServer);
	void RunL();
	void StartL(const RMessage2& aMessage,const TDesC& aArgs, const TDesC8& aBlockArrayPtr);
	void Stop();
	~CBlockControl();
	};

class CWorkerMonitor;
class CWorkerControl;
class CPersistentStepControl : public CStepControlBase
/**
@internalTechnology
@test
*/
	{
public:
	CPersistentStepControl(CTestServer& aServer);
	virtual ~CPersistentStepControl();
	void StartL(const RMessage2& aMessage,const TDesC& aStepArgs);
	void RunL();
	void Stop();
	inline void ChildCompletion();
private:
	CWorkerControl* iWorkerControl;
	CWorkerMonitor* iWorkerMonitor;
	TBool iInitialised;
	};

class CBlockWorkerControl;
class CPersistentBlockControl : public CBlockControlBase
/**
@internalTechnology
@test
*/
	{
public:
	CPersistentBlockControl(CTestServer& aServer);
	virtual ~CPersistentBlockControl();
	void StartL(const RMessage2& aMessage,const TDesC& aArgs, const TDesC8& aBlockArrayPtr);
	void RunL();
	void Stop();
	inline void ChildCompletion();

private:
	CBlockWorkerControl* 	iWorkerControl;
	CWorkerMonitor* 		iWorkerMonitor;
	TBool					iInitialised;
	};

class CWorkerMonitor : public CActiveBase
/**
@internalTechnology
@test
*/
	{
public:
	inline CWorkerMonitor(TRequestStatus& aParentStatus);
	inline virtual ~CWorkerMonitor();
	inline void RunL();
	inline void DoCancel();
private:
	TRequestStatus& iParentStatus;
	};

class CWorkerControl : public CActiveBase
/**
@internalTechnology
@test
*/
	{
public:
	inline CWorkerControl(CTestServer& aServer,TRequestStatus& aParentStatus);
	inline ~CWorkerControl();
	inline void RunL();
	inline void DoCancel();
	inline TRequestStatus& WorkerStatus();
	inline RThread& ControllerThread();
	inline RSemaphore& Semaphore();
	inline CTestServer& Server();
	inline TInt& Result();
	inline TPtrC& Args();
	inline TPtrC& StepName();
	inline TDes& PersistentError();
	//defect 116046
	inline void SetCleanupPtr(CTrapCleanup* aCleanup);
	inline void Cleanup();
	//END defect 116046
private:
	CTestServer& iServer;
	TRequestStatus& iParentStatus;
	RSemaphore iSemaphore;
	TRequestStatus iWorkerStatus;
	RThread iControllerThread;
	TPtrC iArgs;
	TPtrC iStepName;
	TInt iResult;
	TBuf<KMaxTestExecuteNameLength> iPersistentError;
	//defect 116046
	CTrapCleanup* iCleanup;
	//END defect 116046
	};

class CBlockWorkerControl : public CWorkerControl
/**
@internalTechnology
@test
*/
	{
public:
	inline CBlockWorkerControl(CTestServer& aServer,TRequestStatus& iParentStatus );
	inline ~CBlockWorkerControl();
	inline void				SetBlockArray( TTEFItemArray* aBlockArray );
	inline TTEFItemArray*	BlockArray() const;

private:
	TTEFItemArray*			iBlockArray;
	};
	
class CTestSession : public CSession2
/**
@publishedPartner
@test
*/
	{
public:
	IMPORT_C CTestSession();
	IMPORT_C virtual ~CTestSession();
	IMPORT_C virtual void ServiceL(const RMessage2& aMessage);
private:
	CPersistentStepControl*		iPersistentStepControl;
	CPersistentBlockControl*	iPersistentBlockControl;
	TTEFItemArray*				iBlockArray;
	};

#include <test/testexecuteserverutils.inl>
#endif