Commit 2a80212e authored by Shane Hathaway's avatar Shane Hathaway

Added a forgotten argument to the __init__() call in finishConnect(). This

should seal the concurrency bug: the map was being set to None, resulting
in potentially two threads servicing the same queue and making it impossible
to reliably create a ClientStorage once the main loop is running.
parent b2867a86
......@@ -85,7 +85,7 @@
"""Simple rpc mechanisms
"""
__version__ = "$Revision: 1.11 $"[11:-2]
__version__ = "$Revision: 1.12 $"[11:-2]
from ZODB.cPickle import loads
from ZODB import cPickle
......@@ -152,7 +152,7 @@ class asyncRPC(SizedMessageAsyncConnection):
return 1
def finishConnect(self, s):
SizedMessageAsyncConnection.__init__(self, s, {})
SizedMessageAsyncConnection.__init__(self, s, s.getpeername(), {})
# we are our own socket map!
def keys(self): return (self._fileno,)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment