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

Reorganize assembler main code

Browse Source
This commit is contained in:
babic_a
2021-01-19 14:06:57 +01:00
parent 39d714f538
commit 53e24c9f1a
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jf-assembler/src/main.cpp
+2 -5
View File
@@ -5,7 +5,6 @@
#include <BufferUtils.hpp>
#include <AssemblerStats.hpp>
#include "buffer_config.hpp"
#include "assembler_config.hpp"
#include "ZmqPulseSyncReceiver.hpp"
@@ -27,17 +26,15 @@ int main (int argc, char *argv[])
auto config = BufferUtils::read_json_config(string(argv[1]));
auto const stream_name = "assembler";
string RECV_IPC_URL = BUFFER_LIVE_IPC_URL + config.detector_name + "-";
auto ctx = zmq_ctx_new();
zmq_ctx_set(ctx, ZMQ_IO_THREADS, ASSEMBLER_ZMQ_IO_THREADS);
auto sender = BufferUtils::bind_socket(
ctx, config.detector_name, stream_name);
ZmqPulseSyncReceiver receiver(ctx, config.detector_name, config.n_modules);
RamBuffer ram_buffer(config.detector_name, config.n_modules);
AssemblerStats stats(config.detector_name, ASSEMBLER_STATS_MODULO);
auto sender = BufferUtils::bind_socket(
ctx, config.detector_name, stream_name);
ImageMetadata meta;
while (true) {
auto pulse_and_sync = receiver.get_next_pulse_id();