/*

* 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

 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)

{

    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