mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-05-01 05:02:24 +02:00
babic_a
465369a322
The pulse_id stream can be used to synchronize components. For example, the writer can listen for the current pulse_id and write with 1 second delay to a file. This will help us eliminate the need to wait for the run to complete to start the data write request.
16 lines
590 B
C++
16 lines
590 B
C++
namespace stream_config
|
|
{
|
|
// N of IO threads to receive data from modules.
|
|
const int STREAM_ZMQ_IO_THREADS = 2;
|
|
// How long should the RECV queue be.
|
|
const size_t STREAM_RCVHWM = 100;
|
|
// Size of buffer between the receiving and sending part.
|
|
const int STREAM_FASTQUEUE_SLOTS = 5;
|
|
// If the modules are offset more than 1000 pulses, crush.
|
|
const uint64_t PULSE_OFFSET_LIMIT = 1000;
|
|
// SNDHWM for live processing socket.
|
|
const int PROCESSING_ZMQ_SNDHWM = 10;
|
|
// Keep the last second of pulses in the buffer.
|
|
const int PULSE_ZMQ_SNDHWM = 100;
|
|
}
|