+ jHj'Rt^RIt^RIHtHt^RIHt^RIt^RIt^RI H t H t ]P!] 4t]!RR7!RR44tR tR tR tR tR tRtRtRtRtRtRtRtRtRtRtR#)aIBusy same-sender bursts become one shared-runtime admission. Main merged a busy photo burst into the pending slot and debounced queue-mode text from one sender (``BasePlatformAdapter._queue_text_debounce``) so a thought split over two messages ran as one turn. The authority FIFO admits each input as it arrives, so the burst is held here for main's bounded window first, then committed once through ``dispatch_shared_busy``. Every absorbed caller returns only after that commit, with its acceptance copied from it (committed before ACK), and input that arrives later never commits before the burst. An adapter declaring ``serial_receive_loop`` (Signal, IRC, ...) delivers a chat's next input only after this returns, and returning triggers no acknowledgement, so its caller returns once the input is held, as main returned once merged. Its reader still never runs ahead of what it returned on: a chat holds at most one uncommitted burst (the next one waits for that commit, main's backpressure), and a command first waits until every earlier input of that reader has committed (``burst_gate``). N) dataclassfield)partial) MessageEvent MessageTypeF)eqcFa]tRt^toRtRt]!]R7tV3Rlt Rt Vt R#)_BurstN)default_factoryc<V^8dQh/S[;R&S[P;R&S[;R&S[;R&S[PR,;R&S[PR,;R&S[;R&#) headdonefirst_tslast_tsNtimercommitabsorbed)rasyncioFuturefloatTasklist)format __classdict__s"B/home/ubuntu/.hermes/hermes-agent/gateway/session_ingress_burst.py __annotate___Burst.__annotate__sr  ..O  N  <<$ %  LL4 &0) __name__ __module__ __qualname____firstlineno__rrrrr__annotate_func____static_attributes____classdictcell__)rs@rr r s" "&E"&F40Hrr cVP\P8XdVP'gR#VP V4'dR#R#)phototextN) message_typerPHOTOinternal!_is_queue_text_debounce_candidate)adapterevents&&r_kindr0%s< [...u~~~>>uEE6O4Orc:VPPV/4#N)__dict__ setdefault)r.names&&r_stater6+s    & &tR 00rc\VRR4#)serial_receive_loopF)getattr)r.s&r_serialr:/s 715 99rc~aa\;QJd VV3RlR4F 'gK R# R#!VV3RlR44#)zNA burst is held or committing: later input for the route must queue behind it.c3b<"TF$pSSPPVR49xK& R#5i)Nr)r3get).0r5r. session_keys& r #holds_busy_burst..5s+uIt{g..224<:A)H>#H.$'H> H1 >H> +H>6H47H> H6 &H>1H82H>H:A&H>)H<*H>1H>4H>6H>8H>:H><H>c"\V4'dR#\P!VP4GRjxL VPP VnR#L!5ir2)r:rrdrr _gateway_accepted)r.rSr/s&&&rrcrcjs@w .. $$$#jj::E%s7AA"AcVPPV4VPVPP4V#r2)_background_tasksaddadd_done_callbackdiscard)r.tasks&&r_trackrtqs5 !!$'744<<= KrcaaaaSPeSPP4\R\SPSP ,SP SP,4\P!4, 4oVVVV3Rlp\S\P!V!444SnR#)Ngc<"\P!S4GRjxL \P!\SSS44GRjxL R#L/L5ir2)rsleeprdrN)r.rSdelayr?srfire_arm..fire}s;mmE"""nnVG[%@AAA #As!AA (AAAA) rcancelmaxminr_busy_text_debounce_secondsr_busy_text_hard_cap_secondsr`rartr create_task)r.r?rSryrxsfff @rrbrbws {{  S)L)LL'*M*MMOQUQ_Q_Qab cEBB'"5"5df"=>EKrc 2aaVPf\VR4\VR4upoVPS4VJdVSVP\P !4JdVPP 4\V\P!\VSVSPS4444;VnSS&VPPVV3Rl4VPP\\V44VP#)zJStart committing ``burst`` (once), after any earlier commit for the route.rBrCc\<SPS4VJ;'dSPS4#r2)r=pop)rsr?tailss&r_flush..s+EIIk4Jd4R4m4mW\W`W`alWm4mr) rr6r=rr current_taskr{rtr_commitrqr_settle)r.r?rSrirs&f& @rrNrNs ||w(896'Kb;c  ::k "e +{# ;;g224 4 KK   ,27G? <<rc."^RIHpVe \P!V04GRjxL V!WPVRR7GRjxL R#L$L \ d8\ T4'gh\PRTPT4R#i;i5i)rYNT)durablez%[%s] Busy burst for %s was not queued) r]rZrrPr Exceptionr:logger exceptionr5)r.r?rSrjrZs&&&& rrrs<llH:&&&]#7JJ TRRR ' S ]w @',,P[\ ]sD%BA BAAA BA>BBBBc^VPP4'dR#VP4'dVPP4R#VP4e,VPP VP44R#VPP R4R#)zSEvery absorbed caller sees the merged admission's outcome, refusal or cancellation.N)r cancelledr{r set_exception set_result)rSrss&&rrrsk zz ~~    %   !12 d#rcVPPR/4P4Uu.uFqPNK ppV.VPPR/4P4OVPPRR4O, pVUu.uFq3P4'dKVNK up#uupiuupi)zInputs the reader already returned on that are not committed yet: held bursts, burst commits and busy inputs released before their commit (``session_ingress._hold_until_committed``).rBrCrHr)r3r=rOr)r.rSrTfutures& r _undurablers(/'7'7';';v FF >>\ ?sB;C2Cca"\SRR4e VSnR#\S4'gV!4GRjxL R#VSnV3Rlp\S\P !V!444R#L:5i)arRun ``persist()`` once every input a serial reader returned on is committed: a reader that saves its own receive cursor after the call returns (Buzz) must not advance it past a held burst, or a restart in the hold window loses it. Inline when nothing is pending; otherwise one tracked task per adapter, so the reader reads on (a lost cursor write only replays inputs admission already holds). ``persist`` carries the cursor as of this call; while that task waits, a newer call replaces it, and the task picks the newest in the same step that saw nothing pending, so an input that arrives during the write's I/O is never in it._durable_persistNc<"\S4;p'd!\P!V4GRjxL K3SPP RR4pV!4GRjxL R#L4 SPP RR4pi;iL)5i)Nr)rrrPr3r)rTlatestr.s rlater+when_returned_inputs_durable..latersz D'00'0ll7+++1%%))*rs ( =   8 $ e111P 1:v *2:; ?  ] $?249r