diff -r e8e63152f320 -r 2a9601315dfc javatools/tckrunner/tsrc/src/utils/testserver.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javatools/tckrunner/tsrc/src/utils/testserver.cpp	Mon May 03 12:27:20 2010 +0300
@@ -0,0 +1,198 @@
+/*
+* Copyright (c) 2007-2008 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 <string>
+#include <unistd.h>
+#include <errno.h>
+
+#ifdef __SYMBIAN32__
+#include <spawn.h>
+#else
+#include <stdio.h>
+#endif //__SYMBIAN32__
+
+
+#include "logger.h"
+#include "comms.h"
+#include "rtcmessages.h"
+#include "coremessages.h"
+
+#include "testserver.h"
+
+using namespace java::comms;
+using namespace java::captain;
+
+
+TestServer::TestServer()
+{
+}
+
+TestServer::~TestServer()
+{
+}
+
+int TestServer::start()
+{
+    mJavaCaptain.registerDefaultListener(this);
+    mJavaInstaller.registerDefaultListener(this);
+    stopJavaCaptain();
+    int rc = mJavaCaptain.start(IPC_ADDRESS_JAVA_CAPTAIN_C);
+
+    if (!rc)
+    {
+        startTckRunner();
+        rc = mJavaInstaller.connect(IPC_ADDRESS_JAVA_TCK_RUNNER_C);
+
+        while (rc != 0)
+        {
+            // tck runner is not up yet
+            sleep(1);
+            WLOG(ETckRunner, "waiting for tckrunner...");
+            rc = mJavaInstaller.connect(IPC_ADDRESS_JAVA_TCK_RUNNER_C);
+        }
+    }
+    else
+    {
+        ELOG1(ETckRunner, "Unable to create Java Captain endpoint %d. Is Java Captain running?", rc);
+    }
+    return rc;
+}
+
+int TestServer::stop()
+{
+    stopTckRunner();
+    mJavaCaptain.unregisterDefaultListener(this);
+    mJavaInstaller.unregisterDefaultListener(this);
+    int rc1 = mJavaCaptain.stop();
+    int rc2 = mJavaInstaller.disconnect();
+    return rc1 + rc2;
+}
+
+
+void TestServer::processMessage(CommsMessage& aMessage)
+{
+    switch (aMessage.getMessageId())
+    {
+    case MSG_ID_OPERATION:
+    {
+        int oper;
+        string urlOrUid;
+        aMessage >> oper >> urlOrUid;
+
+        CommsMessage msg;
+        msg.replyTo(aMessage);
+        msg.setMessageId(MSG_ID_OPERATION_RESULT);
+        int status = 0;
+        msg << oper << status << 1 << urlOrUid;
+        mJavaInstaller.send(msg);
+    }
+    break;
+
+    case RTC_MSG_ID_LAUNCH_APPLICATION_REQ:
+    {
+        string rtc, uid;
+        int option, type;
+        aMessage >> uid >> type >> option >> rtc;
+
+        CommsMessage msg;
+        msg.replyTo(aMessage);
+        msg.setMessageId(RTC_MSG_ID_APPLICATION_TERMINATED_IND);
+        int status = 0;
+        if (uid.compare("fail") == 0)
+        {
+            status = -1;
+        }
+        msg << uid << status;
+        mJavaCaptain.send(msg);
+
+        mLaunchReqs.push(uid);
+    }
+    break;
+
+    default:
+        LOG1(ETckRunner, EInfo, "Unknown message= %d", aMessage.getMessageId());
+        break;
+    }
+}
+
+int TestServer::startTckRunner()
+{
+    int rc = 0;
+    int pid = 0;
+
+    char* av[4];
+    int index = 0;
+    av[index++] = "tckrunner";
+    av[index++] = "unittest";
+    av[index++] = "unittest:\\\\tckrunner_tester";
+    av[index] = NULL;
+
+#ifdef __SYMBIAN32__
+    rc = posix_spawn(&pid, "tckrunner", NULL, NULL, av, NULL);
+#else
+    if (!(pid = fork()))
+    {
+        rc = execvp("tckrunner", av);
+        if (rc == -1)
+        {
+            rc = errno;
+        }
+    }
+#endif // __SYMBIAN32__
+
+    if (rc)
+    {
+        ELOG3(ETckRunner, "%s failed, %s - errno=%d", __PRETTY_FUNCTION__, strerror(rc), rc);
+    }
+    return rc;
+}
+
+
+int TestServer::stopTckRunner()
+{
+    CommsMessage msg;
+    msg.setMessageId(MSG_ID_OPERATION_RESULT);
+    int status = 0;
+    msg << OPERATION_EXIT << status;
+    int rc = mJavaInstaller.send(msg);
+    while (rc == 0)
+    {
+        sleep(1);
+        WLOG(ETckRunner, "waiting tckrunner to exit...");
+        rc = mJavaInstaller.send(msg);
+    }
+    return rc;
+}
+
+void TestServer::stopJavaCaptain()
+{
+    CommsMessage message;
+    message.setModuleId(PLUGIN_ID_JAVACAPTAIN_CORE_C);
+    message.setMessageId(CORE_MSG_ID_STOP_JAVACAPTAIN);
+    CommsClientEndpoint comms;
+    comms.connect(IPC_ADDRESS_JAVA_CAPTAIN_C);
+    int rc = comms.send(message);
+    while (rc == 0)
+    {
+        sleep(1);
+        WLOG(ETckRunner, "waiting JavaCaptain to exit...");
+        rc = comms.send(message);
+    }
+    comms.disconnect();
+}
+
+