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

added stream for live analysis to test

Browse Source
This commit is contained in:
Dmitry Ozerov
2020-05-04 09:08:24 +02:00
committed by babic_a
parent b5803a3f43
commit 8ce25dd846
1 changed files with 33 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-buffer/src/sf_stream.cpp
+33
View File
@@ -292,6 +292,39 @@ int main (int argc, char *argv[])
0);
}
//same for live analysis
int send_live_analysis = 0;
if ( reduction_factor_live_analysis > 1 ) {
send_live_analysis = rand() % reduction_factor_live_analysis;
}
if ( send_live_analysis == 0 ) {
header["shape"][0] = 16384;
header["shape"][1] = 1024;
} else{
header["shape"][0] = 2;
header["shape"][1] = 2;
}
text_header = Json::writeString(builder, header);
zmq_send(socket_live,
text_header.c_str(),
text_header.size(),
ZMQ_SNDMORE);
if ( send_live_analysis == 0 ) {
zmq_send(socket_live,
(char*)data,
core_buffer::MODULE_N_BYTES*n_modules,
0);
} else {
zmq_send(socket_live,
(char*)data_empty,
8,
0);
}
}
queue.release();