/*

* 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 CHtiBtCommServerSession class. This class

*                represents the client session in server.

*

*/

// INCLUDE FILES

#include "HtiBtClientServerCommon.h"

#include "HtiBtCommServerSession.h"

#include "HtiBtCommServer.h"

#include "BtSerialClient.h"

#include "Logger.h"

#include <e32base.h>

#include <e32std.h>

#include <e32svr.h>

// CONSTANTS

 _LIT(KBtComSessPanic, "BtComSessAssrt");

const TInt KBtAddressHexStringLength = 12; // 6 bytes

const TInt KIncomingDataBufSize = 32 * 1024;

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

//

// Class CHtiBtCommServerSession

//

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

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

CHtiBtCommServerSession::CHtiBtCommServerSession( CHtiBtCommServer* aServer )

    : CSession2()

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: CHtiBtCommServerSession()")))

    __DECLARE_NAME( _S( "CHtiBtCommServerSession" ) );

    iBtCommServer = aServer;

    iReadRequestComplete = ETrue;  // ready to accept read request

    iWriteRequestComplete = ETrue;

    iConnectRequestComplete = ETrue;

    iBtCommServer->SessionCreated(this);

    }

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

CHtiBtCommServerSession* CHtiBtCommServerSession::NewL(

    CHtiBtCommServer* aServer )

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: NewL()")))

    CHtiBtCommServerSession* session =

        new (ELeave) CHtiBtCommServerSession( aServer );

    CleanupStack::PushL( session );

    session->ConstructL();

    CleanupStack::Pop( session );

    return session;

    }

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

void CHtiBtCommServerSession::ConstructL()

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: ConstructL()")))

    iBtClient = CBtSerialClient::NewL(*this);

    iIncomingDataBuf = HBufC8::NewL(KIncomingDataBufSize);

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: ConstructL(): Done")))

    }

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

CHtiBtCommServerSession::~CHtiBtCommServerSession()

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: ~CHtiBtCommServerSession()")))

    delete iBtClient;

    ResetAll(KErrCancel);

    delete iIncomingDataBuf;

    if ( iBtCommServer )

        {

        iBtCommServer->SessionFreed();

        }

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: ~CHtiBtCommServerSession(): Done")))

    }

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

void CHtiBtCommServerSession::ServiceL( const RMessage2& aMessage )

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: ServiceL()")))

    TRAPD( error, DispatchMessageL( aMessage ) );

    if ( error != KErrNone )

        {

        LOGFW(DebugLog(_L("CHtiBtCommServerSession::ServiceL error %d"), error);)

        }

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: ServiceL(): Done")))

    }

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

void CHtiBtCommServerSession::DispatchMessageL( const RMessage2 &aMessage )

    {

    LOGFW( DebugLog( _L( "CHtiBtCommServerSession: DispatchMessageL()" ) ) )

    switch ( aMessage.Function() )

        {

        case EBtCommServerConnect:

            {

            HandleConnectRequestL( aMessage );

            }

            break;

        case EBtCommServerSend:

            {

            HandleSendRequestL( aMessage );

            }

            break;

        case EBtCommServerRecv:

            {

            HandleReadRequestL( aMessage );

            }

            break;

        case ECancelBtCommServerRecv:

        case ECancelBtCommServerSend:

            {

            HandleCancelRequestL( aMessage );

            }

            break;

        case EGetServicePortNumber:

            {

            HandlePortNumberRequestL( aMessage );

            }

            break;

        default:

            {

            LOGFW(ErrLog(_L("CHtiBtCommServerSession::DispatchMessageL: Unknown request: %d. Panicing Client"), aMessage.Function());)

            PanicClient( EBadRequest );

            User::Panic( KBtComSessPanic, 1 );

            }

            break;

        }

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: DispatchMessageL(): Done")))

    }

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

void CHtiBtCommServerSession::HandleConnectRequestL( const RMessage2& aMessage )

    {

    LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL()")))

    if ( !iConnectRequestComplete )

        {

        LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Already connecting")))

        aMessage.Complete( KErrNotReady );

        }

    else

        {

        if ( iBtClient->Connected() )

            {

            LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Already connected")))

            aMessage.Complete( KErrNone ); // Already connected. This is not an error?

            }

        else

            {

            LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Starting to connect to remote host")))

            iConnectRequest = aMessage;

            iConnectRequestComplete = EFalse;

            TInt dataLength = (TUint16)aMessage.GetDesLength( 0 ); //first message slot

            LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Data length = %d"), dataLength));

            TInt port = aMessage.Int1();

            LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Port = %d"), port));

            if ( dataLength < 1 )

                {

                LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): No address or name - need to ask device")))

                iBtClient->ConnectL(); // Request is completed in ConnectedToServer

                }

            else if ( dataLength == KBtAddressHexStringLength )

                {

                TBuf8<KBtAddressHexStringLength> addressBuf8;

                aMessage.ReadL( 0, addressBuf8 );

                TBuf<KBtAddressHexStringLength> addressBuf;

                addressBuf.Copy( addressBuf8 );

                TBTDevAddr address;

                TInt result = address.SetReadable( addressBuf );

                LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): SetReadable result = %d"), result));

                if ( result != KBtAddressHexStringLength )

                    {

                    LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Not valid address - use it as name")))

                    iBtClient->ConnectL( addressBuf, port );

                    }

                else

                    {

                    LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Valid address - connect")))

                    iBtClient->ConnectL( address, port );

                    }

                }

            else

                {

                LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Using name to connect")))

                TBTDeviceName8 deviceName8;

                aMessage.ReadL( 0, deviceName8 );

                TBTDeviceName deviceName;

                deviceName.Copy( deviceName8 );

                iBtClient->ConnectL( deviceName, port );

                }

            }

        }

    LOGFW(DebugLog(_L("CHtiBtCommServer:HandleConnectRequestL(): Done")))

    }

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

void CHtiBtCommServerSession::HandleReadRequestL( const RMessage2& aMessage )

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: HandleReadRequestL()")))

    if ( !iReadRequestComplete )

        {

        LOGFW(WarnLog(_L("CHtiBtCommServerSession: HandleReadRequestL(): Pending request. ret=KErrNotReady")))

        // Two simultaneous read requests are not allowed.

        aMessage.Complete(KErrNotReady);

        return;

        }

    // No data in read buffer. Must wait for new data before completing request

    iReadRequest = aMessage;

    iReadRequestComplete = EFalse; // Not ready to complete next request

    TryCompleteReadRequest(); // if there is something in the readbuffer,

                              // use it for completion.

    if ( iIncomingDataBuf->Des().Length() == 0 )

        {

        // Read some bytes to buffer even before client's request.

        iBtClient->ReadAsyncL(); // Issue async request to read more data.

        }

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: HandleReadRequestL(): Done")))

    }

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

void CHtiBtCommServerSession::HandleSendRequestL( const RMessage2& aMessage )

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: HandleSendRequestL()")))

    TInt dataLength = (TUint16)aMessage.GetDesLength( 0 ); //first message slot

    LOGFW( InfoLog( _L( "Framework requested to send data: %d bytes" ), dataLength ) )

    if ( iBtClient->SendBufferMaxSize() < dataLength )

        {

        aMessage.Complete(KErrOverflow);

        LOGFW(ErrLog(_L("CHtiBtCommServerSession: HandleSendRequestL(): client is giving too big data. Cannot handle.")))

        }

    else if ( !iWriteRequestComplete )

        {

        LOGFW(WarnLog(_L("CHtiBtCommServerSession: HandleSendRequestL(): Pending request. ret=KErrNotReady")))

        // Already pending send request. Two simultaneous send requests not allowed.

        aMessage.Complete( KErrNotReady );

        }

    else

        {

        if ( iBtClient->FreeSpaceInSendBuffer() < dataLength )

            {

            LOGFW(DebugLog(_L("CHtiBtCommServerSession: HandleSendRequestL(): Completing send request delayed")))

            // No space in the iBtClient's send buffer. Copy the data to internal

            // buffer and wait for iBtClient to send its data out before adding

            // data to its send buffer.

            delete iSendBuffer;

            iSendBuffer = NULL;

            iSendBuffer = HBufC8::NewL(dataLength);

            TPtr8 ptr = iSendBuffer->Des();

            aMessage.ReadL( 0, ptr );

            iWriteRequestComplete = EFalse;

            iWriteRequest = aMessage;

            // Wait for callback call AllBufferedDataSent. Complete request there.

            }

        else

            {

            LOGFW(DebugLog(_L("CHtiBtCommServerSession: HandleSendRequestL(): Completing send request immediately")))

            // All data can be sent immediately, because there is enough space in

            // iBtClient's send buffer.

            HBufC8* data = HBufC8::NewLC( dataLength );

            TPtr8 ptr = data->Des();

            aMessage.ReadL( 0, ptr );

            iBtClient->SendL( ptr );

            CleanupStack::PopAndDestroy( data );

            aMessage.Complete( KErrNone );

            }

        }

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: HandleSendRequestL(): Done")))

    }

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

void CHtiBtCommServerSession::HandleCancelRequestL( const RMessage2& aMessage )

    {

    ResetAll( KErrCancel );

    aMessage.Complete( KErrNone );

    }

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

void CHtiBtCommServerSession::HandlePortNumberRequestL(const RMessage2& aMessage)

    {

    TPckgBuf<TInt> p( iBtClient->ServicePort() );

    TInt err = aMessage.Write( 0, p, 0 );

    aMessage.Complete( err );

    }

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

void CHtiBtCommServerSession::PanicClient(TInt aPanic) const

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: PanicClient(): %d"), aPanic))

    LOGFW(WarnLog(_L("CHtiBtCommServerSession: PanicClient(): %d. NOT IMPLEMENTED"), aPanic))

    aPanic = aPanic;

    // should be done with RMessage2?

    }

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

void CHtiBtCommServerSession::ResetAll(TInt aCompletionCode)

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: ResetAll()")))

    if ( !iWriteRequestComplete )

        iWriteRequest.Complete( aCompletionCode );

    if ( !iReadRequestComplete )

        iReadRequest.Complete( aCompletionCode );

    if ( !iConnectRequestComplete )

        iConnectRequest.Complete( aCompletionCode ); // error when making connection

    iWriteRequestComplete = ETrue;

    iReadRequestComplete = ETrue;

    iConnectRequestComplete = ETrue;

    delete iIncomingDataBuf;

    iIncomingDataBuf = NULL;

    delete iSendBuffer;

    iSendBuffer = NULL;

    iIncomingDataBuf = HBufC8::New(KIncomingDataBufSize);

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: ResetAll(): Done")))

    }

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

void CHtiBtCommServerSession::ConnectedToServer(TInt aError)

    {

    // Connected to server. Reading has been started.

    LOGFW(InfoLog(_L("CHtiBtCommServerSession: ConnectedToServer: connected to remote host")))

    iConnectRequestComplete = ETrue;

    iConnectRequest.Complete( aError );

    }

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

void CHtiBtCommServerSession::DisconnectedFromServer()

    {

    LOGFW(InfoLog(_L("CHtiBtCommServerSession: DisconnectedFromServer: disconnected from remote host")))

    ResetAll( KErrDisconnected );

    }

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

void CHtiBtCommServerSession::DataFromServer(const TDesC8& aData)

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: DataFromServer: %d bytes"), aData.Length()))

    TPtr8 ptr = iIncomingDataBuf->Des();

    if ( aData.Length() > ptr.MaxLength() - ptr.Length() )

        PanicClient( KErrUnderflow ); // Client is reading too slowly

    ptr.Append( aData );

    TryCompleteReadRequest();

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: DataFromServer: done"), aData.Length()))

    }

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

void CHtiBtCommServerSession::AllBufferedDataSent()

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: AllBufferedDataSent")))

    if ( !iWriteRequestComplete )

        {

        // iBtClient has sent all of its data and is ready to send more.

        TPtr8 ptr = iSendBuffer->Des();

        TRAPD( err, iBtClient->SendL( ptr ); )

        iWriteRequest.Complete( err );

        iWriteRequestComplete = ETrue;

        delete iSendBuffer;

        iSendBuffer = NULL;

        }

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: AllBufferedDataSent: Done")))

    }

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

void CHtiBtCommServerSession::TryCompleteReadRequest()

    {

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: TryCompleteReadRequest")))

    TPtr8 ptr = iIncomingDataBuf->Des();

    if ( iReadRequestComplete || ptr.Length() == 0 )

        {

        LOGFW(DebugLog(_L("CHtiBtCommServerSession: TryCompleteReadRequest: Nothing to complete")))

        return; // No outstanding client request to complete

        }

    TInt dataMaxLength = (TUint16)iReadRequest.GetDesMaxLength(0); //first message slot

    TPtrC8 dataToClient = ptr.Left(dataMaxLength);

    TRAPD(err, iReadRequest.WriteL(0, dataToClient);)

    ptr.Delete(0, dataToClient.Length());

    iReadRequest.Complete(err);

    iReadRequestComplete = ETrue;

    LOGFW(DebugLog(_L("CHtiBtCommServerSession: TryCompleteReadRequest: Done")))

    }

// End of file