--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/bluetoothengine/bthid/bthidserver/src/socketlistener.cpp	Mon Jan 18 20:28:57 2010 +0200
@@ -0,0 +1,171 @@
+/*
+* Copyright (c) 2008 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:  This is the implementation of application class
+ *
+*/
+
+#include <bt_sock.h>
+#include "socketlistener.h"
+#include "listenerobserver.h"
+#include "sockets.pan"
+#include "bthidclientsrv.h" //for BT Stack v2 security
+#include "bthidtypes.h"
+#include <e32std.h>
+#include <e32svr.h>
+#include "debug.h"
+// The transport protocol of the sockets used by this object.
+_LIT(KTransportProtocol, "L2CAP");
+
+const TInt KListenQueueSize = 2;
+
+CSocketListener* CSocketListener::NewL(RSocketServ& aSocketServ, TUint aPort,
+        MListenerObserver& aObserver, TBool aAuthorisation)
+    {
+    CSocketListener* self = NewLC(aSocketServ, aPort, aObserver,
+            aAuthorisation);
+    CleanupStack::Pop(self);
+    return self;
+    }
+
+CSocketListener* CSocketListener::NewLC(RSocketServ& aSocketServ,
+        TUint aPort, MListenerObserver& aObserver, TBool aAuthorisation)
+    {
+    CSocketListener* self = new (ELeave) CSocketListener(aSocketServ, aPort,
+            aObserver, aAuthorisation);
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    return self;
+    }
+
+CSocketListener::CSocketListener(RSocketServ& aSocketServ, TUint aPort,
+        MListenerObserver& aObserver, TBool aAuthorisation) :
+    CActive(CActive::EPriorityStandard), iSocketServer(aSocketServ), iPort(
+            aPort), iObserver(aObserver), iAuthorisationAskedFlag(
+            aAuthorisation)
+    {
+    CActiveScheduler::Add(this);
+    }
+
+CSocketListener::~CSocketListener()
+    {
+        TRACE_INFO((_L("[BTHID]\tCSocketListener::~CSocketListener()")));
+    Cancel(); // Causes DoCancel
+
+    // Close the listening socket
+    iListeningSocket.Close();
+    }
+
+void CSocketListener::ConstructL()
+    {
+        TRACE_INFO((_L("[BTHID]\tCSocketListener::ConstructL()")));
+    // Open the listening socket
+    User::LeaveIfError(iListeningSocket.Open(iSocketServer,
+            KTransportProtocol));
+    TL2CAPSockAddr addr;
+    addr.SetPort(iPort);
+    TBTServiceSecurity serverSecurity;
+    serverSecurity.SetUid(KUidBTHidServer);
+    serverSecurity.SetAuthentication(ETrue); //Microsoft KB reconnect needs this!?? --> This line has caused IOP problems before.
+    serverSecurity.SetAuthorisation(iAuthorisationAskedFlag); //This should be according to Authorisation setting
+    serverSecurity.SetDenied(EFalse);
+
+    //No need for Interrupt channel to use encryption
+    if (KL2CAPHidInterrupt == iPort)
+        serverSecurity.SetEncryption(EFalse); //Logitech Mx5000 needs this false.
+    else
+        serverSecurity.SetEncryption(ETrue);
+
+    addr.SetSecurity(serverSecurity);
+    //Bind
+    User::LeaveIfError(iListeningSocket.Bind(addr));
+    User::LeaveIfError(iListeningSocket.Listen(KListenQueueSize));
+
+    }
+
+void CSocketListener::DoCancel()
+    {
+    // Cancel any outstanding request
+    iListeningSocket.CancelAccept();
+    }
+
+void CSocketListener::RunL()
+    {
+    TInt err = iStatus.Int();
+
+        TRACE_INFO((_L("[BTHID]\tCSocketListener::RunL(), iStatus.Int()=%d"),err));
+
+    if (err == KErrCancel)
+        return; //Active task was cancelled.
+
+    // In case of KErrHardwareNotAvailable,  cancel and reset the listening
+    // socket and reissue the Accept is needed.
+    if (err == KErrHardwareNotAvailable)
+        {
+        iListeningSocket.CancelAll();
+
+        err = iListeningSocket.Listen(KListenQueueSize);
+
+        if (err == KErrNone)
+            {
+            iListeningSocket.Accept(*iAcceptSocket, iStatus);
+            SetActive();
+            }
+        else
+            {
+            // Report the result to the observer.
+            iObserver.SocketAccepted(iPort, err);
+            }
+        }
+    else
+        {
+        // Report the result to the observer.
+        iObserver.SocketAccepted(iPort, err);
+        }
+    }
+
+TInt CSocketListener::AcceptConnection(RSocket& aSocket)
+    {
+
+        TRACE_INFO((_L("[BTHID]\tCSocketListener::AcceptConnection()")));
+
+    // If we aren't in the correct state to accept, panic.
+    __ASSERT_DEBUG(!IsActive(),
+            User::Panic(KPanicBTConnection, ESocketsBadState));
+
+    // close old connection - if any
+    aSocket.Close();
+
+    // Open abstract socket
+    TInt err = aSocket.Open(iSocketServer);
+
+    if (err == KErrNone)
+        {
+
+            TRACE_INFO((_L("[BTHID]\tCSocketListener::AcceptConnection(), opening new socket succeed")));
+        // Accept onto the new socket
+        iListeningSocket.Accept(aSocket, iStatus);
+
+        // Keep a handle on the accept socket.
+        iAcceptSocket = &aSocket;
+
+        SetActive();
+        }
+    else
+        TRACE_INFO((_L("[BTHID]\tCSocketListener::AcceptConnection(), opening new socket failed")));
+
+    return err;
+    }
+
+//End of file
+