Struct LocalTransport 

pub struct LocalTransport { /* private fields */ }

Single-machine in-process transport. All num_ranks “ranks” share one SymmetricHeap instance, so put / get are just locks + memcpy. Useful for unit tests and for algorithm-correctness checking of collective ops without a real cluster.

Implementations

impl LocalTransport

pub fn new(num_ranks: u32, heap_size: usize, this_rank: Rank) -> LocalTransport

pub fn fan_out(num_ranks: u32, heap_size: usize) -> Vec<LocalTransport>

Construct multiple LocalTransports sharing one heap — Vec of length num_ranks, each with its own me. Tests typically iterate this list to drive each rank.

Trait Implementations

impl Clone for LocalTransport

fn clone(&self) -> LocalTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LocalTransport

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

Formats the value using the given formatter.

impl SymmetricTransport for LocalTransport

fn num_ranks(&self) -> u32

How many ranks participate.

fn this_rank(&self) -> Rank

This process’s rank.

fn put(&self, buf: SymmetricBuffer, src: &[u8]) -> Result<(), CollectiveError>

Write src into buf. Errors on length mismatch.

fn get( &self, buf: SymmetricBuffer, dst: &mut [u8], ) -> Result<(), CollectiveError>

Read from buf into dst. Errors on length mismatch.

fn barrier(&self) -> Result<(), CollectiveError>

Block until every rank has reached this barrier. Local emulation is a memory fence + a counter; real transports implement their own.