Compare commits

..

No commits in common. "7d594a44b50f2baad6e36bec1bb762a0cdee046d" and "8abe8b283cd9bf53fab856e8d6b3636fd2be23f5" have entirely different histories.

2 changed files with 15 additions and 20 deletions

View File

@ -497,9 +497,6 @@ async def _connect_chan(
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)
yield chan
with trio.CancelScope(shield=True):

View File

@ -459,23 +459,21 @@ class MsgpackTransport(MsgTransport):
)
raise tpt_closed from trans_err
# ??TODO??, what case in piker does this and HOW
# CAN WE RE-PRODUCE IT?!?!?
case trio.ClosedResourceError() if (
'this socket was already closed'
in
trans_err.args[0]
):
tpt_closed = TransportClosed.from_src_exc(
message=(
f'{tpt_name} already closed by peer\n'
),
body=f'{self}\n',
src_exc=trans_err,
raise_on_report=True,
loglevel='transport',
)
raise tpt_closed from trans_err
# case trio.ClosedResourceError() if (
# 'this socket was already closed'
# in
# trans_err.args[0]
# ):
# tpt_closed = TransportClosed.from_src_exc(
# message=(
# f'{tpt_name} already closed by peer\n'
# ),
# body=f'{self}\n',
# src_exc=trans_err,
# raise_on_report=True,
# loglevel='transport',
# )
# raise tpt_closed from trans_err
# unless the disconnect condition falls under "a
# normal operation breakage" we usualy console warn