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

Merge pull request #2 from paulscherrerinstitute/ipc_prefix

Browse Source 
Added "-" at the end of ipc
This commit is contained in:
babic_a
2020-05-22 14:35:00 +02:00
committed by GitHub
parent 6489adec67 5f58b1b0de
commit 9eb851b2c7
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-replay/src/main.cpp
+1 -1
View File
@@ -116,7 +116,7 @@ int main (int argc, char *argv[]) {
const auto start_pulse_id = (uint64_t) atoll(argv[5]);
const auto stop_pulse_id = (uint64_t) atoll(argv[6]);
auto ipc_base = REPLAY_STREAM_IPC_URL + ipc_id;
auto ipc_base = REPLAY_STREAM_IPC_URL + ipc_id + "-";
stringstream ipc_stream;
ipc_stream << ipc_base << (int)source_id;
const auto ipc_address = ipc_stream.str();
sf-writer/src/main.cpp
+1 -1
View File
@@ -94,7 +94,7 @@ int main (int argc, char *argv[])
auto ctx = zmq_ctx_new();
zmq_ctx_set (ctx, ZMQ_IO_THREADS, WRITER_ZMQ_IO_THREADS);
auto ipc_base = REPLAY_STREAM_IPC_URL + ipc_id;
auto ipc_base = REPLAY_STREAM_IPC_URL + ipc_id + "-";
thread replay_receive_thread(receive_replay,
ctx, ipc_base, n_modules,
ref(queue), start_pulse_id, stop_pulse_id);