Struct HeldSeats 

pub(crate) struct HeldSeats {
    held: Mutex<HashMap<SessionSlot, Held>>,
    gates: Mutex<HashMap<SessionSlot, Weak<Mutex<()>>>>,
}

The seats a view is showing, and the loop each one runs.

Fields

held: Mutex<HashMap<SessionSlot, Held>>

gates: Mutex<HashMap<SessionSlot, Weak<Mutex<()>>>>

The gate a seat’s reads share, by weak reference, so it outlives the hold exactly as long as a read still holds it. A re-hold during such a read upgrades this and shares the gate; once the read lets go the weak dies and the next hold starts a fresh one. Dead entries are pruned on the next look.

Implementations

impl HeldSeats

fn lock(&self) -> MutexGuard<'_, HashMap<SessionSlot, Held>>

fn gate_arc(&self, slot: &SessionSlot) -> Arc<Mutex<()>>

The gate for a seat’s first hold: the one a read still holds, or a new one, remembered weakly for the next re-hold.

fn acquire(&self, slot: &SessionSlot) -> Taken

Take a hold on slot, answering the mark the record’s read fires and the sender that stops the seat’s loop when this is the first hold.

fn gate(&self, slot: &SessionSlot) -> Option<Arc<Mutex<()>>>

The seat’s read gate, when one is there: a held seat’s, or one a read still holds after its hold went. A seat neither held nor read has no loop to race, so the caller reads unguarded rather than waiting.

fn note_record_read(&self, slot: &SessionSlot)

Say the record’s first read is done, which is the mark the watch’s first pass waits on. notify_one holds the permit for a watch that has not reached its wait yet, so the mark cannot be missed.

fn nudge(&self, slot: &SessionSlot, pr_stale: bool)

Wake the seat’s loop because the session reported a repository mutation, marking the PR block stale too when the report was a published change. A seat nobody holds has no loop to wake.

fn take_pr_stale(&self, slot: &SessionSlot) -> bool

Whether a nudge asked for a PR lookup, clearing the mark.

pub(crate) fn mark_tree_moved(&self, slot: &SessionSlot)

Report the tree moved, as the file watch does, for a test that drives a pass rather than racing the OS daemon’s delivery.

fn take_tree_moved(&self, slot: &SessionSlot) -> bool

Whether a test reported the tree moved, clearing the mark.

pub(crate) fn pass_done(&self, slot: &SessionSlot) -> Option<Arc<Notify>>

The mark a held seat’s loop raises at the end of every pass.

fn release(&self, slot: &SessionSlot)

Give a hold back. The last hold stops the loop and drops the entry; a read still in flight keeps its gate alive through Self::gates, so a re-hold before it finishes shares it rather than racing a second.

Trait Implementations

impl Default for HeldSeats

fn default() -> Self

Returns the “default value” for a type.