httomo.runner.monitoring_interface.MonitoringInterface

class httomo.runner.monitoring_interface.MonitoringInterface(*args, **kwargs)

Methods

__init__(*args, **kwargs)
report_method_block(method_name, ...[, ...])
report_sink_block(name, last_task_id, ...)
report_source_block(name, first_task_id, ...)
report_total_time(cpu_time)
write_results(dest)

report_method_block(method_name: str, module_path: str, task_id: str, slicing_dim: int, block_dims: Tuple[int, int, int], block_idx_chunk: Tuple[int, int, int], block_idx_global: Tuple[int, int, int], cpu_time: float, gpu_kernel_time: float = 0.0, gpu_h2d_time: float = 0.0, gpu_d2h_time: float = 0.0)

report_sink_block(name: str, last_task_id: str, slicing_dim: int, block_dims: Tuple[int, int, int], block_idx_chunk: Tuple[int, int, int], block_idx_global: Tuple[int, int, int], cpu_time: float)

report_source_block(name: str, first_task_id: str, slicing_dim: int, block_dims: Tuple[int, int, int], block_idx_chunk: Tuple[int, int, int], block_idx_global: Tuple[int, int, int], cpu_time: float)

report_total_time(cpu_time: float)

write_results(dest: TextIO)