Home | Trees | Indices | Help |
---|
|
1 import SocketServer 2 from operationscore.Input import * 3 4 """ 5 A rough sketch about how a TCP socket server receives data from the phone (or other stuff). 6 Some corrections are probably needed from Russell. 7 Looks good to me -- not really the way I envisioned it, but since the server 8 we're using has a built in loop. When we call the reponse method to pass the 9 data up the pipe, we should use the sensingLoop so that everything stays 10 thread-safe. 11 """502615 # get data from the TCP socket connected to the client 16 self.data = self.request.recv(1024).strip() 17 18 pydict = json.loads(self.data) # decode and add to queue 19 self.responseQueue.append(pydict) 20 21 """ 22 do something to the dict 23 """ 24 25 self.request.send("yes") # send back confirmation.28 # initialize 29 self.host = "localhost" 30 self.port = 9999 31 self.responseQueue = [] 32 # start server 33 self.server = SocketServer.TCPServer((self.host, self.port), InputTCPHandler) 34 self.server.responseQueue = self.responseQueue 35 self.server.serve_forever() # server keeps running till Ctrl+C or self.server.shutdown() is called.3638 # loop action handled through TCPHandler? 39 # if check says to shut down the server, shut it. 40 if self.doShutDown(): 41 self.server.shutdown() 42 else: 43 for event in self.responseQueue: 44 self.respond(event) 45 self.responseQueue = []46
Home | Trees | Indices | Help |
---|
Generated by Epydoc 3.0.1 on Fri Feb 18 16:55:27 2011 | http://epydoc.sourceforge.net |