Added worker result feedback.
10 optparse.make_option("-q", "--quiet", action="store_true", dest="quiet",
11 help="quiet mode", default=False)]
13 def spawn(host, port):
14 return Worker(host, port, Handler, ())
16 class Handler(SocketServer.BaseRequestHandler):
20 data = self.request[0].strip()
21 socket = self.request[1]
22 model_size = int(data[:10])
23 model = pickle.loads(data[10:10+model_size])
24 max_iter = int(data[10+model_size:20+model_size])
25 model.update(max_iter)
26 for cell in model.cells.iteritems():
27 socket.sendto(pickle.dumps(cell), self.client_address)
29 class Worker(SocketServer.UDPServer):
30 def __init__(self, host, port, handler, options):
31 SocketServer.UDPServer.__init__(self, (host, port), handler)
34 self.handler = handler
35 self.options = options
37 print "worker running at port %s" % self.port
40 if __name__ == "__main__":
41 parser = optparse.OptionParser(usage="usage: %prog [options] port",
42 option_list=option_list)
43 options, args = parser.parse_args()
47 worker = Worker("localhost", port, Handler, options)