/*
* Copyright (c) 2007 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 RGbaServerSession
*
*/


#include "GbaCommon.h"
#include "GbaServerSession.h"
#include "GBALogger.h"

// Number of message slots to reserve for this client server session.
// In this example we can have one asynchronous request outstanding 
// and one synchronous request in progress.
static const TUint KDefaultMessageSlots = 2;
static const TUid KServerUid3 = {0x20029F0A};


static TInt StartServer();
static TInt CreateServerProcess();

// -----------------------------------------------------------------------------
// RGbaServerSession::RGbaServerSession()
// -----------------------------------------------------------------------------
//
RGbaServerSession::RGbaServerSession()
:   RSessionBase(), iGbaInputBuffer(NULL, 0, 0), iGbaOutputBuffer(NULL, 0, 0)
    {
    // No implementation required.
    }

// -----------------------------------------------------------------------------
// RGbaServerSession::Connect()
// -----------------------------------------------------------------------------
//
TInt RGbaServerSession::Connect()
    {
    TInt error = ::StartServer();
    GBA_TRACE_DEBUG(("RGbaServerSession::Connect"));
    if (KErrNone == error)
        {
        GBA_TRACE_DEBUG(("RGbaServerSession::Connect 1"));
        error = CreateSession(KGbaServerName,
                              Version(),
                              KDefaultMessageSlots);
        }
    
    return error;
    }


// -----------------------------------------------------------------------------
// RGbaServerSession::Version()
// -----------------------------------------------------------------------------
//
TVersion RGbaServerSession::Version() const
    {
    return(TVersion(KGbaServMajorVersionNumber,
                    KGbaServMinorVersionNumber,
                    KGbaServBuildVersionNumber));
    }


// -----------------------------------------------------------------------------
// RGbaServerSession::RequestBootstrap()
// -----------------------------------------------------------------------------
//
void RGbaServerSession::RequestBootstrap( TGBABootstrapInputParams& aInput, TGBABootstrapOutputParams& aOutput, TRequestStatus& aStatus) 
    {
    iGbaInputBuffer.Set(reinterpret_cast <TUint8*>(&aInput), sizeof(TGBABootstrapInputParams), sizeof(TGBABootstrapInputParams));
    iGbaOutputBuffer.Set(reinterpret_cast <TUint8*>(&aOutput), sizeof(TGBABootstrapOutputParams), sizeof(TGBABootstrapOutputParams));
    TIpcArgs messageParameters(&iGbaInputBuffer, &iGbaOutputBuffer);
    SendReceive(EGbaServRequestBootstrap, messageParameters, aStatus);
    }


// -----------------------------------------------------------------------------
// RGbaServerSession::CancelBootstrap()
// -----------------------------------------------------------------------------
//
TInt RGbaServerSession::CancelBootstrap() const
    {
    return SendReceive(EGbaServCancelRequestBootstrap);
    }

// -----------------------------------------------------------------------------
// RGbaServerSession::WriteOption()
// -----------------------------------------------------------------------------
//
TInt RGbaServerSession::WriteOption(TUid optionUid, const TDesC8& aValue) const
    {
    TIpcArgs messageParameters(optionUid.iUid,&aValue); 
    return SendReceive(EGbaServWriteOption,messageParameters);
    }


// -----------------------------------------------------------------------------
// RGbaServerSession::IsGBAUSupported()
// -----------------------------------------------------------------------------
//
TInt RGbaServerSession::IsGBAUSupported( TBool& aIsGBAUSupported )
    {

    TPckg<TBool> pckg( aIsGBAUSupported );
    TIpcArgs messageParameters( &pckg ); 
    TInt err = SendReceive(EGbaServIsGBAUSupported,messageParameters);
    GBA_TRACE_DEBUG_NUM(("returned error is %d"), err );
    return err;
    }


// -----------------------------------------------------------------------------
// StartServer()
// -----------------------------------------------------------------------------
//
static TInt StartServer()
    {
    TInt result;

    TFindServer findGbaServer(KGbaServerName);
    TFullName name;

    result = findGbaServer.Next(name);
    if ( result == KErrNone )
        {
        return KErrNone;
       }

    result = CreateServerProcess();
    if ( result != KErrNone )
        {
        return  result;
        }

    return  KErrNone;
    }


// -----------------------------------------------------------------------------
// CreateServerProcess()
// -----------------------------------------------------------------------------
//
static TInt CreateServerProcess()
    {
    TInt result;
    const TUidType serverUid(KNullUid, KNullUid, KServerUid3);
    RProcess server;
    result = server.Create( KGbaServerName, _L(""), serverUid );
    if ( result != KErrNone )
        {
        return  result;
        }

    TRequestStatus stat;
    server.Rendezvous(stat);
    if (stat!=KRequestPending)
        {
        // abort startup
        server.Kill(0);
        }
    else
        {
        // logon OK - start the server
        server.Resume();
        }
    // wait for start or death
    User::WaitForRequest(stat);
    // we can't use the 'exit reason' if the server panicked as this
    // is the panic 'reason' and may be '0' which cannot be distinguished
    // from KErrNone
    TInt r=(server.ExitType()==EExitPanic) ? KErrGeneral : stat.Int();
    server.Close();

    return  r;
    }
    

//EOF