/**
   This file is part of CWRT package **

   Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies). **

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


#include "serviceipcsymbiansession.h"

namespace WRT
{
// ============================== 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
{
    return User::LeaveIfError(RSessionBase::SendReceive(aFunction));
}

/*!
 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
{
    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
{
    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
{
    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
{
    return iVersion;
}

/*!
 Start the server 
 @param aImage binary name to start
 @return KErrNone if started properly
 */
TInt RServiceIPCSession::StartServer(const TDesC& aImage)
{
    RProcess server;
    TInt ret = server.Create(aImage, KNullDesC);
    if (ret == KErrNone) {
        TRequestStatus status;
        server.Rendezvous(status);
        if (status != KRequestPending)
            server.Kill(0);
        else
            server.Resume();
        User::WaitForRequest(status);
        ret = (server.ExitType() == EExitPanic) ? KErrGeneral : status.Int();
        server.Close();
    }
    return ret;
}
}

// END OF FILE