/*
* 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 
* CTestServerThreadStarter class member functions.
*
*/

// INCLUDE FILES
#include "TestServerThreadStarter.h"
#include <stifinternal/TestServerClient.h>

// EXTERNAL DATA STRUCTURES
// None

// EXTERNAL FUNCTION PROTOTYPES  
// None

// CONSTANTS
// None

// MACROS
// None

/**
 * CTestServerThreadStarter thread heap size.
 */
const TUint KDefaultHeapSize = 0x10000;     // 64 K

/**
 * CTestServerThreadStarter thread max heap size.
 */
const TUint KMaxHeapSize     = 0x20000;     // 128 K 

// LOCAL CONSTANTS AND MACROS
// None

// MODULE DATA STRUCTURES
// None

// LOCAL FUNCTION PROTOTYPES
// None

// FORWARD DECLARATIONS
// None


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

/*
-------------------------------------------------------------------------------

     Class: CTestServerThreadStarter

     Method: TestServerStarterThreadFunction

     Description: CTestServerThreadStarter thread function.

	 CTestServerThreadStarter thread function in which testserver creation code
	 is executed.

     Parameters: TAny* aParameters: in: Pointer to CTestServerThreadStarter object
     
     Return Values: None.

     Errors/Exceptions: None.

     Status: Draft
    
-------------------------------------------------------------------------------
*/
TInt CTestServerThreadStarter::TestServerStarterThreadFunction( TAny* aParameters )
	{
	RDebug::Printf( "UITESTING: CTestServerThreadStarter::TestServerStarterThreadFunction" );
    
    CTestServerThreadStarter* testServerStarter = (CTestServerThreadStarter*)aParameters;
    TThreadId mainThreadId = testServerStarter->iMainThreadId;
    CTestThreadContainerRunnerFactory* testThreadContainerRunnerFactory = 
    	testServerStarter->iTestThreadContainerRunnerFactory;
    
   	// Signal that all needed data is copied and main thread can continue its execution 
    testServerStarter->iServerThreadStartedSemaphore.Signal();
    	
    // Get module name from command line
	const TInt length = User().CommandLineLength();

    HBufC* cmdLine = HBufC::New( length );
    
    if ( cmdLine == NULL )
        {
        return KErrNoMemory;
        }

    TPtr moduleName = cmdLine->Des();

	User().CommandLine( moduleName );

    RDebug::Print(_L("CTestServerThreadStarter::TestServerStarterThreadFunction() Received data [%S]"), &moduleName);

    // Extract semaphore name passed in data
    TInt index = moduleName.Find(_L(" "));
    RDebug::Print(_L("CTestServerThreadStarter::TestServerStarterThreadFunction() Space separator found at position [%d]"), index);
    TPtrC semaphoreName = moduleName.Mid(index + 1);
    moduleName = moduleName.Left(index);

    RDebug::Print(_L("CTestServerThreadStarter::TestServerStarterThreadFunction() Extracted module name [%S] and sempahore name [%S]"), &moduleName, &semaphoreName);

    // Open start-up synchronization semaphore
    RSemaphore startup;
    RDebug::Print(_L(" Openingstart-up semaphore"));
    //TName semaphoreName = _L("startupSemaphore");
    //semaphoreName.Append( moduleName );
    
    TInt res = startup.OpenGlobal(semaphoreName);
    RDebug::Print(_L("Opening result %d"), res);    


    TFileName serverName;
    TInt r = StartNewServer ( moduleName, serverName, EFalse, startup, true, testThreadContainerRunnerFactory );

    if ( r ==   KErrAlreadyExists )
        {        
        // Ok, server was already started
        RDebug::Print(_L("UI TestServer already started, signaling semaphore and exiting"));
        startup.Signal();        

        delete cmdLine;

        return KErrNone;
        }
    else
        {       
        RDebug::Print(_L("UI TestServer is finished, code %d"), r);
        }

    delete cmdLine;
    
    //delete testThreadContainerRunnerFactory;
    testThreadContainerRunnerFactory = NULL;
    
    // Kill main thread to end UITestServerStarter application
    // when testserver is finished    
    RThread mainThread;
    TInt ret = mainThread.Open( mainThreadId );
	if( ret != KErrNone )
		{
		User::Panic( _L("ThreadHandleOpenError"), ret );
		}
    mainThread.Kill( KErrNone );
    
    return r;	
	}

/*
-------------------------------------------------------------------------------

     Class: CTestServerThreadStarter

     Method: NewL

     Description: NewL is first phase of two-phased constructor.

	 NewL is first phase of two-phased constructor.

     Parameters: None.
     
     Return Values: Pointer to new CTestServerThreadStarter object.

     Errors/Exceptions: Leaves if new or ConstructL leaves.

     Status: Draft
    
-------------------------------------------------------------------------------
*/
CTestServerThreadStarter* CTestServerThreadStarter::NewL( )
	{
	CTestServerThreadStarter* self = new(ELeave) CTestServerThreadStarter();
	CleanupStack::PushL( self );
	self->ConstructL();
	CleanupStack::Pop( self );
	return self;
	}

/*
-------------------------------------------------------------------------------

     Class: CTestServerThreadStarter

     Method: CTestServerThreadStarter

     Description: Default constructor.

	 Default constructor.

     Parameters: None.
     
     Return Values: None.

     Errors/Exceptions: None.

     Status: Draft
    
-------------------------------------------------------------------------------
*/
CTestServerThreadStarter::CTestServerThreadStarter()
:CActive( EPriorityNormal )
	{
	}

/*
-------------------------------------------------------------------------------

     Class: CTestServerThreadStarter

     Method: NewL

     Description: Default destructor.

	 Default destructor.

     Parameters: None.
     
     Return Values: None.

     Errors/Exceptions: None.

     Status: Draft
    
-------------------------------------------------------------------------------
*/
CTestServerThreadStarter::~CTestServerThreadStarter()
	{
	Cancel();
	iTimer.Close();
	}

/*
-------------------------------------------------------------------------------

     Class: CTestServerThreadStarter

     Method: ConstructL

     Description: Second phase of two-phased constructor.

	 Second phase of two-phased constructor.

     Parameters: None.
     
     Return Values: None.

     Errors/Exceptions: None.

     Status: Draft
    
-------------------------------------------------------------------------------
*/
void CTestServerThreadStarter::ConstructL()
	{
	TInt ret = iTimer.CreateLocal();
	if ( ret != KErrNone )
		{
		User::Leave( ret );
		}

	CActiveScheduler::Add( this );
	}

/*
-------------------------------------------------------------------------------

     Class: CTestServerThreadStarter

     Method: RunTestServerThread

     Description: Starts-up testserver.

	 Starts-up testserver.

     Parameters: None.
     
     Return Values: KErrNone when there was no error.

     Errors/Exceptions: None.

     Status: Draft
    
-------------------------------------------------------------------------------
*/
TInt CTestServerThreadStarter::RunTestServerThread( CTestThreadContainerRunnerFactory* aTestThreadContainerRunnerFactory )
	{
	if ( IsActive() )
		{
		User::Panic( _L("E32USER-CBase"), 42 );
		}
		
	TInt ret = iServerThreadStartedSemaphore.CreateLocal( 0 );
	if ( ret != KErrNone )
		{
		User::Leave( ret );
		}
	
	iTestThreadContainerRunnerFactory = aTestThreadContainerRunnerFactory;
	iMainThreadId = RThread().Id();
	iReturnCode = KErrNone;
	
	iStatus = KRequestPending;

	SetActive();
	iTimer.After( iStatus, 0 );
	
	return KErrNone;
	}

/*
-------------------------------------------------------------------------------

     Class: CTestServerThreadStarter

     Method: RunL

     Description: RunL derived from CActive handles the completed requests.

	 RunL derived from CActive handles the completed requests.

     Parameters: None.
     
     Return Values: None.

     Errors/Exceptions: Leaves if one of the called method leavs.

     Status: Draft
    
-------------------------------------------------------------------------------
*/
void CTestServerThreadStarter::RunL()
	{
	RThread testServerStarterThread;	
	TInt ret = testServerStarterThread.Create( _L("testserverstarterthread"), 
			TestServerStarterThreadFunction, 10 * KDefaultStackSize, 10 * KDefaultHeapSize, 10 * KMaxHeapSize, this );
	
	User::LeaveIfError( ret );
		
	testServerStarterThread.Resume();	
	testServerStarterThread.Close();
	
	iServerThreadStartedSemaphore.Wait();
	iServerThreadStartedSemaphore.Close();
	
	// Delete CTestServerThreadStarter after testserver is started
	delete this;
	}

/*
-------------------------------------------------------------------------------

     Class: CTestServerThreadStarter

     Method: DoCancel

     Description: DoCancel derived from CActive handles the Cancel.

	 DoCancel derived from CActive handles the Cancel.

     Parameters: None.
     
     Return Values: None.

     Errors/Exceptions: None.

     Status: Draft
    
-------------------------------------------------------------------------------
*/
void CTestServerThreadStarter::DoCancel()
	{
	if ( IsActive() )
		{
		iTimer.Cancel();
		}
	}

// End of File