sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-06-07 09:38:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

Adjust Alvra runner

Browse Source
This commit is contained in:
babic_a
2018-07-18 17:10:56 +02:00
parent f3d90a2c4a
commit a9e026166c
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf_alvra/alvra_h5_writer.cpp
+8 -6
View File
@@ -41,9 +41,6 @@ int main (int argc, char *argv[])
writer_utils::create_destination_folder(output_file);
AlvraFormat format;
WriterManager manager(format.get_input_value_type(), output_file, n_frames);
auto header_values = shared_ptr<unordered_map<string, HeaderDataType>>(new unordered_map<string, HeaderDataType> {
{"pulse_id", HeaderDataType("uint64")},
{"frame", HeaderDataType("uint64")},
@@ -62,10 +59,15 @@ int main (int argc, char *argv[])
{"module_number", HeaderDataType("uint64", n_modules)}
});
ZmqReceiver receiver(connect_address, config::zmq_n_io_threads, config::zmq_receive_timeout, header_values);
ProcessManager::run_writer(manager, format, receiver, rest_port, bsread_rest_address);
AlvraFormat format;
WriterManager writer_manager(format.get_input_value_type(), output_file, n_frames);
ZmqReceiver receiver(connect_address, config::zmq_n_io_threads, config::zmq_receive_timeout, header_values);
RingBuffer ring_buffer(config::ring_buffer_n_slots);
ProcessManager process_manager(writer_manager, receiver, ring_buffer, format, rest_port, bsread_rest_address);
process_manager.run_writer();
return 0;
}