/*

* 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:  

* System Includes

*

*/

#include <stdio.h>

#include <stdlib.h>

#include <assert.h>

/*******************************************************************************

 *

 * Local Includes

 *

 ******************************************************************************/

#include "CAThread.h" 

/*******************************************************************************

 *

 * Implementation

 *

 ******************************************************************************/

CAThread::CAThread()

{

	iThreadHandle = NULL;

	iThreadState = TS_INIT;

	iProc = NULL;

}

CAThread::CAThread( string aThreadName )

{

	iThreadHandle = NULL;

	iThreadState = TS_INIT;

	iProc = NULL;

	iThreadName = aThreadName;

}

CAThread::~CAThread()

{

	assert( iThreadHandle == NULL );

	assert( iThreadState != TS_ACTIVE );

}

TThreadError CAThread::StartThread( void *aStartProc, void *aArg, int *aSystemSpecificError )

{

	// check params

	assert( aSystemSpecificError != NULL );

	*aSystemSpecificError = 0;

	// create the thread

	iThreadHandle = CreateThread( NULL, 0, (LPTHREAD_START_ROUTINE)aStartProc, aArg, 0, NULL );

	iProc = aStartProc;

	// handle errors

	if( iThreadHandle == NULL ) {

		*aSystemSpecificError = GetLastError();

		return TE_ERROR;

	}

	// done

	iThreadState = TS_ACTIVE;

	return TE_NONE;

}

TThreadError CAThread::WaitForThread( int aTimeout )

{

	int err;

	// wait for the object

	err = WaitForSingleObject( iThreadHandle, aTimeout );

	// handle the case that we got it

	if( err == WAIT_OBJECT_0 ) {

		iThreadState = TS_DONE;

		iThreadHandle = NULL;

		return TE_NONE;

	}

	// handle a timeout

	if( err == WAIT_TIMEOUT ) {

		return TE_TIMEOUT;

	}

	// handle all other responses

	assert( !"INVALID CODE PATH" );

	return TE_NONE;

}

TThreadState CAThread::GetThreadState()

{

	return iThreadState;

}