Add runtime level msg around channel draining
parent
f07e9dbb2f
commit
b29def8b5d
|
@ -611,7 +611,8 @@ class Actor:
|
||||||
entry = local_nursery._children.get(uid)
|
entry = local_nursery._children.get(uid)
|
||||||
if entry:
|
if entry:
|
||||||
_, proc, _ = entry
|
_, proc, _ = entry
|
||||||
log.warning(f'Actor {uid}@{proc} IPC connection broke!?')
|
log.warning(
|
||||||
|
f'Actor {uid}@{proc} IPC connection broke!?')
|
||||||
# if proc.poll() is not None:
|
# if proc.poll() is not None:
|
||||||
# log.error('Actor {uid} proc died and IPC broke?')
|
# log.error('Actor {uid} proc died and IPC broke?')
|
||||||
|
|
||||||
|
@ -630,6 +631,11 @@ class Actor:
|
||||||
# Attempt to wait for the far end to close the channel
|
# Attempt to wait for the far end to close the channel
|
||||||
# and bail after timeout (2-generals on closure).
|
# and bail after timeout (2-generals on closure).
|
||||||
assert chan.msgstream
|
assert chan.msgstream
|
||||||
|
|
||||||
|
log.runtime(
|
||||||
|
f'Draining lingering msgs from stream {chan.msgstream}'
|
||||||
|
)
|
||||||
|
|
||||||
async for msg in chan.msgstream.drain():
|
async for msg in chan.msgstream.drain():
|
||||||
# try to deliver any lingering msgs
|
# try to deliver any lingering msgs
|
||||||
# before we destroy the channel.
|
# before we destroy the channel.
|
||||||
|
|
Loading…
Reference in New Issue