Struct CommunicationProfiler 

pub struct CommunicationProfiler { /* private fields */ }

Thread-safe communication profiler

Implementations

impl CommunicationProfiler

pub fn new() -> Self

Create a new profiler with default configuration

pub fn with_config(config: ProfilingConfig) -> Self

Create a new profiler with custom configuration

pub fn start_timing(&self) -> ProfilingTimer

Start timing a communication operation

pub fn record_event( &self, op_type: CommunicationOpType, rank: u32, world_size: u32, data_size_bytes: usize, timer: ProfilingTimer, ) -> TorshResult<()>

Record a communication event

pub fn get_operation_stats( &self, op_type: CommunicationOpType, ) -> TorshResult<Option<OperationStats>>

Get statistics for a specific operation type

pub fn get_all_operation_stats( &self, ) -> TorshResult<HashMap<CommunicationOpType, OperationStats>>

Get all operation statistics

pub fn get_rank_stats( &self, rank: u32, ) -> TorshResult<Option<HashMap<CommunicationOpType, OperationStats>>>

Get statistics for a specific rank

pub fn get_recent_events( &self, count: usize, ) -> TorshResult<Vec<CommunicationEvent>>

Get recent events (last N events)

pub fn get_all_events(&self) -> TorshResult<Vec<CommunicationEvent>>

Get all events

pub fn get_failed_operations_count(&self) -> u64

Get the count of failed operations across all ranks and operation types

pub fn clear(&self) -> TorshResult<()>

Clear all profiling data

pub fn update_config(&self, config: ProfilingConfig) -> TorshResult<()>

Update configuration

pub fn export_json(&self) -> TorshResult<String>

Export profiling data to JSON

pub fn generate_summary(&self) -> TorshResult<String>

Generate a summary report

Trait Implementations

impl Default for CommunicationProfiler

fn default() -> Self

Returns the “default value” for a type.