testexecmgmt/ucc/RemoteInterface/src/CRemoteInterface.cpp
author Johnson Ma <johnson.ma@nokia.com>
Mon, 08 Mar 2010 15:04:18 +0800
changeset 0 3da2a79470a7
permissions -rw-r--r--
Initial EPL Contribution

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



#include <math.h>

#include "CRemoteInterface.h"
#include "CTCPTransport.h"

// Constant values
const char	KSpace[]				= { " " };
const char	KQuote[]				= { "\"" };
const char	KEquals[]				= { "=" };
const char	KRunCmd[]				= { "runcmd" };
const char	KServiceName[]			= { "svcname" };
const char	KCall[]					= { "call" };
const char	KMethodID[]				= { "methodid" };
const char	KStartServiceID[]		= { "1" };
const char	KStopServiceID[]		= { "2" };
const char	KDefaultMethodID[]		= { "10" };

CRemoteInterface::CRemoteInterface( const string &aDestination )
	: iTransport(NULL), iIsSetup(false), iDestination(aDestination), iConnected(false)
	{
	iRandomSeed = rand();
	}

CRemoteInterface::~CRemoteInterface()
	{
	if( iTransport )
		{
		iTransport->Disconnect();
		delete iTransport;
		iTransport = NULL;
		iConnected = false;
		}
	}

void CRemoteInterface::SetupStartService( const string &aServiceName )
	{
	// Setup the default start to the command line
	DefaultSetupCall( aServiceName, KStartServiceID );

	// The command line is now setup
	iIsSetup = true;
	}

void CRemoteInterface::SetupStopService( const string &aServiceName )
	{
	// Setup the default start to the command line
	DefaultSetupCall( aServiceName, KStopServiceID );

	// The command line is now setup
	iIsSetup = true;
	}

void CRemoteInterface::SetupCall( const string &aServiceName, const string &aCall )
	{
	// Setup the default start to the command line
	DefaultSetupCall( aServiceName, KDefaultMethodID );

	// Add the call
	iCommandLine += KCall;
	iCommandLine += KEquals;
	iCommandLine += KQuote;
	iCommandLine += aCall;
	iCommandLine += KQuote;
	iCommandLine += KSpace;

	// The command line is now setup
	iIsSetup = true;
	}

void CRemoteInterface::AddParam( const string &aName, const string &aValue )
	{
	// If the command line is setup append the next parameter
	if( iIsSetup )
		{
		iCommandLine += aName;
		iCommandLine += KEquals;
		iCommandLine += KQuote;
		iCommandLine += aValue;
		iCommandLine += KQuote;
		iCommandLine += KSpace;
		}
	}

int CRemoteInterface::Send()
	{
	int ret = 0;

	if( !iTransport )
		{
		iTransport = new CTCPTransport();
		}

	// If the command line is setup then continue with the send
	if( iIsSetup && iTransport)
		{
		if( !iConnected )
			{
			// Connect to the UCC
			ret = iTransport->Connect( iDestination );
			iConnected = true;
			}
		if( !ret )
			{
			if ( iCommandLine.size() > MAXCOMMANDLINELEN )
				{
				ret = TRI_COMMANDLINETOOLONG;
				}
			else
				{
				TRunCommandRequest* run_req = new TRunCommandRequest();
				if( run_req != NULL )
					{
					memset( run_req->iCommandLine, 0x00, sizeof(run_req->iCommandLine) );
					memcpy( run_req->iCommandLine, iCommandLine.c_str(), iCommandLine.size());

					TPHeader header;
					header.iCmdID = CMD_REQ_RUNCOMMAND;
					header.iDataLen = sizeof(*run_req);
					header.iUid = (int)iRand_UID;

					// Send the header first
					ret = iTransport->RequestSend( (char*)&header, sizeof(header) );
					ret?ret=TRI_ERRSENDING:ret=0;
					if( !ret )
						{
						// Now send the rest of the data
						ret = iTransport->RequestSend( (char*)run_req, sizeof(*run_req) );
						ret?ret=TRI_ERRSENDING:ret=0;
						}

					// Cleanup
					delete run_req;
					}
				else
					{
					ret = TRI_ERRINTIALISING;
					}
				}
			}
		if( !ret )
			{
			// Retrieve the header
			TPHeader header;
			ret = iTransport->RequestReceive( (char*)&header, sizeof(header) );

			if( !ret )
				{
				TRunCommandReply run_rep;
				// Retrieve the result
				ret = iTransport->RequestReceive( (char*)&run_rep, sizeof(run_rep) );
				ret?ret=TRI_ERRRECV:ret=run_rep.iResult;
				}
			}
		}

	return ret;
	}

void CRemoteInterface::DefaultSetupCall( const string &aServiceName, const string &aMethodID )
	{
	// New call started so clear out the command line buffer
	iCommandLine.erase();

	// Add the runcmd
	iCommandLine += KRunCmd;
	iCommandLine += KSpace;

	// Add the service name
	iCommandLine += KServiceName;
	iCommandLine += KEquals;
	iCommandLine += KQuote;
	iCommandLine += aServiceName;
	iCommandLine += KQuote;
	iCommandLine += KSpace;

	// Append the methodid to the command line
	iCommandLine += KSpace;
	iCommandLine += KMethodID;
	iCommandLine += KEquals;
	iCommandLine += KQuote;
	iCommandLine += aMethodID;
	iCommandLine += KQuote;
	iCommandLine += KSpace;
	}