worker.py
changeset 5 5ab3cc2e7851
parent 4 4cee17e91d29
child 6 9147c845cecb
     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):