sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-04 20:04:14 +02:00
Code Issues Packages Projects Releases Wiki Activity

Executable instantiate receiver

Browse Source
This commit is contained in:
babic_a
2018-02-12 10:15:14 +01:00
parent 8b9927ca79
commit d2b7863897
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/h5_zmq_writer.cpp
+6
View File
@@ -2,8 +2,10 @@
#include <sstream>
#include <stdexcept>
#include "config.hpp"
#include "ProcessManager.hpp"
#include "WriterManager.hpp"
#include "ZmqReceiver.hpp"
#include "format/NXmxFormat.cpp"
int main (int argc, char *argv[])
@@ -44,6 +46,10 @@ int main (int argc, char *argv[])
WriterManager manager(format.get_input_value_type(), output_file, n_frames);
string connect_address = string(argv[1]);
int n_io_threads = config::zmq_n_io_threads;
int receive_timeout = config::zmq_receive_timeout;
ZmqReceiver receiver(connect_address, n_io_threads, receive_timeout);
int rest_port = atoi(argv[4]);
ProcessManager::run_writer(manager, format, connect_address, rest_port);