Client skeleton added.
11 optparse.make_option("-q", "--quiet", action="store_true", dest="quiet",
12 help="quiet mode", default=False)]
14 def spawn(host, port):
15 return Worker(host, port, Handler, ())
17 class Handler(SocketServer.BaseRequestHandler):
21 data = self.request[0].strip()
22 socket = self.request[1]
23 model_size = int(data[:10])
24 model = pickle.loads(data[10:10+model_size])
25 max_iter = int(data[10+model_size:20+model_size])
26 model.update(max_iter)
27 for cell in model.cells.iteritems():
28 socket.sendto(" ".join(("data", model.name, str(cell[0].real),
29 str(cell[0].imag), str(cell[1].real), str(cell[1].imag))),
32 class Worker(SocketServer.UDPServer):
33 def __init__(self, host, port, handler, options):
34 SocketServer.UDPServer.__init__(self, (host, port), handler)
37 self.handler = handler
38 self.options = options
40 print "worker running at port %s" % self.port
43 if __name__ == "__main__":
44 parser = optparse.OptionParser(usage="usage: %prog [options] port",
45 option_list=option_list)
46 options, args = parser.parse_args()
50 worker = Worker("localhost", port, Handler, options)