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. 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):

View File

@ -459,23 +459,21 @@ class MsgpackTransport(MsgTransport):
) )
raise tpt_closed from trans_err raise tpt_closed from trans_err
# ??TODO??, what case in piker does this and HOW # case trio.ClosedResourceError() if (
# CAN WE RE-PRODUCE IT?!?!? # 'this socket was already closed'
case trio.ClosedResourceError() if ( # in
'this socket was already closed' # trans_err.args[0]
in # ):
trans_err.args[0] # tpt_closed = TransportClosed.from_src_exc(
): # message=(
tpt_closed = TransportClosed.from_src_exc( # f'{tpt_name} already closed by peer\n'
message=( # ),
f'{tpt_name} already closed by peer\n' # body=f'{self}\n',
), # src_exc=trans_err,
body=f'{self}\n', # raise_on_report=True,
src_exc=trans_err, # loglevel='transport',
raise_on_report=True, # )
loglevel='transport', # raise tpt_closed from trans_err
)
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