From ac7923e01f9963538b8ad068d20522eb50247c20 Mon Sep 17 00:00:00 2001 From: damocles Date: Tue, 9 Jun 2026 00:25:49 +0200 Subject: [PATCH] address review: drop issue refs from continue-mechanism comments --- hive-ag3nt/src/bin/hive.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/hive-ag3nt/src/bin/hive.rs b/hive-ag3nt/src/bin/hive.rs index ca58567e..04b4c39a 100644 --- a/hive-ag3nt/src/bin/hive.rs +++ b/hive-ag3nt/src/bin/hive.rs @@ -133,7 +133,7 @@ fn consume_continue_sentinel() -> bool { /// What a finished turn tells the serve loop to do next. Replaces the /// bare `auth_failed` bool so the loop can also act on a pending /// `request_next_turn` without round-tripping a synthetic message -/// through the broker (#1543). +/// through the broker. struct TurnControl { /// The turn ended in `AuthFailed` — caller parks on login. auth_failed: bool, @@ -159,8 +159,8 @@ fn should_self_continue(ctrl: &TurnControl) -> bool { /// Synthesize the `from: "self"` / `body: "continue"` message that a /// `request_next_turn` self-continue drives. Built in-process rather /// than fetched from the broker — it never touches the send/recv -/// path, so it doesn't persist to sqlite or pollute the inbox -/// (#1543). `id = 0` is a non-broker sentinel: the synthetic message +/// path, so it doesn't persist to sqlite or pollute the inbox. +/// `id = 0` is a non-broker sentinel: the synthetic message /// has no DB row, and `AckTurn` keys off the recipient's in-flight /// list (which is empty here) rather than this id. fn synthetic_continue() -> hive_sh4re::DeliveredMessage { @@ -456,7 +456,7 @@ async fn serve_loop( S::requeue_inflight(socket).await; // Set when a turn calls `request_next_turn` and no real work is // pending — the next iteration drives this synthetic message - // in-process instead of long-polling the broker (#1543). Never + // in-process instead of long-polling the broker. Never // persisted: it lives entirely in this loop's stack. let mut self_continue: Option = None; loop { @@ -623,7 +623,7 @@ mod continue_tests { #[test] fn no_self_continue_when_real_messages_pending() { // A real message will drive the next turn via recv — the - // continue is superseded, not needed (#1543 contract). + // continue is superseded, not needed (request_next_turn contract). assert!(!should_self_continue(&ctrl(false, true, 3))); }