Struct PendingTracker 

pub struct PendingTracker { /* private fields */ }

Tracks sequence hashes that are currently pending transfer.

This is shared between the pipeline and the presence policy via Arc. Thread-safe for concurrent access from multiple pipeline stages.

Implementations

impl PendingTracker

pub fn new() -> Self

Create a new empty pending tracker.

pub fn is_pending(&self, hash: &SequenceHash) -> bool

Check if a sequence hash is currently pending transfer.

Used by PresenceFilter to skip blocks that are already in-flight.

pub fn len(&self) -> usize

Get the number of pending transfers.

Useful for metrics and debugging.

pub fn is_empty(&self) -> bool

Check if there are no pending transfers.

pub fn guard(self: &Arc<Self>, hash: SequenceHash) -> PendingGuard

Create a guard that marks a sequence hash as pending until dropped.

The guard uses RAII to ensure the hash is removed when:

• Transfer completes successfully
• Transfer is cancelled
• Block is evicted from pipeline
• Any error causes the block to be dropped

Trait Implementations

impl Debug for PendingTracker

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

Formats the value using the given formatter.

impl Default for PendingTracker

fn default() -> PendingTracker

Returns the “default value” for a type.