Struct DummyCommunicationBackend 

pub struct DummyCommunicationBackend { /* private fields */ }

Dummy communication backend for testing.

Implementations

impl DummyCommunicationBackend

pub fn new() -> Self

Create a new dummy backend.

Trait Implementations

impl CommunicationBackend for DummyCommunicationBackend

fn initialize( &mut self, config: &DistributedConfig, ) -> Result<(), ExecutorError>

Initialize the communication backend.

fn finalize(&mut self) -> Result<(), ExecutorError>

Finalize and clean up the backend.

fn rank(&self) -> usize

Get the rank of this process.

fn world_size(&self) -> usize

Get the world size (total number of processes).

fn all_reduce( &self, _tensor_id: &str, _reduction: ReductionOp, ) -> Result<(), ExecutorError>

Perform an all-reduce operation.

fn broadcast( &self, _tensor_id: &str, _src_rank: usize, ) -> Result<(), ExecutorError>

Broadcast from source rank to all ranks.

fn scatter( &self, _tensor_id: &str, _src_rank: usize, ) -> Result<(), ExecutorError>

Scatter data from source rank to all ranks.

fn gather( &self, _tensor_id: &str, _dst_rank: usize, ) -> Result<(), ExecutorError>

Gather data from all ranks to destination rank.

fn all_gather(&self, _tensor_id: &str) -> Result<(), ExecutorError>

All-gather operation.

fn reduce_scatter( &self, _tensor_id: &str, _reduction: ReductionOp, ) -> Result<(), ExecutorError>

Reduce-scatter operation.

fn send(&self, _tensor_id: &str, _dst_rank: usize) -> Result<(), ExecutorError>

Point-to-point send.

fn recv(&self, _tensor_id: &str, _src_rank: usize) -> Result<(), ExecutorError>

Point-to-point receive.

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

Synchronize all processes.

impl Default for DummyCommunicationBackend

fn default() -> Self

Returns the “default value” for a type.