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

Adapt main to the new recv class

Browse Source
This commit is contained in:
babic_a
2020-06-09 11:00:27 +02:00
parent c6960b5e59
commit 5e1377e00a
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-stream/src/main.cpp
+3 -4
View File
@@ -56,9 +56,10 @@ int main (int argc, char *argv[])
auto ctx = zmq_ctx_new();
zmq_ctx_set (ctx, ZMQ_IO_THREADS, STREAM_ZMQ_IO_THREADS);
const string LIVE_IPC_URL = BUFFER_LIVE_IPC_URL+DETECTOR_NAME+"-";
const string LIVE_IPC_URL = BUFFER_LIVE_IPC_URL+DETECTOR_NAME + "-";
ZmqLiveReceiver receiver(n_modules, ctx, LIVE_IPC_URL);
LiveRecvModule recv_module(queue, n_modules, ctx, LIVE_IPC_URL);
LiveRecvModule recv_module(queue, receiver);
// 0mq sockets to streamvis and live analysis
void *socket_streamvis = zmq_socket(ctx, ZMQ_PUB);
@@ -72,8 +73,6 @@ int main (int argc, char *argv[])
uint16_t data_empty [] = { 0, 0, 0, 0};
// TODO: Remove stats trash.
int stats_counter = 0;