/*

* Copyright (c) 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: This file contains the header file of the CTestExecution.

*

*/

#ifndef TEST_SERVER_MODULE_IF_H

#define TEST_SERVER_MODULE_IF_H

//  INCLUDES

#include <e32std.h>

#include <e32base.h>

#include <StifTestModule.h>

#include <StifTestInterface.h>

#include <stfeventsystem.h>

#include <stfasynceventactive.h>

#include "StifTFwIfProt.h"

// CONSTANTS

// MACROS

// DATA TYPES

// FUNCTION PROTOTYPES

typedef CSTIFTestMeasurementImplementation*( 

        *CTestMeasurementFactory )( const TDesC&,

                                    CSTIFTestMeasurement::TSTIFMeasurementType );

// FORWARD DECLARATIONS

class TEvent;

class CTestModule;

class CTestModuleContainer;

class CPrintQueue;

class CPrintHandler;

class CEventHandler;

class CSndHandler;

class CRcvHandler;

class CErrorPrintHandler;

class CInterferenceHandler;

class CMeasurementHandler;

class CCommandHandler;

class CAsyncEventActive;

// CLASS DECLARATION

// DESCRIPTION

// TCmdDef represents remote command

class TCmdDef

    {

    public:

        TStifCommand    iCommand;

        TParams         iParam;

        TInt            iLen;

        TRequestStatus* iStatus;

    };

// TCommandDef represents command

class TCommandDef

    {

    public:

        TCommand                       iCommand;

        TBuf8<KMaxCommandParamsLength2> iParamsPckg;

    };

// DESCRIPTION

// CCommandDef represents command

class CCommandDef : public CBase

    {

    public: // Enumerations

    private: // Enumerations

    public:  // Constructors and destructor

    		static CCommandDef* NewL();

        	~CCommandDef();

    private:  // Constructors and destructor

    		CCommandDef();

        	void ConstructL();

    public: // New functions

    public: // Functions from base classes

    protected:  // New functions

    protected:  // Functions from base classes

    private:

    public:		//Data

            TCommand iCommand;

            TBuf8<KMaxCommandParamsLength2> iParamsPckg;

    protected:  // Data

    private:    // Data

    public:     // Friend classes

    protected:  // Friend classes

    private:    // Friend classes

    };

// CLASS DECLARATION

// DESCRIPTION

// TCmdDef represents remote command

class TEventDef

    {

    public:

        enum TEventCmdType

            {

            EEventCmd,

            EEventCmdCancel,

            };

    // Added constructor to TEventDef @js

        TEventDef():iStatus(NULL){};

    public:

        TEventCmdType   iType;

        TEventIf        iEvent;

        TRequestStatus* iStatus;

    };

// DESCRIPTION

// TTestInterference represents remote command

class TTestInterference 

    {

    public:

        enum TOperation

            {

            EAppend,

            ERemove,

            };

    public:

        TTestInterference(){};

    public:

        // Thread id.

        TUint iThreadId;

        // Is operations append or remove.

        TOperation iOperation;

    };

// DESCRIPTION

// TTestMeasurement contains measurement related information

// transfering between TestInterface and TestServer.

class TTestMeasurement 

    {

    public:

        TTestMeasurement(){};

    public:

        // Struct for information.

        CSTIFTestMeasurement::TStifMeasurementStruct iMeasurementStruct;

    };

// DESCRIPTION

// TMeasurementHandling keeps information for measurement module

// dynamic loading, types, etc.

class TMeasurementHandling 

    {

    public:

        TMeasurementHandling() : iMeasurement( NULL ),

                                 iMeasurementModulePtr( NULL ){};

        ~TMeasurementHandling()

            { 

            delete iMeasurement;

            delete iMeasurementModulePtr;

            // After close test measurement's pointer is not valid anymore.

            if ( iMeasurementModule.Handle() )

                { 

                iMeasurementModule.Close(); 

                }

            };

    public:

        RLibrary iMeasurementModule;

        CTestMeasurementFactory iMeasurementLibEntry;

        CSTIFTestMeasurementImplementation* iMeasurement;

        CSTIFTestMeasurement::TSTIFMeasurementType iMeasurementType;

        CSTIFTestMeasurementImplementation* iMeasurementModulePtr;

    };

// CLASS DECLARATION

// DESCRIPTION

// CTestExecution represents a subsession object in the CTestServer.

// A session may own any number of CTestExecution objects

class CTestExecution

        :public CObject

    {

    public: // Enumerations

        enum TTestState

            {

            ENotStarted,

            EOnGoing,

            EFinished,

            ECancelled,

            };

        enum TRequestType

            {

            ERqPrint,

            ERqEvent,

            ERqSnd,

            ERqRcv,

            ERqInterference,

            ERqMeasurement,

            ERqCommand,

            };

        enum TTestThreadFailure

            {

            ETestThreadOk       = 0,

            ETestMemLeak        = 0x00000001,

            ETestRequestLeak    = 0x00000002,

            ETestHandleLeak     = 0x00000004,

            };

    private: // Enumerations

        // None

    public:  // Constructors and destructor

        /**

        * NewL is first phase of two-phased constructor.

        */

        static CTestExecution* NewL( CTestModule* aModuleSession, 

                                     TInt aCaseNumber, 

                                     const TFileName& aConfig

                                   );

        /**

        * Destructor

        */

        virtual ~CTestExecution();

    public: // New functions

        /**

        * Close Test Execution

        */

        TInt CloseTestExecution( const RMessage2& aMessage );

        /**

        * Run a test case

        */

        TInt RunTestCase( const RMessage2& aMessage );

        /**

        * Sets a print notification

        */

        TInt NotifyPrint( const RMessage2& aMessage );

        /**

        * Sets a event notification

        */

        TInt NotifyEvent( const RMessage2& aMessage );

        /**

        * Sets a RemoteCmd notification

        */

        TInt NotifyRemoteCmd( const RMessage2& aMessage );

        /**

        * Reads a RemoteCmd notification

        */

        TInt ReadRemoteCmdInfo( const RMessage2& aMessage );

        /**

        * Resumes a paused test case

        */

        TInt Resume( const RMessage2& aMessage );

        /**

        * Pauses ongoing test case

        */

        TInt Pause( const RMessage2& aMessage );

        /**

        * Cancels asynchronous request

        */

        TInt CancelRequestL( const RMessage2& aMessage );

        /**

        * Completes a print request. 

        */

        void DoNotifyPrint();

        /**

        * Completes a interference request. 

        */

        void DoNotifyInterference();

        /**

        * Completes a measurement request. 

        */

        TInt DoNotifyMeasurement();

        /**

        * Completes a print request. 

        */

        void DoErrorPrint();

        /**

        * Enables remote command receiving. 

        */

        void DoRemoteReceive();

        /**

        * Sends remote commands. 

        */

        void DoRemoteSend();

        /**

        * Completes a event request. 

        */

        TInt DoNotifyEvent();

        /**

        * Completes a event cancel request. 

        */

        void CancelEvent();

        /** 

        * Set thread State. 

        * This function can be called from test execution thread.

        */

        void SetThreadState( const TTestState aState );

        /**

        * Completes print request if print queue is empty

        */

        void CompletePrintRequestIfQueueEmpty();

        /**

        * Completes print request if print queue is empty

        */

        void CleanupEvents();

        /**

        * Completes test execution

        */

        void CompleteTestExecution( const TInt aCompletionCode, 

                                    const TFullTestResult::TCaseExecutionResult aCaseExecutionType,

                                    const TInt aCaseExecutionCode,

                                    const TInt aCaseResult,

                                    const TDesC& aText );

        /**

        * Unsets all pending state events.

        */

        void UnsetStateEvents();

        /**

        * Completes test execution

        */

        void CompleteTestExecution( const TInt aCompletionCode );

        /**

        * Current thread state.

        */

        TTestState ThreadState(){ return iThreadState; }

        /**

        * Cancels test(s) execution in special cases e.g. timeout, exit etc.

        */

        TInt CancelTestExecution();

        /**

        * Make sure that any of the test interference thread's won't stay

        * to run if test case is crashed of test interference object is not

        * deleted.

        */

        TInt KillTestinterferenceThread();

        /**

        * Make sure that any of the test measurement process's won't stay

        * to run if test case is crashed of test measurement object is not

        * deleted.

        */

        TInt KillTestMeasurement();

        /**

        * Executes command for ongoing test case.

        * Created to allow test case to kill itself.

        */

        TInt NotifyCommand(const RMessage2& aMessage);

        /**

        * Completes a command request.

        * Created to allow test case to kill itself.

        */

        TInt DoNotifyCommand();

        /**

        * Cancels command request.

        * Created to allow test case to kill itself.

        */

        TInt CancelCommandRequest();

    public: // Functions that are called from test thread

        /**

        * Get mutex handles.

        */

        TInt EventMutexHandle(){ return iEventMutex.Handle(); };

        TInt SndMutexHandle(){ return iSndMutex.Handle(); };

        TInt RcvMutexHandle(){ return iRcvMutex.Handle(); };

        TInt PrintMutexHandle(){ return iPrintMutex.Handle(); };

        TInt InterferenceMutexHandle(){ return iInterferenceMutex.Handle(); };

        TInt MeasurementMutexHandle(){ return iMeasurementMutex.Handle(); };

        TInt CommandMutexHandle(){ return iCommandMutex.Handle(); };

        /**

        * Get semaphore handles.

        */

        TInt EventSemHandle(){ return iEventSem.Handle(); };

        TInt SndSemHandle(){ return iSndSem.Handle(); };

        TInt RcvSemHandle(){ return iRcvSem.Handle(); };

        //TInt ReceiverSemHandle(){ return iReceiverSem.Handle(); };

        TInt PrintSemHandle(){ return iPrintSem.Handle(); };

        TInt InterferenceSemHandle(){ return iInterferenceSem.Handle(); };

        TInt MeasurementSemHandle(){ return iMeasurementSem.Handle(); };

        TInt CommandSemHandle(){ return iCommandSem.Handle(); };

        /**

        * Set execution test thread id.

        */ 

        void SetTestThread( TThreadId aThreadId ){ iTestThreadId = aThreadId; };

        /**

        * Access to "shared" memory.

        */

        TFullTestResult& FullResult(){ return iFullResult; };

        TTestProgress& TestProgress(){ return iProgress; };

        TEventDef& EventDef(){ return iEventDef; };

        TCmdDef& SndInfo(){ return iCmdDef; };

        TCmdDef& RcvInfo(){ return iRcvCmdDef; };

        TInt& TestThreadFailure(){ return iTestThreadFailure; };

        TTestInterference& TestInterference(){ return iTestInterference; };

        TTestMeasurement& TestMeasurement(){ return iTestMeasurement; };

        CCommandDef& CommandDef(){ return *iCommandDef; };

        /**

        * Get specific TRequestStatus variable.

        */

        TRequestStatus* GetRq( TRequestType aType );

        /**

        * Get mutex handle.

        * This mutex meaning is to make sure that test complete and test

        * case cancel operations are not executed at the same time.

        */

        TInt TestThreadMutexHandle() { return iTestThreadMutex.Handle(); };

        const TDesC& GetConfigFileName() const { return iConfig; }

    public: // Functions from base classes

        // None

    protected:  // New functions

        // None

    protected:  // Functions from base classes

        // None

    private:

        /** 

        * C++ default constructor.

        */

        CTestExecution(); 

        /**

        * By default Symbian OS constructor is private.

        */

        void ConstructL( CTestModule* aModuleSession,

                         TInt aCaseNumber,

                         const TFileName& aConfig );

        /**

        * Cancels print request.

        */

        TInt CancelPrintRequest();

        /**

        * Cancels test interference request.

        */

        TInt CancelInterferenceRequest();

        /**

        * Cancels test execution request

        */

        TInt CancelTestRequest();

        /**

        * Cancel event request.

        */

        TInt CancelEventRequest();

        /**

        * Cancel event request.

        */

        TInt CancelRemoteCmdRequest();

        /**

        * Writes a print notification to client memory space.

        */

        TInt WritePrint( TTestProgress& aProgress );