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

Fix address for mock stream

Browse Source
This commit is contained in:
babic_a
2020-04-08 16:34:13 +02:00
parent e699a2c09a
commit 321e3baa41
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/test/mock/stream.hpp
+3 -1
View File
@@ -3,11 +3,13 @@
#include <zmq.hpp>
const std::string MOCK_STREAM_ADDRESS("tcp://127.0.0.1:11000");
void generate_stream(size_t n_messages)
{
zmq::context_t context(1);
zmq::socket_t socket(context, ZMQ_PUSH);
socket.bind("tcp://127.0.0.1:11000");
socket.bind(MOCK_STREAM_ADDRESS);
string header = "{\"frame\": 0, \"shape\": [1,16], \"type\": \"uint8\"}";
zmq::const_buffer header_msg(header.c_str(), header.length());