From 5e1377e00a54283830a322e0291407149ac20cd3 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Tue, 9 Jun 2020 11:00:27 +0200 Subject: [PATCH] Adapt main to the new recv class --- sf-stream/src/main.cpp | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/sf-stream/src/main.cpp b/sf-stream/src/main.cpp index 0ddbf52..83d3f9d 100644 --- a/sf-stream/src/main.cpp +++ b/sf-stream/src/main.cpp @@ -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;