diff --git a/tractor/ipc/_transport.py b/tractor/ipc/_transport.py index 704c13a6..93652a87 100644 --- a/tractor/ipc/_transport.py +++ b/tractor/ipc/_transport.py @@ -459,21 +459,23 @@ class MsgpackTransport(MsgTransport): ) 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 + # ??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 # unless the disconnect condition falls under "a # normal operation breakage" we usualy console warn