diff -r 000000000000 -r 3e07fef1e154 testexecfw/tef/utils/src/testclient.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/testexecfw/tef/utils/src/testclient.cpp	Mon Mar 08 15:03:44 2010 +0800
@@ -0,0 +1,183 @@
+/*
+* 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:  
+* Implementation of the RTestServ and RTestSession API's
+*
+*/
+
+
+
+/**
+ @file TestClient.cpp
+*/
+#include <testexecuteclient.h>
+#include <testexecutestepbase.h>
+
+TVersion RTestServ::Version() const
+	{
+	return(TVersion(KTestExecuteMajorVersionNumber,KTestExecuteMinorVersionNumber,KTestExecuteBuildVersionNumber));
+	}
+
+
+EXPORT_C TInt RTestServ::Connect(const TDesC& aServerName, TBool aDebugMode)
+/**
+ * @param aServerName - Human readable name of the test server
+ * @param aDebugMode - Set to true for just in time debugging
+ * @return int - Standard error codes
+ * Secure version of the API call. Expects the server binary to be
+ * ServerXXX.exe
+ */
+	{
+	if(aServerName.Length() > iServerName.MaxLength())
+		return KErrTooBig;
+	iServerName = aServerName;
+	// Assume the server is already running and attempt to create a session
+	// 4 message slots
+	TInt err = CreateSession(aServerName,Version(),-1);
+	if(err == KErrNotFound || err == KErrServerTerminated)
+		{
+		// Server not running
+		// Construct the server binary name
+		TBuf<KMaxTestExecuteNameLength> serverFile;
+		RProcess server;
+		_LIT(KEmpty,"");
+		_LIT(KExe,".exe");
+
+		serverFile.Copy(aServerName);
+		serverFile.Append(KExe);
+		err = server.Create(serverFile,KEmpty);
+		if(err != KErrNone)
+			return err;
+		// Synchronise with the server
+		TRequestStatus reqStatus;
+		server.Rendezvous(reqStatus);
+
+		// Set just in time debugging for the process
+		if(aDebugMode)
+			server.SetJustInTime(ETrue);
+		else
+			server.SetJustInTime(EFalse);
+
+		// Start the test harness
+		server.Resume();
+		// Server will call the reciprocal static synchronise call
+		User::WaitForRequest(reqStatus);
+		server.Close();
+		if(reqStatus.Int() != KErrNone)
+			return reqStatus.Int();
+		// Create the root server session
+		err = CreateSession(aServerName,Version(),-1);
+		}
+	return err;
+	}
+
+EXPORT_C const TDesC& RTestServ::ServerName() const
+/**
+ * @return - The human readable server name
+ */
+	{
+	return iServerName;
+	}
+
+///////
+EXPORT_C TInt RTestSession::Open(RTestServ& aServ, const TDesC& aStepName, TBool aSharedData)
+/**
+ * @param aServ - Reference to the root server session
+ * @param aStepName - Reference to the name of the test step owned by the server
+ * @return Standard error codes
+ * Secure and Non-secure variants
+ * Synchronously open a server test step session
+ */
+	{
+	if(aStepName.Length() > KMaxTestStepNameLength)
+		return KErrTooBig;
+	TIpcArgs args;
+	args.Set(0,&aStepName);
+	args.Set(1,aSharedData);
+	return CreateSubSession(aServ,EOpenTestStep,args);
+	}
+
+EXPORT_C TInt RTestSession::Open(RTestServ& aServ, TBool aSharedData)
+/**
+ * @param aServ - Reference to the root server session
+ * @param aStepName - Reference to the name of the test step owned by the server
+ * @return Standard error codes
+ * Secure and Non-secure variants
+ * Synchronously open a server test step session
+ */
+	{
+	TIpcArgs args;
+	args.Set(1,aSharedData);
+	return CreateSubSession(aServ,EOpenTestBlock,args);
+	}
+	
+EXPORT_C void RTestSession::RunTestStep(const TDesC& aCommandString, TDes& aPanicString, TRequestStatus& aStatus)
+/**
+ *
+ * @param aCommandString - The arguments to the RUN_TEST_STEP command
+ * @return aPanicString  - If the test step panics, this member is set up with the panic string
+ * @param aStatus - For completion to the caller
+ * Secure and Non-secure variants
+ * Send the RUN_TEST_STEP arguments to the test server
+ */
+	{
+	if(aCommandString.Length() > KMaxTestExecuteCommandLength)
+		{
+		TRequestStatus* status = &aStatus;
+		User::RequestComplete(status,KErrTooBig);
+		}
+	TIpcArgs args;
+	args.Set(0,&aCommandString);
+	args.Set(1,&aPanicString);
+	SendReceive(ERunTestStep,args,aStatus);
+	}
+
+EXPORT_C void RTestSession::RunTestBlock(const TDesC& aCommandString, TDes& aPanicString, TDes8& aBlockArray, TRequestStatus& aStatus)
+/**
+ *
+ * @param aCommandString - The arguments to the test block command
+ * @return aPanicString  - If the test step panics, this member is set up with the panic string
+ * @param aStatus - For completion to the caller
+ * Secure and Non-secure variants
+ * Send the RUN_TEST_STEP arguments to the test server
+ */
+	{
+	if(aCommandString.Length() > KMaxTestExecuteCommandLength)
+		{
+		TRequestStatus* status = &aStatus;
+		User::RequestComplete(status,KErrTooBig);
+		}
+	TIpcArgs args;
+	args.Set(0,&aCommandString);
+	args.Set(1,&aPanicString);
+	args.Set(2,&aBlockArray);
+	
+	SendReceive(ERunTestBlock,args,aStatus);
+	}
+
+EXPORT_C TInt RTestSession::AbortTestStep()
+/**
+ *
+ * @return - Standard Epoc error codes 
+ * Secure and Non-secure variants
+ * Synchronous abort of the the test step
+ */
+	{
+	return SendReceive(EAbortTestStep);
+	}
+
+EXPORT_C void RTestSession::Close()
+	{
+	CloseSubSession(ECloseTestStep);
+	}