sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-06-06 15:28:42 +02:00
Code Issues Packages Projects Releases Wiki Activity

Try multi polling instead of single merge

Browse Source
This commit is contained in:
babic_a
2020-04-22 15:48:38 +02:00
parent 15a3347951
commit 8a839d8e59
2 changed files with 55 additions and 74 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_replay.cpp
-11
View File
@@ -57,14 +57,6 @@ int main (int argc, char *argv[]) {
throw runtime_error(strerror (errno));
}
auto meta_socket = zmq_socket(ctx, ZMQ_SUB);
if (zmq_connect(meta_socket, "ipc://metadata") != 0) {
throw runtime_error(strerror (errno));
}
if (zmq_setsockopt(meta_socket, ZMQ_SUBSCRIBE, "", 0) != 0) {
throw runtime_error(strerror (errno));
}
for (const auto& suffix:path_suffixes) {
metadata_buffer->start_pulse_id = suffix.start_pulse_id;
metadata_buffer->stop_pulse_id = suffix.stop_pulse_id;
@@ -181,9 +173,6 @@ int main (int argc, char *argv[]) {
H5::PredType::NATIVE_UINT16,
H5::DataSpace::ALL, meta_space);
}
// Wait for sync.
zmq_recv(meta_socket, nullptr, 0, 0);
}
input_file.close();