Buffer Manager#

class ccat_data_transfer.buffer_manager.BufferManager[source]#

Bases: object

Manages the data buffer and implements protection against overflow.

__init__()[source]#
start_monitoring()[source]#

Start the buffer monitoring thread.

stop_monitoring()[source]#

Stop the buffer monitoring thread.

get_buffer_state() → Dict[str, Any][source]#

Get the current buffer state.

can_create_data() → bool[source]#

Check if new data can be created based on buffer state.

get_max_parallel_transfers() → int[source]#

Get the maximum number of parallel transfers based on buffer state.

Overview#

The Buffer Manager monitors and manages buffer storage at different sites.

Key Functions#

  • start_monitoring() - Start buffer monitoring

  • stop_monitoring() - Stop buffer monitoring