goodboy
/
tractor
1
0
Fork 2
Code Issues 5 Pull Requests 7 Packages Projects Releases Wiki Activity

Unmask `ClosedResourceError` handling in `._transport` 

Unmask the CRE case block for peer-closed socket errors which already
had a TODO about reproducing the condition. It appears this case can
happen during inter-actor comms teardowns in `piker`, but i haven't been
able to figure out exactly what reproduces it yet..

So activate the block again for that 'socket already closed'-msg case,
and add a TODO questioning how to reproduce it.

(this commit msg was generated in some part by [`claude-code`][claude-code-gh])
[claude-code-gh]: https://github.com/anthropics/claude-code
tpt_tolerance
Gud Boi 2026-02-11 13:49:52 -05:00
parent c3f455a8ec
commit f8e25688c7
1 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
tractor/ipc/_transport.py
View File

@ -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