Struct CommunicationStats 

pub struct CommunicationStats {
    pub allreduce_operations: u64,
    pub allreduce_time: Duration,
    pub allreduce_bytes: usize,
    pub broadcast_operations: u64,
    pub broadcast_time: Duration,
    pub broadcast_bytes: usize,
    pub p2p_operations: u64,
    pub p2p_time: Duration,
    pub p2p_bytes: usize,
    pub communication_efficiency: f64,
}

Distributed communication statistics

Fields

allreduce_operations: u64

Number of all-reduce operations

allreduce_time: Duration

Total time spent in all-reduce

allreduce_bytes: usize

Total bytes all-reduced

broadcast_operations: u64

Number of broadcast operations

broadcast_time: Duration

Total time spent in broadcast

broadcast_bytes: usize

Total bytes broadcast

p2p_operations: u64

Number of point-to-point communications

p2p_time: Duration

Total time spent in point-to-point communication

p2p_bytes: usize

Total bytes in point-to-point communication

communication_efficiency: f64

Communication efficiency (achieved vs theoretical)

Implementations

impl CommunicationStats

pub fn new() -> Self

pub fn record_gradient_sync( &mut self, duration: Duration, num_gradients: usize, world_size: usize, )

pub fn record_operation( &mut self, operation: CommunicationOperation, duration: Duration, bytes: usize, )

pub fn get_efficiency(&self) -> f64

pub fn get_allreduce_bandwidth(&self) -> f64

pub fn get_broadcast_bandwidth(&self) -> f64

pub fn merge(&mut self, other: &CommunicationStats)

Trait Implementations

impl Clone for CommunicationStats

fn clone(&self) -> CommunicationStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommunicationStats

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

Formats the value using the given formatter.

impl Default for CommunicationStats

fn default() -> Self

Returns the “default value” for a type.