at this point, the subject line should be something like
"0MQ reconnect problem"
>> Then server and workers can't talk to each other anymore. Workers
>> spawned after the server's restart can communicate with the server...
>
> Does the same happen when you use TCP?
With TCP:
1. if the server starts the worker before setting up 0MQ, no problem. I
can kill and restart the server, and 0MQ reconnects every time.
2. if the server starts the worker *after* setting up 0MQ, then I get
the error message: "Address already in use" when I kill and try to
restart the server.
> You could be hitting a file permissions issue, if you're running the
> server and workers under different user ids.
From the command-line, same user with the code below.
#------------------------------------------------------------------
Usage:
./server5.py -before # starts worker before 0MQ
./server5.py -after # starts worker after 0MQ
Then kill the server, and restart it alone with:
./server5.py # starts server alone
and see when 0MQ reconnects, and when not.
#------------------------------------------------------------------
#!/usr/bin/python
# server5.py
import time
import os
import sys
import subprocess
import zmq
if '-before' in sys.argv:
args =('python','./worker5.py')
p = subprocess.Popen(args)
pid = "server " + str(os.getpid())
context = zmq.Context()
WorkersToServer = context.socket(zmq.PULL)
WorkersToServer.bind("tcp://*:12345")
poller = zmq.Poller()
poller.register(WorkersToServer, zmq.POLLIN)
if '-after' in sys.argv:
args =('python','./worker5.py')
p = subprocess.Popen(args)
while True:
socks = dict(poller.poll(5000))
if WorkersToServer in socks and socks[WorkersToServer] == zmq.POLLIN:
message = WorkersToServer.recv()
print pid, "=", message
else:
print pid, "timeout"
#------------------------------------------------------------------
#!/usr/bin/python
# worker5.py
import time
import os
import zmq
pid = "worker " + str(os.getpid())
context = zmq.Context()
WorkersToServer = context.socket(zmq.PUSH)
WorkersToServer.connect("tcp://localhost:12345")
while True:
WorkersToServer.send(time.ctime() + " from " + pid)
print "\t", pid
time.sleep(1)
_______________________________________________
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev
