/****************************************************************************

**

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

** All rights reserved.

** Contact: Nokia Corporation (developer.feedback@nokia.com)

**

** This file is part of the HbCore module of the UI Extensions for Mobile.

**

** GNU Lesser General Public License Usage

** This file may be used under the terms of the GNU Lesser General Public

** License version 2.1 as published by the Free Software Foundation and

** appearing in the file LICENSE.LGPL included in the packaging of this file.

** Please review the following information to ensure the GNU Lesser General

** Public License version 2.1 requirements will be met:

** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.

**

** In addition, as a special exception, Nokia gives you certain additional

** rights.  These rights are described in the Nokia Qt LGPL Exception

** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.

**

** If you have questions regarding the use of this file, please contact

** Nokia at developer.feedback@nokia.com.

**

****************************************************************************/

#include <hbdevicedialogtrace_p.h>

#include <hbdevicedialogserverdefs_p.h>

#include <apacmdln.h>

#include "hbdevicedialogclientsession_p.h"

// Check if the client is running in device dialog server

static bool IsDeviceDialogServer()

{

    const TUid ServerUid = {0x20022FC5};

    return RProcess().SecureId().operator TUid() == ServerUid;

}

// Preallocate 1 message slot for sessions

static const int KNumAsyncMessageSlots = 1;

/*!

    \internal

*/

RHbDeviceDialogClientSession::RHbDeviceDialogClientSession()

{

    TRACE_ENTRY

    TRACE_EXIT

}

/*!

    \internal

*/

RHbDeviceDialogClientSession::~RHbDeviceDialogClientSession()

{

    TRACE_ENTRY

    TRACE_EXIT

}

TInt RHbDeviceDialogClientSession::Connect(TRequestStatus *aStatus)

{

    TRACE_ENTRY

    // Check server is not trying to connect to itself

    if (IsDeviceDialogServer()) {

      return KErrNotSupported;

    }

    TInt error = KErrNone;

    if (!Handle()) {

        TVersion serverVersion(KHbServerMajor, KHbServerMinor, KHbServerBuild);

        error = CreateSession(KHbServerName, serverVersion, KNumAsyncMessageSlots,

            EIpcSession_Unsharable, 0, aStatus);

    }

    TRACE_EXIT

    return error;

}

/*!

    \internal

*/

TInt RHbDeviceDialogClientSession::Connect()

{

    TRACE_ENTRY

    // Check server is not trying to connect to itself

    if (IsDeviceDialogServer()) {

      return KErrNotSupported;

    }

    TInt error = KErrNone;

    TInt retry(3);

    if (!Handle()) {

        forever {

            TVersion serverVersion(KHbServerMajor, KHbServerMinor, KHbServerBuild);

            error = CreateSession(KHbServerName, serverVersion, KNumAsyncMessageSlots);

            if (error != KErrNotFound && error != KErrServerTerminated) {

                // KErrNone, KErrPermissionDenied or other serious error.

                break;

            }

            if (--retry == 0) {

                // We have tried enough, return an error.

                break;

            }

            error = StartServer();

            if (error != KErrNone && error != KErrAlreadyExists) {

                // Unrecoverable error, return an error.

                break;

            }

        } // for-loop end

    }

    TRACE_EXIT

    return error;

}

TBool RHbDeviceDialogClientSession::ServerRunning()

{

    TRACE_STATIC_ENTRY

    TFindServer findHbServer(KHbServerName);

    TFullName name;

    TRACE_EXIT

    return findHbServer.Next(name) == KErrNone;

}

/*!

    \internal

*/

TInt RHbDeviceDialogClientSession::StartServer()

{

    TRACE_ENTRY

    TInt error(KErrNone);

    if (ServerRunning()) {

        // Already running, return error.

        return KErrAlreadyExists;

    }

    RProcess process;

    // Create the server process

    error = process.Create(KHbServerExe, KNullDesC);

    if (error != KErrNone) {

        // Process could not be created, return error.

        return error;

    }

    CApaCommandLine* apaCommandLine = 0;

    TRAP(error, apaCommandLine = CApaCommandLine::NewL());

    if (error != KErrNone) {

        process.Close();

        return error;

    }

    TRAP(error,

        apaCommandLine->SetExecutableNameL(KHbServerExe);

        apaCommandLine->SetCommandL(EApaCommandBackground);

        apaCommandLine->SetProcessEnvironmentL(process);

    );

    delete apaCommandLine;

    apaCommandLine = 0;

    if (error != KErrNone) {

        process.Close();

        return error;

    }

    TRequestStatus status;

    process.Rendezvous(status);

    if (status != KRequestPending) {

        process.Close();

        return KErrGeneral;

    }

    process.Resume();    // logon OK - start the server

    // Wait for start or death

    User::WaitForRequest(status);

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

    if (process.ExitType() == EExitPanic) {

        error = KErrGeneral;

    } else {

        error = status.Int();

    }

    process.Close();

    TRACE_EXIT

    return error;

}

/*!

    \internal

*/

void RHbDeviceDialogClientSession::Close()

{

    TRACE_ENTRY

    RSessionBase::Close();

    TRACE_EXIT

}

/*!

    \internal

*/

int RHbDeviceDialogClientSession::SendSyncRequest(int aCommand, int aInt0)

{

    TRACE_ENTRY

    TIpcArgs args(aInt0);

    TInt err(KErrBadHandle);

    if (Handle()){

        err = SendReceive( aCommand, args );

    }

    TRACE_EXIT

    return err;

}

/*!

    \internal

*/

int RHbDeviceDialogClientSession::SendSyncRequest(int aCommand, const TDesC8& aData, TDes8 *aReceiveData)

{

    TRACE_ENTRY

    TIpcArgs args( &aData );

    args.Set(KSlot1, aReceiveData);

    TInt err (KErrBadHandle);

    if (Handle()) {

        err = SendReceive(aCommand, args);

    }

    TRACE_EXIT

    return err;

}

/*!

    \internal

*/

int RHbDeviceDialogClientSession::SendSyncRequest(int aCommand, TDes8& aData, TDes8 *aReceiveData)

{

    TRACE_ENTRY

    TIpcArgs args( &aData );

    args.Set(KSlot1, aReceiveData);

    TInt err ( KErrBadHandle );

    if (Handle()) {

        err = SendReceive(aCommand, args);

    }

    TRACE_EXIT

    return err;

}

/*!

    \internal

*/

int RHbDeviceDialogClientSession::SendASyncRequest(int aCommand, TDes8& aData, TDes8& aType, TRequestStatus& aStatus)

{

    TRACE_ENTRY

    TIpcArgs args(&aData, &aType);

    TInt err(KErrBadHandle);

    if (Handle()) {

        err = KErrNone;

        SendReceive(aCommand, args, aStatus);

    }

    TRACE_EXIT

    return err;

}