/*
* 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:   
* This file was autogenerated by rpcgen, but should be modified by the developer.
* Make sure you don't use the -component_mod flag in future or this file will be overwritten.
* Thu Oct 16 14:41:55 2003
* System Includes
*
*/




#include <stdio.h>
#include <signal.h>


/****************************************************************************************
 * 
 * Local Includes
 * 
 ***************************************************************************************/
#include "CSvcHostexecuteasync.h"
#include "CSHostexecuteasync.h"
#include "../include/standard_unix.h"
#include "../include/strncpynt.h"

/****************************************************************************************
 * 
 * Implementation
 * 
 ***************************************************************************************/
CSHostexecuteasync::CSHostexecuteasync()
{
	iProcess = NULL;
}

CSHostexecuteasync::~CSHostexecuteasync()
{
	assert( iProcess == NULL );
}

int CSHostexecuteasync::GetKey()
{
	return iKey;
}

void CSHostexecuteasync::SetKey( int aKey )
{
	iKey = aKey;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: cstr_startprocess
 * 
 ***************************************************************************************/
TResult CSHostexecuteasync::cstr_startprocess( char *aArgs )
{
	TResult rv = { ERR_NONE, 0, 0 };
	int errcode;
	TCAProcessError perr;

	// create a process object
	iProcess = new CAProcess();
	assert( iProcess != NULL );

	// start the process running
	perr = iProcess->StartProcess( aArgs, &errcode, true, true, false );
	if( perr != CAE_NONE ) {
		rv.iStandardResult = ERR_START_PROCESS_ERROR;
		rv.iExtendedCode = (int)perr;
		rv.iSystemError = errcode;
		delete iProcess;
		iProcess = NULL;
		return rv;
	}

	// done - success
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: dstr_removeprocess
 * 
 ***************************************************************************************/
TResult CSHostexecuteasync::dstr_removeprocess( int aArgs, int *aDeleteInstance )
{
	TResult rv = { ERR_NONE, 0, 0 };
	TCAProcessError perr;
	TProcessStatus pstatus;

	// make sure that we still have a process
	assert( iProcess != NULL );
	
	// get the status of the process to make sure we are ok
	perr = iProcess->GetProcessStatus( &pstatus );
	assert( perr == CAE_NONE );
	if( pstatus == PS_STARTED ) {
	  *aDeleteInstance = 0;
	  rv.iStandardResult = ERR_INVALIDSTATE;
	  return rv;
	}

	// ok - remove the process
	delete iProcess;
	iProcess = NULL;

	// done - success
	*aDeleteInstance = 1; 
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: killprocess
 * 
 ***************************************************************************************/
TResult CSHostexecuteasync::killprocess( int aArgs )
{
	return StopProcessWithSignal( SIGKILL );
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: stopprocess
 * 
 ***************************************************************************************/
TResult CSHostexecuteasync::stopprocess( int aArgs )
{
	return StopProcessWithSignal( SIGTERM );
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: getprocessinfo
 * 
 ***************************************************************************************/
THostExecuteAsyncProcessInfo CSHostexecuteasync::getprocessinfo( int aArgs )
{
	string command_line;
	THostExecuteAsyncProcessInfo rv;
	TCAProcessError perr;
	TProcessStatus pstatus = PS_INVALID;
	TProcessExitReason preason = ER_INVALID;
	int exitcode = 0;

	// check the state
	assert( iProcess != NULL );

	// interrogate the process	
	perr = iProcess->GetProcessStatus( &pstatus );
	assert( perr == CAE_NONE );
	if( (pstatus == PS_STOPPED) || (pstatus == PS_ABANDONNED) ) {
		perr = iProcess->GetExitReason( &preason );
		assert( perr == CAE_NONE );
	}
	if( (pstatus == PS_STOPPED) || (pstatus == PS_ABANDONNED) ) {
		perr = iProcess->GetExitCode( &exitcode );
		assert( perr == CAE_NONE );
	}
	command_line = iProcess->GetCommandString();

	// copy into the rv
	rv.iErrorCode = ERR_NONE;
	rv.iErrorDetail = 0;
	rv.iProcessStatus = (int)pstatus;
	rv.iProcessExitReason = (int)preason;
	rv.iExitCode = exitcode;
	STRNCPY_NULL_TERMINATE( rv.iCommandLine, command_line.c_str(), MAXCOMMANDLINE );

	// done - success
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: getstandardoutput
 * 
 ***************************************************************************************/
TVarData CSHostexecuteasync::getstandardoutput( int aArgs )
{
	TVarData rv;
	TCAProcessError perr;
	int output_read_count, error_read_count, read_error;
	string output;

	// since we create in the constructor and stop in the destructor there must be a process
	assert( iProcess != NULL );

	// poll for new output - ignore errors since there may be some buffered data anyway
	perr = iProcess->PollProcessForNewOutput( 0, &output_read_count, &error_read_count );

	// now read it into a string
	output_read_count = iProcess->GetRecordedStandardOutput( &output, &read_error );
	if( output_read_count == 0 ) {
	  rv.TVarData_val = NULL;
	  rv.TVarData_len = 0;
	  return rv;
	}

	// copy it into a buffer
	rv.TVarData_val = (char*)malloc( output.size() + 1 );
	rv.TVarData_len = output.size() + 1;
	memcpy( rv.TVarData_val, output.c_str(), output.size() );
	rv.TVarData_val[output.size()] = 0;
	return rv;
}


/****************************************************************************************
 * 
 * PUBLIC FUNCTION: getstandarderror
 * 
 ***************************************************************************************/
TVarData CSHostexecuteasync::getstandarderror( int aArgs )
{
	TVarData rv;
	TCAProcessError perr;
	int output_read_count, error_read_count, read_error;
	string stderror;

	// since we create in the constructor and stop in the destructor there must be a process
	assert( iProcess != NULL );

	// poll for new output - ignore errors since there may be some buffered data anyway
	perr = iProcess->PollProcessForNewOutput( 0, &output_read_count, &error_read_count );

	// now read it into a string
	error_read_count = iProcess->GetRecordedStandardError( &stderror, &read_error );
	if( error_read_count == 0 ) {
	  rv.TVarData_len = 0;
	  rv.TVarData_val = NULL;
	  return rv;
	}

	// copy it into a buffer
	rv.TVarData_val = (char*)malloc( stderror.size() + 1 );
	rv.TVarData_len = stderror.size() + 1;
	memcpy( rv.TVarData_val, stderror.c_str(), stderror.size() );
	rv.TVarData_val[stderror.size()] = 0;
	return rv;
}


/****************************************************************************************
 * 
 * PRIVATE FUNCTION: StopProcessWithSignal
 * 
 ***************************************************************************************/
TResult CSHostexecuteasync::StopProcessWithSignal( int aSignal )
{
	TResult rv = { ERR_NONE, 0, 0 };
	TCAProcessError perr;
	TProcessStatus pstatus;

	// since we create in the constructor and stop in the destructor there must be a process
	assert( iProcess != NULL );

	// if the process isn't running then it has died outside the scope of this controller, 
	// clean up the state, return an error since this is noteworthy and should be either 
	// expected or not happen.
	perr = iProcess->GetProcessStatus( &pstatus );
	assert( perr == CAE_NONE );
	if( pstatus != PS_STARTED ) {
	  assert( (pstatus == PS_STOPPED) || (pstatus == PS_ABANDONNED) );
	  rv.iStandardResult = ERR_PROCESS_TERMINATED_OUTSIDE_SCOPE;
	  return rv;
	}

	// request the process to stop
	perr = iProcess->RequestStop( aSignal );
	if( perr != CAE_NONE ) {
	  rv.iStandardResult = ERR_STOP_PROCESS_ERROR;
	  rv.iExtendedCode = (int)perr;
	  return rv;
	}

	// wait for the process to stop
	perr = iProcess->WaitForProcessToTerminate( -1 );
	if( perr != CAE_NONE ) {
	  rv.iStandardResult = ERR_WAIT_PROCESS_ERROR;
	  rv.iExtendedCode = (int)perr;
	  return rv;
	}

	// done - success
	return rv;
}