Compare commits
2 Commits
8abe8b283c
...
7d594a44b5
| Author | SHA1 | Date |
|---|---|---|
|
|
7d594a44b5 | |
|
|
a2014907bb |
|
|
@ -497,6 +497,9 @@ async def _connect_chan(
|
||||||
teardown.
|
teardown.
|
||||||
|
|
||||||
'''
|
'''
|
||||||
|
# XXX, ONLY uncomment for tracing lowlevel connection issues.
|
||||||
|
# from tractor.devx import open_crash_handler
|
||||||
|
# with open_crash_handler():
|
||||||
chan = await Channel.from_addr(addr)
|
chan = await Channel.from_addr(addr)
|
||||||
yield chan
|
yield chan
|
||||||
with trio.CancelScope(shield=True):
|
with trio.CancelScope(shield=True):
|
||||||
|
|
|
||||||
|
|
@ -459,21 +459,23 @@ class MsgpackTransport(MsgTransport):
|
||||||
)
|
)
|
||||||
raise tpt_closed from trans_err
|
raise tpt_closed from trans_err
|
||||||
|
|
||||||
# case trio.ClosedResourceError() if (
|
# ??TODO??, what case in piker does this and HOW
|
||||||
# 'this socket was already closed'
|
# CAN WE RE-PRODUCE IT?!?!?
|
||||||
# in
|
case trio.ClosedResourceError() if (
|
||||||
# trans_err.args[0]
|
'this socket was already closed'
|
||||||
# ):
|
in
|
||||||
# tpt_closed = TransportClosed.from_src_exc(
|
trans_err.args[0]
|
||||||
# message=(
|
):
|
||||||
# f'{tpt_name} already closed by peer\n'
|
tpt_closed = TransportClosed.from_src_exc(
|
||||||
# ),
|
message=(
|
||||||
# body=f'{self}\n',
|
f'{tpt_name} already closed by peer\n'
|
||||||
# src_exc=trans_err,
|
),
|
||||||
# raise_on_report=True,
|
body=f'{self}\n',
|
||||||
# loglevel='transport',
|
src_exc=trans_err,
|
||||||
# )
|
raise_on_report=True,
|
||||||
# raise tpt_closed from trans_err
|
loglevel='transport',
|
||||||
|
)
|
||||||
|
raise tpt_closed from trans_err
|
||||||
|
|
||||||
# unless the disconnect condition falls under "a
|
# unless the disconnect condition falls under "a
|
||||||
# normal operation breakage" we usualy console warn
|
# normal operation breakage" we usualy console warn
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue