diff --git a/sf-stream/src/main.cpp b/sf-stream/src/main.cpp index 9ebb111..dbe313a 100644 --- a/sf-stream/src/main.cpp +++ b/sf-stream/src/main.cpp @@ -5,10 +5,8 @@ #include #include -#include "buffer_config.hpp" #include "stream_config.hpp" #include "ZmqLiveSender.hpp" -#include "ZmqPulseSyncReceiver.hpp" using namespace std; using namespace buffer_config; @@ -30,22 +28,22 @@ int main (int argc, char *argv[]) // TODO: Add stream_name to config reading - multiple stream definitions. auto config = BufferUtils::read_json_config(string(argv[1])); - string RECV_IPC_URL = BUFFER_LIVE_IPC_URL + config.detector_name + "-"; auto ctx = zmq_ctx_new(); zmq_ctx_set(ctx, ZMQ_IO_THREADS, STREAM_ZMQ_IO_THREADS); + auto receiver = BufferUtils::connect_socket( + ctx, config.detector_name, "assembler"); - ZmqPulseSyncReceiver receiver(ctx, config.detector_name, config.n_modules); RamBuffer ram_buffer(config.detector_name, config.n_modules); StreamStats stats(config.detector_name, stream_name, STREAM_STATS_MODULO); ZmqLiveSender sender(ctx, config); ImageMetadata meta; while (true) { - auto pulse_and_sync = receiver.get_next_pulse_id(); - char* data = ram_buffer.read_image(pulse_and_sync.pulse_id, meta); + zmq_recv(receiver, &meta, sizeof(meta), 0); + char* data = ram_buffer.read_image(meta.pulse_id); sender.send(meta, data); - stats.record_stats(meta, pulse_and_sync.n_lost_pulses); + stats.record_stats(meta); } }