Added worker.
10 optparse.make_option("-q", "--quiet", action="store_true", dest="quiet",
11 help="quiet mode", default=False)]
13 class Handler(SocketServer.BaseRequestHandler):
17 data = self.request[0].strip()
18 socket = self.request[1]
19 print "%s wrote:" % self.client_address[0]
21 for key, value in com.commands.iteritems():
23 args = data.partition(key)[2].split()
25 value[0](socket, self.client_address, self.worker, args)
27 value[0](socket, self.client_address, self.worker)
29 class Server(SocketServer.UDPServer):
30 def __init__(self, host, port, handler, options, worker):
31 SocketServer.UDPServer.__init__(self, (host, port), handler)
34 self.handler = handler
35 self.options = options
36 self.handler.worker = worker
40 def spawnWorker(server, n):
44 #worker.spawn(server[0], port + i)
45 subprocess.Popen(["python worker.py", str(port + i)], shell=True)
46 worker_list.append((server[0], port + i))
49 if __name__ == "__main__":
50 parser = optparse.OptionParser(usage="usage: %prog [options] port worker",
51 option_list=option_list)
52 options, args = parser.parse_args()
57 worker_count = int(args[1])
58 worker = spawnWorker((host, port), worker_count)
59 server = Server(host, port, Handler, options, worker)