/*

* 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 module contains the implementation of xxx 

* class member functions...>

*

*/

// INCLUDE FILES

#include <e32svr.h>

#include "TestServerEvent.h"

#include "TestThreadContainer.h"

#include "TestServerModuleIf.h"

#include "Logging.h"

// EXTERNAL DATA STRUCTURES

//extern  ?external_data;

// EXTERNAL FUNCTION PROTOTYPES  

//extern ?external_function( ?arg_type,?arg_type );

// CONSTANTS

//const ?type ?constant_var = ?constant;

// MACROS

//#define ?macro ?macro_def

// LOCAL CONSTANTS AND MACROS

//const ?type ?constant_var = ?constant;

//#define ?macro_name ?macro_def

// MODULE DATA STRUCTURES

//enum ?declaration

//typedef ?declaration

// LOCAL FUNCTION PROTOTYPES

//?type ?function_name( ?arg_type, ?arg_type );

// FORWARD DECLARATIONS

//class ?FORWARD_CLASSNAME;

// ================= MEMBER FUNCTIONS =========================================

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: TEvent

    Description: Default constructor

    C++ default constructor can NOT contain any code, that

    might leave.

    <description of the functionality 

    description continues and...

    continues.>

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

		                     description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

TEvent::TEvent( TThreadId aTestThread ) :

    TEventIf(),

	iReq(NULL),

	iThread( aTestThread ),

	iEventPending(EFalse),

	iExecution( NULL )

	{

    }

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: ~TEvent

    Description: Destructor

    <description of the functionality 

    description continues and...

    continues.>

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

		                     description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/    

TEvent::~TEvent()

    {

    // Removed this call, to be studied @js

    //Release(); //safety

    }

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: Set

    Description: Set event.

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

			                 description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

void TEvent::Set( TEventType aEventType )

    {

   	iEventPending = ETrue; 

    iEventType = aEventType;

   	if( iReq )

   		{ 

   		CompletePendingWait( KErrNone );  

  		if( iEventType == EIndication )

			iEventPending = EFalse;    		

    	} 

    }

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: EventPending

    Description: Check event status.

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

			                 description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

TBool TEvent::EventPending()

	{

	if( iEventPending )

		{

		// Indication events are signaled only once

		if( iEventType == EIndication )

			iEventPending = EFalse;

		return ETrue;

		}

	return EFalse;

	}        

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: WaitEventPending

    Description: Check waiting status.

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

			                 description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

TBool TEvent::WaitEventPending()

	{

	if( iReq )

	    {

	    return ETrue;

	    }

	else

	    {

	    return EFalse;

	    }

	}        

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: SetWaitPending

    Description: First phase of waiting.

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

			                 description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

TInt TEvent::SetWaitPending( TRequestStatus* aStatus )

	{	       

	if( aStatus )

	    {

	    iReq = aStatus;

	    }

	else

	    {

	    iReq = &iRequestStatus;

	    }

    __RDEBUG((_L("Set wait pending(%d) %x"), this, iReq ));

    return KErrNone;

	}

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: CompletePendingWait

    Description: Complete pending wait.

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

			                 description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

void TEvent::CompletePendingWait( TInt aError )

	{	       

	_LIT( KTEvent, "TEvent" );

	__ASSERT_ALWAYS( iReq, User::Panic( KTEvent, KErrGeneral ) );

	RThread rt;

    if( rt.Open( iThread ) == KErrNone )

        {

        __RDEBUG( (_L("Complete wait(%d) %x"), this, iReq ) );

        rt.RequestComplete( iReq, aError );

	    } 

    rt.Close();

    iReq = NULL;

	}

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: Wait

    Description: Wait event.

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

			                 description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

void TEvent::Wait()

    { 

    User::WaitForRequest( iRequestStatus );

    // else Wait was already completed from other thread

    EventPending();

    } 

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: Release

    Description: Release event. Completes conceivably pending unset.

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

			                 description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

void TEvent::Release()

    { 

    if( iReq )

   		{

   		// Wait is pending and we received Release, 

   		// so we complete event with Cancel   

   		CompletePendingWait( KErrCancel );

   		iEventPending = ETrue;

    	} 

	if( iExecution )

		{

		iExecution->UnsetEvent( *this, iUnsetMessage );

		iExecution = NULL;

		}

    } 

/*

-------------------------------------------------------------------------------

    Class: TEvent

    Method: Unset

    Description: Unset event. Unset blocks until Release is called 

    			(i.e. iUnsetMessage is compeled from release).

    Parameters:	<arg1>: <in/out/inout>: <accepted values>: <Description>

    Return Values: <value_1: Description

		            value_n: Description line 1

			                 description line 2>

    Errors/Exceptions: <description how errors and exceptions are handled>

    Status: Draft

-------------------------------------------------------------------------------

*/

TInt TEvent::Unset( const RMessage2& aMessage, CTestExecution* aExecution )

    { 

    if( iExecution )

        {

    	return KErrAlreadyExists;

    	}

    if( aExecution == NULL )

        {

    	return KErrArgument;

    	}

    iExecution = aExecution;	

    iUnsetMessage = aMessage;

    return KErrNone;

    }