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

Change logic from pulse_id to block sending

Browse Source
This commit is contained in:
babic_a
2020-05-27 10:43:22 +02:00
parent 72a9b3bcc9
commit 32f4ef6dba
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-replay/src/main.cpp
+7 -4
View File
@@ -89,10 +89,13 @@ int main (int argc, char *argv[]) {
ReplayZmqSender sender(ipc_id, source_id);
// "<= stop_pulse_id" because we include the stop_pulse_id in the file.
for (uint64_t curr_pulse_id=start_pulse_id;
curr_pulse_id <= stop_pulse_id;
curr_pulse_id++) {
uint64_t start_block = start_pulse_id / BUFFER_BLOCK_SIZE;
uint64_t stop_block = stop_pulse_id / BUFFER_BLOCK_SIZE;
// "<= stop_block" because we include the stop_block in the transfer.
for (uint64_t curr_block=start_block;
curr_block <= stop_block;
curr_block++) {
int slot_id;
while((slot_id = queue.read()) == -1) {