/*

* Copyright (c) 2010 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 <e32cmn.h>

#include "stubclient.h"

#include "stubclientsrv.h"

_LIT(KStubSrvExe, "stubsrv.exe");

static TInt ClientStart()

	{

	RProcess server;

	TInt r = server.Create(KStubSrvExe, KNullDesC, TUidType(KNullUid, KNullUid, KStubSrvUid3));

	if (r!=KErrNone)

		return r;

	TRequestStatus stat;

	server.Rendezvous(stat);

	if (stat != KRequestPending)

	    server.Kill(0);

	else

	    server.Resume();

	User::WaitForRequest(stat);

	r = (server.ExitType() == EExitPanic) ? KErrGeneral : stat.Int();

	server.Close();

	return r;

	}

void RStubClient::EnqueBehavior(const TApiBehavior& aBeh, TInt aExeDuration)

    {

    CheckSession();

    TApiBehaviorPckgBuf buf(aBeh);

    (void) SendReceive(EStubSrvEnqueApiBehavior, TIpcArgs(&buf, aExeDuration));    

    }

void RStubClient::DeleteBehaviors(TUint aLib, TUint aApi)

    {

    CheckSession();

    (void) SendReceive(EStubSrvDeleteApiBehaviors, TIpcArgs(aLib, aApi)); 

    }

void RStubClient::InvokeApi(TApiBehaviorPckg& aBehPckg, TApiInvokeMode aMode)

    {

    CheckSession();

    (void) SendReceive(EStubSrvInvokeApi, TIpcArgs(&aBehPckg, aMode, 0));    

    }

void RStubClient::InvokeApiL(TApiBehaviorPckg& aBehPckg, TRequestStatus& aStatus, TApiInvokeMode aMode)

    {

    CheckSession();

    TInt transctionId = 0;

    TPckg<TInt> transpckg(transctionId);

    TInt err = SendReceive(EStubSrvGetApiCompletionCode, TIpcArgs(aBehPckg().iLib, aBehPckg().iApi, &transpckg));

    if (err)

        {

        User::Leave(err);

        }

    SendReceive(EStubSrvInvokeApi, TIpcArgs(&aBehPckg, aMode, transctionId), aStatus);

    }

void RStubClient::InvokeApiCancel(TUint aLib, TUint aApi)

    {

    CheckSession();

    (void) SendReceive(EStubSrvInvokeApiCancel, TIpcArgs(aLib, aApi));

    }

TInt RStubClient::Connect()

    {

	TInt retVal = CreateSession(KStubSrvName, Version());

	if (retVal)

        {

        retVal = ClientStart();

        if (!retVal)

            retVal = CreateSession(KStubSrvName, Version());

        }

    return retVal;

    }

TVersion RStubClient::Version() const

    {

    return(TVersion(KStubSrvMajorVersionNumber, KStubSrvMinorVersionNumber, KStubSrvBuildNumber));

    }

_LIT(KPanicCat, "!Stubsrv");

void RStubClient::CheckSession()

    {

    if (!Handle())

        User::Panic(KPanicCat, KErrBadHandle);

    }