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

Substitute deprecated method with valid one for Zmq recv

Browse Source
This commit is contained in:
babic_a
2020-04-03 13:51:35 +02:00
parent a3d8b1e92b
commit 1949eab3ef
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/receiver/ZmqReceiver.cpp
+6 -6
View File
@@ -117,17 +117,17 @@ pair<shared_ptr<FrameMetadata>, char*> ZmqReceiver::receive()
}
// Get the message header.
if (!socket_.recv(&message_header_)){
if (!socket_.recv(message_header_)){
return {nullptr, nullptr};
}
auto header_string = string(
static_cast<char*>(message_header.data()),
message_header.size());
static_cast<char*>(message_header_.data()),
message_header_.size());
auto frame_metadata = read_json_header(header_string);
// Get the message data.
if (!socket_.recv(&message_data)) {
if (!socket_.recv(message_data_)) {
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
@@ -139,9 +139,9 @@ pair<shared_ptr<FrameMetadata>, char*> ZmqReceiver::receive()
return {nullptr, nullptr};
}
frame_metadata->frame_bytes_size = message_data.size();
frame_metadata->frame_bytes_size = message_data_.size();
return {frame_metadata, static_cast<char*>(message_data.data())};
return {frame_metadata, static_cast<char*>(message_data_.data())};
}
shared_ptr<FrameMetadata> ZmqReceiver::read_json_header(const string& header)