--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/qthighway/xqserviceipc/xqserviceipc/xqserviceipc_symbiansession.cpp	Tue Aug 31 16:02:37 2010 +0300
@@ -0,0 +1,144 @@
+/*
+* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+*
+* This program is free software: you can redistribute it and/or modify
+* it under the terms of the GNU Lesser General Public License as published by
+* the Free Software Foundation, version 2.1 of the License.
+* 
+* This program is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+* GNU Lesser General Public License for more details.
+*
+* You should have received a copy of the GNU Lesser General Public License
+* along with this program.  If not, 
+* see "http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html/".
+*
+* Description:  implementation of playback session
+*
+*/
+
+#include "xqservicelog.h"
+
+#include "xqserviceipc_symbiansession.h"
+
+namespace QtService
+{
+// ============================== MEMBER FUNCTIONS ============================
+
+/*!
+    \class RServiceIPCSession
+    \brief Symbian class encapsulating RMessage2 interface
+ */
+
+/*!
+    Send a message.
+    \param aFunction Function code.
+    \return Message completion code.
+ */
+TInt RServiceIPCSession::SendReceiveL(TInt aFunction) const
+{
+    XQSERVICE_DEBUG_PRINT("RServiceIPCSession::SendReceiveL(1)");
+    return User::LeaveIfError(RSessionBase::SendReceive(aFunction));
+}
+
+TInt RServiceIPCSession::Send(TInt aFunction, const TIpcArgs& aArgs) const
+{
+    XQSERVICE_DEBUG_PRINT("RServiceIPCSession::Send");
+    return RSessionBase::Send(aFunction, aArgs);
+}
+
+/*!
+    Send a message.
+    \param aFunction Function code.
+    \param aArgs Parameter to server.
+    \return Message completion code.
+ */
+TInt RServiceIPCSession::SendReceiveL(TInt aFunction, const TIpcArgs& aArgs) const
+{
+    XQSERVICE_DEBUG_PRINT("RServiceIPCSession::SendReceiveL(2)");
+    return User::LeaveIfError(RSessionBase::SendReceive(aFunction, aArgs));
+}
+
+/*!
+    Send message asynchronously.
+    \param aFunction Function code.
+    \param aStatus The request status object used to contain the 
+                   completion status of the request.
+*/
+EXPORT_C void RServiceIPCSession::SendReceive(TInt aFunction,
+                                              TRequestStatus& aStatus) const
+{
+    XQSERVICE_DEBUG_PRINT("RServiceIPCSession::SendReceive(1)");
+    RSessionBase::SendReceive(aFunction, aStatus);
+}
+
+/*!
+    Send message asynchronously.
+    \param aFunction Function code.
+    \param aArgs Parameter to server.
+    \param aStatus The request status object used to contain the
+                   completion status of the request.
+*/
+void RServiceIPCSession::SendReceive(TInt aFunction,
+                                     const TIpcArgs& aArgs,
+                                     TRequestStatus& aStatus) const
+{
+    XQSERVICE_DEBUG_PRINT("RServiceIPCSession::SendReceive(2)");
+    RSessionBase::SendReceive(aFunction, aArgs, aStatus);
+}
+
+/*!
+    Connect to server.
+    \param aServer server name.
+    \param aVersion version of the server.
+    \return KErrNone success, otherwise system error code.
+*/
+TInt RServiceIPCSession::Connect(const TDesC& aServer, const TVersion& aVersion)
+{
+    QString server = QString::fromUtf16(aServer.Ptr(), aServer.Length());
+    XQSERVICE_DEBUG_PRINT("RServiceIPCSession::Connect %s", qPrintable(server));
+    iVersion = aVersion;
+    return CreateSession(aServer, aVersion, 1);
+}
+
+/*!
+    Get version info.
+    \return Version info.
+*/
+TVersion RServiceIPCSession::Version() const
+{
+    XQSERVICE_DEBUG_PRINT("RServiceIPCSession::Version");
+    return iVersion;
+}
+
+/*!
+    Start the server .
+    \param aImage Binary name to start.
+    \return KErrNone if started properly.
+*/
+TInt RServiceIPCSession::StartServer(const TDesC& aImage)
+{
+    XQSERVICE_DEBUG_PRINT("RServiceIPCSession::StartServer");
+    RProcess server;
+    TInt ret = server.Create(aImage, KNullDesC);
+    if (ret == KErrNone) {
+        TRequestStatus status;
+        XQSERVICE_DEBUG_PRINT("RServiceIPCSession::Rendezvouz");
+        server.Rendezvous(status);
+        if (status != KRequestPending)
+            server.Kill(0);
+        else
+            server.Resume();
+        User::WaitForRequest(status);
+        XQSERVICE_DEBUG_PRINT("RServiceIPCSession::Rendezvouz done");
+        ret = (server.ExitType() == EExitPanic) ? KErrGeneral : status.Int();
+        server.Close();
+    }
+    return ret;
+}
+
+}
+
+// END OF FILE