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

Cleanup of sf_buffer

Browse Source
This commit is contained in:
babic_a
2020-04-23 09:51:39 +02:00
parent 83afffc325
commit 0a90e4437d
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_buffer.cpp
+6 -2
View File
@@ -9,6 +9,7 @@
using namespace std;
using namespace core_buffer;
int main (int argc, char *argv[]) {
@@ -28,7 +29,7 @@ int main (int argc, char *argv[]) {
int udp_port = atoi(argv[2]);
string root_folder = string(argv[3]);
RingBuffer<UdpFrameMetadata> ring_buffer(core_buffer::BUFFER_RB_SIZE);
RingBuffer<UdpFrameMetadata> ring_buffer(BUFFER_RB_SIZE);
UdpRecvModule udp_module(ring_buffer);
udp_module.start_recv(udp_port, JUNGFRAU_DATA_BYTES_PER_FRAME);
@@ -39,7 +40,8 @@ int main (int argc, char *argv[]) {
uint64_t last_pulse_id = 0;
FastH5Writer writer(
core_buffer::FILE_MOD, 512, 1024, device_name, root_folder);
core_buffer::FILE_MOD, MODULE_Y_SIZE, MODULE_X_SIZE,
device_name, root_folder);
writer.add_scalar_metadata<uint64_t>("pulse_id");
writer.add_scalar_metadata<uint64_t>("frame_id");
@@ -59,6 +61,8 @@ int main (int argc, char *argv[]) {
writer.write_data(data.second);
// TODO: Combine all this into 1 struct.
writer.write_scalar_metadata<uint64_t>(
"pulse_id", &(data.first->pulse_id));