Changeset 34

Timestamp:

07/22/07 17:43:30 (5 years ago)

Author:

dlefevre

Message:

Initial Bluetooth server implementation

Files:

• mymrc/trunk/mymrc/src/networking/btserver.py (modified) (3 diffs)

mymrc/trunk/mymrc/src/networking/btserver.py

@@ +1 @@
+from settings.settings import Settings
+import thread, threading, bluetooth
+from mobileclient.client import Client
+
 def printd( aString ):
     print aString
+    
+class BtServerSocket( bluetooth.BluetoothSocket ):
+    def __init__(self, aMac="", aPort=bluetooth.PORT_ANY):
+        bluetooth.BluetoothSocket.__init__( self, bluetooth.RFCOMM )
+        self.bind( (aMac, aPort) )
+        self.listen(1)
+        
+        if aPort == bluetooth.PORT_ANY:
+            bluetooth.port = self.getsockname()[1]
+        
+        uuid = "94f39d29-7d6d-437d-973b-fba39e49d4ee"
+
+        bluetooth.advertise_service( self, "myMRC",
+                   service_id = uuid,
+                   service_classes = [ uuid, bluetooth.SERIAL_PORT_CLASS ],
+                   profiles = [ bluetooth.SERIAL_PORT_PROFILE ] )
+        
+        self._iLock = threading.Semaphore()
+        self._iClientStack = []
+        
+        printd("Bt interface: %s"%(repr(self.getsockname())))
+
+    ## Add instance to the array.
+    #  @param self: The object pointer.
+    #  @param aChannel: Channel to had the the array.
+    def _addToStack( self, aClient ):
+        self._iLock.acquire( )
+        self._iClientStack.append( aClient )
+        self._iLock.release( )
+        printd( "Client added to stack")
+        
+    ## Handle incomming connection request.
+    #  @param self: The object pointer.
+    def _connectionHandler( self ):
+        printd("Wait for incoming connection")
+        while True:
+            try:
+                client = Client(self.accept())
+                self._addToStack( client )
+            except Exception, e:
+                printd("BT interface busy: %s", repr(e))        
+    
+        
+    ## Listen interface for incomming connection.
+    #  @param self The object pointer.
+    def start( self ):
+        thread.start_new_thread(self._connectionHandler, () )     
+        
+    def __del__(self):
+        for client in self._iClientStack:
+            self._removeFromStack(client)
+            del client
 
 ## Bluetooth server singleton.
@@ -17 +73 @@
         def start(self):
             self._iRunning = True
-            printd("BtServer start not implemented")
-            pass
+            mac = Settings().get("bluetooth","mac")
+            port = int(Settings().get("bluetooth","port"))
+            self._iSocketServer = BtServerSocket( mac, port )
+            self._iSocketServer.start()
+            printd("BtServer started")
         
         ## Stop the server.
@@ -24 +83 @@
         def stop(self):
             self._iRunning = False
-            printd("BtServer stop not implemented")
-            pass
+            del self._iSocketServer
+            printd("BtServer stopped")
         
         ## Restart server.
         #  @param self The object pointer.    
         def restart(self):
-            printd("BtServer restart not implemented")
-            pass
+            printd("Restarting BtServer")
+            self.stop()
+            self.start()
         
         def isRunning(self):