mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-05-02 04:02:24 +02:00
Remove deprecated methods from tests
This commit is contained in:
@@ -14,11 +14,15 @@ void generate_stream(size_t n_messages)
|
||||
socket.bind("tcp://127.0.0.1:11000");
|
||||
|
||||
string header = "{\"frame\": 0, \"shape\": [1,16], \"type\": \"uint8\"}";
|
||||
unique_ptr<char[]> buffer(make_unique<char[]>(16));
|
||||
zmq::const_buffer header_msg(header.c_str(), header.length());
|
||||
|
||||
size_t buffer_size = 16;
|
||||
char buffer[buffer_size];
|
||||
zmq::const_buffer buffer_msg(buffer, buffer_size);
|
||||
|
||||
for (size_t i=0; i<n_messages; i++) {
|
||||
socket.send(header.c_str(), header.length(), ZMQ_SNDMORE);
|
||||
socket.send(buffer.get(), 16);
|
||||
socket.send(header_msg, zmq::send_flags::sndmore);
|
||||
socket.send(buffer_msg);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user