/*

* Copyright (c) 2009 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 RHtiBtCommInterface class.

*              Symbian side component uses this interface to receive and

*              send HTI data to HtiBtCommServer.

*              HtiBtCommServer acts as proxy to send and receive data

*              to and from PC.

*

*/

// INCLUDE FILES

#include "HtiBtClientServerCommon.h"

#include "HtiBtCommInterface.h"

#include <e32uid.h>

// CONSTANTS

const TUint KBtCommServerDefaultMessageSlots = 4; // Read, write, readCancel, writeCancel

// Constants

/*---------------------------------------------------------------------------*/

EXPORT_C RHtiBtCommInterface::RHtiBtCommInterface()

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::RHtiBtCommInterface()" );

    }

/*---------------------------------------------------------------------------*/

EXPORT_C TInt RHtiBtCommInterface::Connect( TDesC8& aDeviceNameOrAddress,

                                            TInt aPort )

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::Connect()" );

    TInt error = StartThread(); // see HtiBtClientServerCommon.h

    if (error == KErrNone)

        {

        error = CreateSession( KBtCommServerName,

                               Version(),

                               KBtCommServerDefaultMessageSlots );

        }

    if ( error )

        return error;

    return ConnectBt( aDeviceNameOrAddress, aPort );

    }

/*---------------------------------------------------------------------------*/

EXPORT_C void RHtiBtCommInterface::Close()

    {

    HTI_LOG_FUNC_IN( "RHtiBtCommInterface::Close" );

    // Use thread finder to find the server thread

    TFullName threadName;

    TFullName matchPattern;

    matchPattern.Append( _L( "*" ) );

    matchPattern.Append( KBtCommServerName );

    matchPattern.Append( _L( "*" ) );

    TFindThread threadFinder;

    threadFinder.Find( matchPattern );

    TInt err = threadFinder.Next( threadName );

    if ( err )

        {

        HTI_LOG_FORMAT( "RHtiBtCommInterface::Close: Failed to find server thread: %d", err );

        User::Panic( _L( "BtIf Close, server thread not found" ), err );

        }

    HTI_LOG_TEXT( "RHtiBtCommInterface::Close: Found server thread:" );

    HTI_LOG_DES( threadName );

    RThread thread;

    err = thread.Open( threadName );

    if ( err )

        {

        HTI_LOG_FORMAT( "RHtiBtCommInterface::Close: Failed to open server thread: %d", err );

        User::Panic( _L( "BtIf Close, error opening server thread" ), err );

        }

    else

        {

        // initiate server shutdown

        RSessionBase::Close();

        // For clean server stop, wait for its death

        HTI_LOG_TEXT( "RHtiBtCommInterface::Close: Waiting for server thread to die..." );

        TRequestStatus status;

        thread.Logon( status );

        User::WaitForRequest( status );

        HTI_LOG_TEXT( "RHtiBtCommInterface::Close: Server thread dead." );

        }

    thread.Close();

    HTI_LOG_FUNC_OUT( "RHtiBtCommInterface::Close" );

    }

/*---------------------------------------------------------------------------*/

EXPORT_C TVersion RHtiBtCommInterface::Version(void) const

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::Connect()" );

    return ( TVersion( KBtCommServerMajorVersionNumber,

                       KBtCommServerMinorVersionNumber,

                       KBtCommServerBuildVersionNumber ) );

    }

/*---------------------------------------------------------------------------*/

EXPORT_C TInt RHtiBtCommInterface::GetSendBufferSize() const

    {

    return KClientSendBufferMaxSize;

    }

/*---------------------------------------------------------------------------*/

EXPORT_C TInt RHtiBtCommInterface::GetReceiveBufferSize() const

    {

    return KClientReceiveBufferMaxSize;

    }

/*---------------------------------------------------------------------------*/

EXPORT_C void RHtiBtCommInterface::Receive(TDes8& aData,

                                        TRequestStatus& aStatus)

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::Receive()" );

    SendReceive( EBtCommServerRecv, TIpcArgs( &aData ), aStatus );

    }

/*---------------------------------------------------------------------------*/

EXPORT_C void RHtiBtCommInterface::Send(const TDesC8& aData,

                                        TRequestStatus& aStatus)

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::Send()" );

    SendReceive( EBtCommServerSend, TIpcArgs( &aData ), aStatus );

    }

/*---------------------------------------------------------------------------*/

EXPORT_C void RHtiBtCommInterface::CancelReceive()

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::CancelReceive()" );

    SendReceive( ECancelBtCommServerRecv, TIpcArgs( NULL ) );

    }

/*---------------------------------------------------------------------------*/

EXPORT_C void RHtiBtCommInterface::CancelSend()

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::CancelSend()" );

    SendReceive( ECancelBtCommServerSend, TIpcArgs( NULL ) );

    }

/*---------------------------------------------------------------------------*/

EXPORT_C TInt RHtiBtCommInterface::GetPortNumber() const

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::GetPortNumber()" );

    TPckgBuf<TInt> pckg;

    TInt ret = SendReceive( EGetServicePortNumber, TIpcArgs( &pckg ) );

    if ( ret == KErrNone )

        {

        ret = pckg();

        }

    return ret;

    }

/*---------------------------------------------------------------------------*/

TInt RHtiBtCommInterface::ConnectBt( TDesC8& aDeviceNameOrAddress, TInt aPort )

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::ConnectBt()" );

    return SendReceive( EBtCommServerConnect,

                            TIpcArgs( &aDeviceNameOrAddress, aPort ) );

    }

/*---------------------------------------------------------------------------*/

GLDEF_C TInt E32Main()

    {

    HTI_LOG_TEXT( "RHtiBtCommInterface::E32Main()" );

    return KErrNone;

    }

// End of the file