`gjddZddlmZddlZddlZ ddlZdZ ddl Z dZ ddl Z dZ d dZ d dZy#e$rdZdZY'wxYw#e$rdZ dZ Y/wxYw) uGShared spurious stdin-EOF recovery for the TUI gateway entry point and slash worker. When a child process inherits fd 0 (stdin) and sets ``O_NONBLOCK``, the flag lands on the **shared open file description** — not just the child's descriptor. The gateway's next ``read()`` returns ``EAGAIN``, which CPython's buffered ``TextIOWrapper`` converts to ``b''`` (apparent EOF), killing the gateway. This module provides: - :func:`diagnose_stdin_state` — forensic diagnostic (``O_NONBLOCK`` / ``SO_RCVTIMEO``) - :func:`handle_spurious_eof` — check whether an empty ``readline()`` is a genuine peer-close or a spurious EOF, and recover if spurious. The recovery is **POSIX-only** (``fcntl``). On Windows, ``O_NONBLOCK`` on a shared file description is not a concern, so the guard simply reports a genuine EOF and lets the caller exit. ) annotationsNTF cg}trUtO tjdtj}|j d|t j zrdndn|j dtrt tjdtjtj} |jtjtj}|j d||j! |rd j#|Sd S#t$r}|j d|Yd}~d}~wwxYw#|j!wxYw#t$rY_wxYw) aReturn a diagnostic string about stdin's current state. Used for crash-log forensics when stdin iteration falls through. Distinguishes genuine peer-close (flag clear) from spurious EOF caused by a child setting ``O_NONBLOCK`` on the shared file description. Nrz O_NONBLOCK=10zF_GETFL error: zO_NONBLOCK=n/a (no fcntl)z SO_RCVTIMEO=z, unknown) _HAS_FCNTL_fcntlfcntlF_GETFLappendos O_NONBLOCK Exception _HAS_SOCKET_socketfromfdAF_UNIX SOCK_STREAM getsockopt SOL_SOCKET SO_RCVTIMEOclosejoin)partsflagsestvs N/root/.hermes/venv/lib/python3.12/site-packages/tui_gateway/_stdin_recovery.pydiagnose_stdin_stater!0s!Ef( 0LLFNN3E LL;ebmm.Cs&MN O  01 w* q'//73F3FGA \\'"4"4g6I6IJ |B623  %499U 3)3) 0 LL?1#. / / 0"    sCA D<3E0AE2E D?!D::D?EE E#"E#c trt |dy tjdtj}t |t j z}|s |dytj}|j||Dcgc] }||dz kDs |c}|ddt|tkDr|dt|dtdyt}|d |t jdd trt tj dtj"tj$} |j'tj(tj*t-j.d dd|j1y y #t$rd}YKwxYwcc}w#|j1wxYw#t$rYy wxYw) uCheck whether an empty ``readline()`` is spurious; recover if so. Returns ``True`` if the caller should ``continue`` the read loop (spurious EOF was recovered), ``False`` if it should ``break`` (genuine peer-close or rate limit exceeded). ``log_fn`` is called with a diagnostic string — ``_log_exit`` in ``entry.py``, ``print(file=sys.stderr)`` in ``slash_worker.py``. Nzstdin EOF (peer closed)Fr<z+stdin spurious-EOF recovery rate exceeded (z /min, cap )z=stdin spurious EOF (subprocess O_NONBLOCK flip), recovering: Tll)r r r r boolrrrtimer lenMAX_RECOVERIES_PER_MINUTEr! set_blockingrrrrr setsockoptrrstructpackr)recovery_timeslog_fnr is_nonblocknowtdiagrs r handle_spurious_eofr4Ss 6-() Q/52==01  () ))+C#$2Cqa#(lCN1 >66N#$J/H.I L   !D J4& QROOAt w* q'//73F3FGA  W//1D1DfkkRVXY[\F]^  [  D2      sIAF F&F& 3G>AF+G F#"F#+F==G G  G )returnstr)r.z list[float]r/objectr5r&)__doc__ __future__rrr'r r r ImportErrorsocketrrr,r)r!r4r r>s"# J K  4FDD D Ds FJGKs4A AA AA