Changeset 177 for pykoticon/trunk/bin

Timestamp:

01/26/07 21:23:40 (18 years ago)

Author:

jerome

Message:

Now accepts several concurrent requests.

Files:

• pykoticon/trunk/bin/pykoticon (modified) (2 diffs)

pykoticon/trunk/bin/pykoticon

@@ -41 +41 @@
 import xmlrpclib
 import SimpleXMLRPCServer
+import SocketServer
+
 try :
     import optparse
@@ -88 +90 @@
 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA."""
 
-        
-class MyXMLRPCServer(SimpleXMLRPCServer.SimpleXMLRPCServer) :
+
+class ThreadedXMLRPCServer(SocketServer.ThreadingTCPServer, SimpleXMLRPCServer.SimpleXMLRPCDispatcher) :
+    """Base class to have a threaded XMLRPC Server."""
+    def __init__(self, addr, requestHandler=SimpleXMLRPCServer.SimpleXMLRPCRequestHandler, logRequests=False) :
+        """Imitate what is in SimpleXMLRPCServer.py but with a threaded TCP server instead."""
+        self.logRequests = logRequests
+        SimpleXMLRPCServer.SimpleXMLRPCDispatcher.__init__(self)
+        SocketServer.ThreadingTCPServer.__init__(self, addr, requestHandler)
+        
+class MyXMLRPCServer(ThreadedXMLRPCServer) :
     """My own server class."""
     allow_reuse_address = True
     def __init__(self, frame, options, arguments) :
-        SimpleXMLRPCServer.SimpleXMLRPCServer.__init__(self, \
-                                                       ('0.0.0.0', options.port), \
-                                                       SimpleXMLRPCServer.SimpleXMLRPCRequestHandler, \
-                                                       options.debug)
+        ThreadedXMLRPCServer.__init__(self, \
+                                      ('0.0.0.0', options.port), \
+                                      SimpleXMLRPCServer.SimpleXMLRPCRequestHandler, \
+                                      options.debug)
         self.frame = frame
         self.debug = options.debug