1.1 --- a/worker.py Mon Jun 14 23:16:47 2010 +0200
1.2 +++ b/worker.py Tue Jun 15 14:58:05 2010 +0200
1.3 @@ -3,6 +3,7 @@
1.4 import com
1.5 import model
1.6 import optparse
1.7 +import time
1.8 import pickle
1.9 import SocketServer
1.10
1.11 @@ -24,7 +25,9 @@
1.12 max_iter = int(data[10+model_size:20+model_size])
1.13 model.update(max_iter)
1.14 for cell in model.cells.iteritems():
1.15 - socket.sendto(pickle.dumps(cell), self.client_address)
1.16 + time.sleep(0.01)
1.17 + socket.sendto(model.name + " " + pickle.dumps(cell),
1.18 + self.client_address)
1.19
1.20 class Worker(SocketServer.UDPServer):
1.21 def __init__(self, host, port, handler, options):