jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Handle mp accept_addr

dereg_on_channel_aclose
Tyler Goodlet 2020-08-08 20:27:43 -04:00
parent acd5b80f4c
commit 42be410076
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tractor/_actor.py
View File

@ -578,6 +578,9 @@ class Actor:
for attr, value in parent_data.items(): for attr, value in parent_data.items():
setattr(self, attr, value) setattr(self, attr, value)
else: # mp
accept_addr = None
return chan, accept_addr return chan, accept_addr
except OSError: # failed to connect except OSError: # failed to connect
@ -613,9 +616,14 @@ class Actor:
# establish primary connection with immediate parent # establish primary connection with immediate parent
self._parent_chan = None self._parent_chan = None
if parent_addr is not None: if parent_addr is not None:
self._parent_chan, accept_addr = await self._chan_to_parent( self._parent_chan, accept_addr_from_rent = await self._chan_to_parent(
parent_addr) parent_addr)
# either it's passed in because we're not a child
# or because we're running in mp mode
if accept_addr_from_rent is not None:
accept_addr = accept_addr_from_rent
# load exposed/allowed RPC modules # load exposed/allowed RPC modules
# XXX: do this **after** establishing a channel to the parent # XXX: do this **after** establishing a channel to the parent
# but **before** starting the message loop for that channel # but **before** starting the message loop for that channel