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

Fix call to FrameUdpReceiver

Browse Source
This commit is contained in:
babic_a
2021-07-05 15:02:09 +02:00
parent 78899d319f
commit f9e8b2750a
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jf-live-writer/src/main.cpp
+1 -1
View File
@@ -62,7 +62,7 @@ int main (int argc, char *argv[])
// Fair distribution of images among writers.
if (meta.i_image % n_writers == i_writer) {
char* data = ram_buffer.read_image(meta.image_metadata.pulse_id);
char* data = ram_buffer.get_slot_data(meta.image_metadata.pulse_id);
stats.start_image_write();
writer.write_data(meta.run_id, meta.i_image, data);
std-udp-recv/src/main.cpp
+2 -3
View File
@@ -49,7 +49,7 @@ int main (int argc, char *argv[]) {
const size_t FRAME_N_BYTES = MODULE_N_PIXELS * bit_depth / 8;
const size_t N_PACKETS_PER_FRAME = FRAME_N_BYTES / DATA_BYTES_PER_PACKET;
FrameUdpReceiver receiver(udp_port);
FrameUdpReceiver receiver(udp_port, N_PACKETS_PER_FRAME);
RamBuffer frame_buffer(config.detector_name, sizeof(ModuleFrame),
FRAME_N_BYTES, config.n_modules);
FrameStats stats(config.detector_name, module_id,
@@ -82,8 +82,7 @@ int main (int argc, char *argv[]) {
frame_buffer.write_frame(meta, data);
zmq_send(socket, &image_id, sizeof(image_id), 0);
const bool is_good_frame = meta.n_recv_packets == N_PACKETS_PER_FRAME;
stats.record_stats(meta, is_good_frame);
stats.record_stats(meta);
}
delete[] data;