SmootLight.inputs.TCPInput

Source Code for Module SmootLight.inputs.TCPInput_backup

+ 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 """ +

12 -class TCPInput(Input.Input): +

13 - class InputTCPHandler(SocketServer.BaseRequestHandler): +

14 - def handle(self): +

15 # 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. +

26 +

27 - def inputInit(self): +

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. +

36 +

37 - def sensingLoop(self): +

38 # 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 +

47 - def doShutDown(self): +

48 # do some checks to see if server should be shut down +49 return False; +

50 +