/*
* 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 (moduleName);
// 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 existing"));
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