Enum ResumeState 

pub(super) enum ResumeState {
    NotTracking {
        current_generation: u64,
    },
    AwaitingOutcome {
        generation: u64,
        attempted_sid: String,
        retry: RetryPayload,
        held_error_line: Option<String>,
        stop_requested: bool,
    },
    ConfirmedRetry {
        generation: u64,
        attempted_sid: String,
        retry: RetryPayload,
        held_error_line: Option<String>,
        stop_requested: bool,
    },
}

One spawn attempt’s resume/error-line lifecycle.

Variants

NotTracking

No --resume attempt is in flight for the current generation — either this spawn never attached --resume, or a prior attempt already resolved (session id captured, retry fired, or exited with an unrelated error). current_generation is whichever generation this resolved FROM (or 0 if no spawn has ever happened — see Default below). reagentx P1 (round 5 on PR #2373): without this, NotTracking couldn’t tell a legitimate ProcessExited for the generation that just resolved apart from a STALE one for an already-superseded older generation, letting the older one incorrectly publish terminal status over a newer, actively-running generation. See ProcessExited’s handling below.

Fields

current_generation: u64

AwaitingOutcome

--resume <attempted_sid> was attached at spawn; outcome not yet known. held_error_line is Some once a terminal result/is_error:true stdout line has arrived but its persistence is still undecided. stop_requested records an explicit user Stop that must override a retry even if one gets confirmed later.

Fields

generation: u64

attempted_sid: String

retry: RetryPayload

held_error_line: Option<String>

stop_requested: bool

ConfirmedRetry

The stderr reader confirmed attempted_sid unreachable under the current config dir — the retry WILL fire the moment the process actually exits, unless stop_requested overrides it.

reagentx P1 (round 9 on this PR, also flagged inline by codex): attempted_sid is carried forward from AwaitingOutcome (not dropped at promotion) so SessionCaptured can still tell an ambiguous same-sid echo apart from unambiguous progress even after confirmation — see that arm’s own doc comment for why treating EVERY capture as unambiguous once confirmed was wrong: resume_poisoned (persistent/mod.rs) is a single, non-generation- scoped, permanent field, so a lagging stderr-reader task from an OLDER, already-superseded generation can overwrite it to a different sid while THIS generation is still ConfirmedRetry, silently disabling try_capture_session_id’s poison guard for this generation’s own attempted sid and letting a routine same-sid echo reach this arm.

Fields

generation: u64

attempted_sid: String

retry: RetryPayload

held_error_line: Option<String>

stop_requested: bool

Implementations

impl ResumeState

pub(super) fn is_seeded_message( &self, generation: u64, delivered_seq: u64, ) -> bool

Read-only accessor for the drain: is delivered_seq the exact message spawn_process originally seeded the retry batch with (its first entry), for the given generation? Used to identify the already-recorded seed before appending any LATER message the drain delivers. Matched by queue identity (QueuedRetryEntry::seq), neither by position (see PersistentSubprocessController::drain_queue_after_successful_spawn’s own doc comment for why the front of the queue isn’t necessarily the seed) nor by content (issue #2365 — a later, genuinely different delivery sharing identical text must not be mistaken for the seed).

Trait Implementations

impl Clone for ResumeState

fn clone(&self) -> ResumeState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ResumeState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ResumeState

fn default() -> Self

current_generation: 0 — real generations start at 1 (PersistentInner::spawn_generation is bumped before its first use), so this default can never accidentally match a genuine ProcessExited event.

impl PartialEq for ResumeState

fn eq(&self, other: &ResumeState) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ResumeState