/*

 * Component Name: Headset Simulator

 * Author: Comarch S.A.

 * Version: 1.0

 * Copyright (c) 2010 Comarch S.A.

 *  

 * This Software is submitted by Comarch S.A. to Symbian Foundation Limited on 

 * the basis of the Member Contribution Agreement entered between Comarch S.A. 

 * and Symbian Foundation Limited on 5th June 2009 (“Agreement”) and may be 

 * used only in accordance with the terms and conditions of the Agreement. 

 * Any other usage, duplication or redistribution of this Software is not 

 * allowed without written permission of Comarch S.A.

 * 

 */

#include "hsaudioserver.h"

#include "debug.h"

CHsAudioServer* CHsAudioServer::NewL( RSocketServ& aSocketServ,

        TBool aPullAudio )

    {

    CHsAudioServer* self = CHsAudioServer::NewLC( aSocketServ, aPullAudio );

    CleanupStack::Pop( self );

    return self;

    }

CHsAudioServer* CHsAudioServer::NewLC( RSocketServ& aSocketServ,

        TBool aPullAudio )

    {

    CHsAudioServer* self = new ( ELeave ) CHsAudioServer( aSocketServ,

            aPullAudio );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

CHsAudioServer::~CHsAudioServer()

    {

    if ( iSCOSocket )

        {

        delete iSCOSocket;

        }

    }

void CHsAudioServer::ListenL()

    {

    TRACE_FUNC_ENTRY

    if ( iListening )

        {

        User::Leave( KErrInUse );

        }

    if ( iSCOSocket )

        {

        delete iSCOSocket;

        iSCOSocket = NULL;

        }

    iSCOSocket = CBluetoothSynchronousLink::NewL( *this, iSServ );

    User::LeaveIfNull( iSCOSocket );

    User::LeaveIfError( iSCOSocket->AcceptConnection( iAcceptedPackets ) );

    TRACE_FUNC_EXIT

    }

void CHsAudioServer::ConnectL( const TBTDevAddr &aAddr )

    {

    TRACE_FUNC_ENTRY

    if ( iConnected )

        {

        User::Leave( KErrInUse );

        }

    if ( iSCOSocket )

        {

        delete iSCOSocket;

        iSCOSocket = NULL;

        }

    iSCOSocket = CBluetoothSynchronousLink::NewL( *this, iSServ );

    User::LeaveIfNull( iSCOSocket );

    iAddr = aAddr;

    iSCOSocket->SetupConnection( aAddr, iAcceptedPackets );

    TRACE_FUNC_EXIT

    }

void CHsAudioServer::Disconnect()

    {

    TRACE_FUNC_ENTRY

    if ( iSCOSocket && iConnected )

        {

        iSCOSocket->CancelReceive();

        iSCOSocket->CancelSend();

        iSCOSocket->Disconnect();

        delete iSCOSocket;

        iSCOSocket = NULL;

        iConnected = EFalse;

        iListening = EFalse;

        ListenL();

        }

    TRACE_FUNC_EXIT

    }

void CHsAudioServer::Shutdown()

    {

    TRACE_FUNC_ENTRY

    if ( iSCOSocket )

        {

        if ( iListening )

            {

            iSCOSocket->CancelAccept();

            }

        delete iSCOSocket;

        iSCOSocket = NULL;

        iListening = EFalse;

        iConnected = EFalse;

        }

    TRACE_FUNC_EXIT

    }

void CHsAudioServer::SetPullAudio( TBool aPullAudio )

    {

    iPullAudio = aPullAudio;

    }

TBool CHsAudioServer::IsConnected()

    {

    return iConnected;

    }

TBool CHsAudioServer::IsListen()

    {

    return iListening;

    }

CHsAudioServer::CHsAudioServer( RSocketServ& aSocketServ, TBool aPullAudio ) :

    iSServ( aSocketServ ), iAcceptedPackets( EAnySCOPacket ), iListening(

            EFalse ), iPullAudio( aPullAudio )

    {

    }

void CHsAudioServer::ConstructL()

    {

    }

void CHsAudioServer::HandleSetupConnectionCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L("aErr = %d"), aErr) );

    iConnected = ETrue;

    iListening = EFalse;

    iSCOSocket->AcceptConnection( TBTSyncPackets( iAcceptedPackets ) );

    if ( aErr == KErrNone && iPullAudio )

        {

        User::LeaveIfError( iSCOSocket->Receive( iReceiveBuffer ) );

        }

    TRACE_FUNC_EXIT

    }

void CHsAudioServer::HandleDisconnectionCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L("aErr = %d"), aErr) );

    iConnected = EFalse;

    iListening = ETrue;

    iSCOSocket->AcceptConnection( TBTSyncPackets( iAcceptedPackets ) );

    TRACE_FUNC_EXIT

    }

void CHsAudioServer::HandleAcceptConnectionCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L("aErr = %d"), aErr) );

    iConnected = ETrue;

    iListening = EFalse;

    if ( aErr == KErrNone && iPullAudio && iSCOSocket )

        {

        User::LeaveIfError( iSCOSocket->Receive( iReceiveBuffer ) );

        }

    TRACE_FUNC_EXIT

    }

void CHsAudioServer::HandleSendCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L("aErr = %d"), aErr) );

    if ( iPullAudio )

        {

        User::LeaveIfError( iSCOSocket->Receive( iReceiveBuffer ) );

        }

    TRACE_FUNC_EXIT

    }

void CHsAudioServer::HandleReceiveCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L("aErr = %d"), aErr) );

    if ( iPullAudio && aErr != KErrNone )

        {

        User::LeaveIfError( iSCOSocket->Receive( iReceiveBuffer ) );

        }

    if ( aErr == KErrDisconnected )

        {

        Disconnect();

        }

    TRACE_FUNC_EXIT

    }