--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/bluetoothengine/headsetsimulator/core/src/Server/hsclient.cpp	Wed Sep 15 15:59:44 2010 +0200
@@ -0,0 +1,300 @@
+/*
+ * 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 "hsclient.h"
+#include "hsclientobservers.h"
+#include "debug.h"
+
+CHsClient* CHsClient::NewL( CBluetoothSocket *aClient,
+        MHsClientStateNotifier *aClientStateNotifier,
+        MHsClientObserver *aClientDisconnectNotifier )
+    {
+    User::LeaveIfNull( aClient );
+
+    CHsClient *self = CHsClient::NewLC( aClient, aClientStateNotifier,
+            aClientDisconnectNotifier );
+    CleanupStack::Pop( self );
+
+    return self;
+    }
+
+CHsClient* CHsClient::NewLC( CBluetoothSocket *aClient,
+        MHsClientStateNotifier *aClientStateNotifier,
+        MHsClientObserver *aClientDisconnectNotifier )
+    {
+
+    User::LeaveIfNull( aClient );
+
+    CHsClient *self = new ( ELeave ) CHsClient( *aClient, aClientStateNotifier,
+            aClientDisconnectNotifier );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+
+    return self;
+    }
+
+CHsClient::~CHsClient()
+    {
+    TRACE_FUNC_ENTRY
+
+    if ( iSocket )
+        {
+        iSocket->CancelAll();
+        delete iSocket;
+        }
+
+    if ( iConnected )
+        {
+        if ( iStateNotifier )
+            {
+            TRAP_IGNORE( iStateNotifier->HandleClientDisconnectL(KErrNone) );
+            }
+        }
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::Send( const TDesC8 &aData )
+    {
+    TRACE_FUNC_ENTRY
+
+    if ( iSocket && iConnected )
+        {
+        TRAP_IGNORE( BufferedProcessL(aData) );
+        }
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::SetClientDisconnectNotfier( MHsClientObserver &aNotifier )
+    {
+    TRACE_FUNC_ENTRY
+
+    iClientObserver = &aNotifier;
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::SetClientStateNotfier( MHsClientStateNotifier &aNotifier )
+    {
+    TRACE_FUNC_ENTRY
+
+    iStateNotifier = &aNotifier;
+
+    TRACE_FUNC_EXIT
+    }
+
+MHsClientStateNotifier* CHsClient::GetClientStateNotifer()
+    {
+    TRACE_FUNC_ENTRY
+
+    TRACE_FUNC_EXIT
+    return iStateNotifier;
+    }
+
+CHsClient::CHsClient( CBluetoothSocket &aClient,
+        MHsClientStateNotifier *aClientStateNotifier,
+        MHsClientObserver *aClientDisconnectNotifier )
+    {
+    TRACE_FUNC_ENTRY
+
+    iSocket = &aClient;
+    iStateNotifier = aClientStateNotifier;
+    iState = CHsClient::EIdle;
+    iConnected = ETrue;
+    iClientObserver = aClientDisconnectNotifier;
+    iSocket->SetNotifier( *this );
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::ConstructL()
+    {
+    TRACE_FUNC_ENTRY
+    BufferedProcessL();
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::RawRecvL( TDes8 &aData )
+    {
+    TRACE_FUNC_ENTRY
+
+    User::LeaveIfNull( iSocket );
+    if ( !iConnected )
+        {
+        TRACE_INFO( _L(" Client is no longer connected" ) )
+        User::LeaveIfError( KErrDisconnected );
+        }
+    iState = CHsClient::EReceiving;
+    User::LeaveIfError( iSocket->RecvOneOrMore( aData, iReceiveFlag,
+            iReceiveMessageLength ) );
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::RawSendL( const TDesC8 &aData )
+    {
+    TRACE_FUNC_ENTRY
+
+    User::LeaveIfNull( iSocket );
+    if ( !iConnected )
+        {
+        User::LeaveIfError( KErrDisconnected );
+        }
+    if ( aData.Length() == 0 )
+        {
+        User::Leave( KErrWrite );
+        }
+    iState = CHsClient::ESending;
+    User::LeaveIfError( iSocket->Send( aData, iSendFlag ) );
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::BufferedProcessL( const TDesC8 &aData )
+    {
+    TRACE_FUNC_ENTRY
+
+    if ( iState != CHsClient::ESending )
+        {
+        iTempSendBuf.Append( aData );
+        SwapBuffers();
+        if ( iSendBuf.Length() > 0 )
+            {
+            iSocket->CancelRecv();
+            RawSendL( iSendBuf );
+            }
+        else if ( iState != CHsClient::ESending )
+            {
+            RawRecvL( iReceiveMessageBuffer );
+            }
+        }
+    else
+        {
+
+        iTempSendBuf.Append( aData );
+        }
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::SwapBuffers()
+    {
+    TRACE_FUNC_ENTRY
+
+    iSendBuf.Copy( iTempSendBuf );
+    iTempSendBuf.Zero();
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::HandleConnectCompleteL( TInt aErr )
+    {
+
+    TRACE_FUNC_ENTRY
+    TRACE_INFO( ( _L("aErr = %d"), aErr) )
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::HandleAcceptCompleteL( TInt aErr )
+    {
+    TRACE_FUNC_ENTRY
+    TRACE_INFO( ( _L("aErr = %d"), aErr) )
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::HandleShutdownCompleteL( TInt aErr )
+    {
+    TRACE_FUNC_ENTRY
+    TRACE_INFO( ( _L("aErr = %d"), aErr) )
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::HandleSendCompleteL( TInt aErr )
+    {
+    TRACE_FUNC_ENTRY
+    TRACE_INFO( ( _L("aErr = %d"), aErr) )
+
+    iState = CHsClient::EIdle;
+    iSendBuf.Zero();
+    if ( aErr != KErrDisconnected )
+        {
+        BufferedProcessL( KNullDesC8 );
+        }
+    if ( iStateNotifier )
+        {
+        if ( aErr != KErrDisconnected )
+            {
+            iStateNotifier->HandleClientSendCompleteL( aErr );
+            }
+        else
+            {
+            iConnected = EFalse;
+            iStateNotifier->HandleClientDisconnectL( aErr );
+            iClientObserver->HandleClientDisconnect( this, aErr );
+            }
+        }
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::HandleReceiveCompleteL( TInt aErr )
+    {
+    TRACE_FUNC_ENTRY
+    TRACE_INFO( ( _L("aErr = %d"), aErr) )
+
+    iState = CHsClient::EIdle;
+    if ( iStateNotifier )
+        {
+        if ( aErr == KErrNone )
+            {
+            TRAP_IGNORE( iStateNotifier->HandleClientReceiveCompleteL(
+                            iReceiveMessageBuffer, aErr ) );
+
+            }
+        else
+            {
+            iConnected = EFalse;
+            iStateNotifier->HandleClientDisconnectL( aErr );
+            iClientObserver->HandleClientDisconnect( this, aErr );
+            }
+        }
+
+    if ( aErr == KErrNone )
+        {
+        BufferedProcessL( KNullDesC8 );
+        }
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::HandleIoctlCompleteL( TInt aErr )
+    {
+    TRACE_FUNC_ENTRY
+    TRACE_INFO( ( _L("aErr = %d"), aErr) );
+
+    TRACE_FUNC_EXIT
+    }
+
+void CHsClient::HandleActivateBasebandEventNotifierCompleteL( TInt aErr,
+        TBTBasebandEventNotification& aEventNotification )
+    {
+    TRACE_FUNC_ENTRY
+    TRACE_INFO( ( _L("aErr = %d"), aErr) );
+
+    TRACE_FUNC_EXIT
+    }