+ iHjrRt^RIHt^RIt^RIHt]P !]4tRRlt RRlt RR lt R#) aBest-effort accessors for the single-writer stream fence. The fence lives on ``AIAgent`` (``_claim_stream_writer`` / ``_stream_writer_is_current``) but is used from other streaming modules. Calling it directly would turn an *additive* safety net into a fatal AttributeError on a partially-updated checkout, hot-reloaded gateway, duck-typed agent, or test double (a cron job died this way). The fence may only drop a *provably* superseded stream, never the sole writer, so when it is unavailable or raises the degradation is "no fence". ) annotationsN)Anyc V^8dQhRRRR/#)agentrreturnint)formats"?/home/ubuntu/.hermes/hermes-agent/agent/stream_single_writer.py __annotate__r sccscscc(\VR\^R4#)zvClaim the delta sink for this stream attempt; ``0`` (never fenced) when the agent lacks the fence or the claim raised._claim_stream_writerz!claim failed; proceeding unfenced) _fence_callr)rs&r claim_stream_writerrs u4c1>a bbr c$V^8dQhRRRRRR/#)rrrtokenrrboolr )r s"r r r s&~~C~~~r c>V'gR#\VR\RRV4#)zwTrue when ``token`` is still the active writer; a falsy token or a fence-less agent cannot prove supersession, so True.T_stream_writer_is_currentz,is_current check failed; treating as current)rr)rrs&&r stream_writer_is_currentrs  u94Guw| }}r c$V^8dQhRRRRRR/#)rrrnamestr failure_noter )r s"r r r s!s#Sr c\WR4p\V4'dV!V!V!4#V# \d\P RTRR7T#i;i)zdCall ``agent.(*args)`` when it exists; ``fallback`` when missing or raising (logged at debug).Nzstream single-writer: %sT)exc_info)getattrcallable Exceptionloggerdebug)rrcastfallbackrargsfns&&&&&* r rrs] d #B|| RD ? " O R LL3\DL Q O Rs -#AA) __doc__ __future__rloggingtypingr getLogger__name__r!rrrr r r r-s6#   8 $c ~r