Hi,
I'm trying to use remote managers in the multiprocessing module to listen
for some events synchronously while my program goes off and does other
things. I use the .start() method which forks a new process to handle
communication. When I catch the sigint and call sys.exit() though, the
network port is still bound even after the python interpretor finishes.
Here is my short code and the output:
from multiprocessing.managers import BaseManager
import threading
import sys
import signal
import time
class WorkManager(BaseManager):
def __init__(self):
BaseManager.__init__(self,address=('', 51114), authkey='chris')
self.register('get_string', callable=self.getString)
def getString(self):
return "hi"
manager = WorkManager()
manager.start()
def quit( arg1, arg2 ):
sys.exit()
signal.signal(signal.SIGINT, quit)
#busy wait
while 1:
time.sleep(1)
cab...@ubuntu:~$ python2.6 server.py
^ccab...@ubuntu:~$ python2.6 server.py
Process WorkManager-1:
Traceback (most recent call last):
File "/usr/local/lib/python2.6/multiprocessing/process.py", line 231, in
_bootstrap
self.run()
File "/usr/local/lib/python2.6/multiprocessing/process.py", line 88, in
run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python2.6/multiprocessing/managers.py", line 517, in
_run_server
server = cls._Server(registry, address, authkey, serializer)
File "/usr/local/lib/python2.6/multiprocessing/managers.py", line 136, in
__init__
self.listener = Listener(address=address, backlog=5)
File "/usr/local/lib/python2.6/multiprocessing/connection.py", line 97, in
__init__
self._listener = SocketListener(address, family, backlog)
File "/usr/local/lib/python2.6/multiprocessing/connection.py", line 217,
in __init__
self._socket.bind(address)
File "<string>", line 1, in bind
error: [Errno 98] Address already in use
Traceback (most recent call last):
File "server.py", line 16, in <module>
manager.start()
File "/usr/local/lib/python2.6/multiprocessing/managers.py", line 499, in
start
self._address = reader.recv()
EOFError
cab...@ubuntu:~$
Comments? Is this a bug, or is there a better way to clean up the manager
myself before shutting down?
Chris
--
View this message in context:
http://www.nabble.com/multiprocessing-BaseManager-doesn%27t-clean-up-net-connections--tp21238615p21238615.html
Sent from the Python - python-list mailing list archive at Nabble.com.
--
http://mail.python.org/mailman/listinfo/python-list
