Struct SharedCompletedNodes

pub struct SharedCompletedNodes { /* private fields */ }

A concurrency‐safe set of completed node indices, using tokio::sync::AsyncMutex<HashSet<usize>>.

Implementations

impl SharedCompletedNodes

pub fn new() -> Self

Constructs an empty SharedCompletedNodes.

pub fn from_slice(nodes: &[usize]) -> Self

Constructs a SharedCompletedNodes by inserting all elements from the given slice. Duplicates in the slice are ignored (only one copy of each index is stored).

pub async fn insert( &self, node_idx: usize, ) -> Result<InsertOutcome, NetworkError>

Inserts node_idx into the set. Returns InsertOutcome or a potential NetworkError.

pub async fn len(&self) -> usize

Returns the current number of unique completed nodes.

pub async fn contains(&self, node_idx: usize) -> bool

Checks if node_idx is in the set.

pub async fn clear(&self) -> usize

Clears all entries. Returns the number of entries that were cleared.

pub async fn is_all_done(&self, total_count: usize) -> bool

Returns true if we have exactly total_count unique nodes in the set.

pub async fn as_slice(&self) -> Vec<usize>

Returns a sorted snapshot (as a Vec<usize>) of the current contents.

pub async fn mark_node_completed( &self, node_idx: usize, worker_id: usize, checkpoint_cb: Option<Arc<dyn CheckpointCallback>>, )

Marks node_idx as completed, logs the outcome, and optionally calls a checkpoint callback.

Arguments

• node_idx: The index to record.
• worker_id: For logging; e.g. which worker thread is marking completion.
• checkpoint_cb: Optionally, a callback to be invoked with a sorted snapshot of the set.

Trait Implementations

impl Clone for SharedCompletedNodes

fn clone(&self) -> SharedCompletedNodes

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SharedCompletedNodes

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

Formats the value using the given formatter.

impl From<&[usize]> for SharedCompletedNodes

Convenience From<&[usize]> so you can do: SharedCompletedNodes::from(&[0,1,2]) directly.

fn from(slice: &[usize]) -> Self

Converts to this type from the input type.

impl<const N: usize> From<&[usize; N]> for SharedCompletedNodes

fn from(array: &[usize; N]) -> Self

Converts to this type from the input type.