Struct Progress 

struct Progress {
    base: Instant,
    at: AtomicU64,
    showing: Mutex<Option<SessionSlot>>,
}

The connection’s own clock: one stamp per completed socket write, and the seat it last said it was showing.

A task cannot watch itself. The keepalive answers a peer that went away while the loop still runs; it cannot see the loop itself parked in an await, because a select! branch never fires while another branch is being driven. A loop turn is not progress either: one pass can issue several bounded writes (batch::flush feeds one or two frames, then a snapshot, then an optional home snapshot), so a turn-based stamp would claim progress the connection did not make. The stamp sits where every frame crosses - ClientSocket’s flush - so the watchdog’s bound means “no write completed in the bound”, which is what it claims.

Fields

base: Instant

tokio’s clock rather than the standard one, so a test that pauses time pauses the watchdog with it.

at: AtomicU64

showing: Mutex<Option<SessionSlot>>

The seat this connection last showed, for a wedge’s own record: a connection can watch several seats, and the one on screen is what a person would name.

Implementations

impl Progress

fn new() -> Self

fn stamp(&self)

One write completed and its bytes were flushed.

fn silent_for(&self, now: Instant) -> Duration

How long the connection has been parked since its last write.

fn note_showing(&self, seat: Option<&SessionSlot>)

Record the seat this connection says it is showing.

fn showing_seat(&self) -> Option<SessionSlot>

The seat this connection was showing when it stopped.

Trait Implementations

impl Debug for Progress

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

Formats the value using the given formatter.