mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-04-27 07:50:44 +02:00
Add original header to frame metadata
This commit is contained in:
@@ -105,9 +105,9 @@ void ProcessManager::receive_zmq(WriterManager& manager, RingBuffer& ring_buffer
|
||||
}
|
||||
|
||||
// Parse JSON header.
|
||||
string header_string(static_cast<char*>(message_header.data()), message_header.size());
|
||||
frame_metadata.header_string = string(static_cast<char*>(message_header.data()), message_header.size());
|
||||
stringstream header_stream;
|
||||
header_stream << header_string << endl;
|
||||
header_stream << frame_metadata.header_string << endl;
|
||||
pt::read_json(header_stream, json_header);
|
||||
|
||||
// Extract data from message header.
|
||||
|
||||
+5
-2
@@ -11,10 +11,10 @@
|
||||
struct FrameMetadata
|
||||
{
|
||||
FrameMetadata(){}
|
||||
|
||||
|
||||
FrameMetadata(const FrameMetadata& other) :
|
||||
buffer_slot_index(other.buffer_slot_index), frame_bytes_size(other.frame_bytes_size), frame_index(other.frame_index),
|
||||
endianness(other.endianness), type(other.type) {
|
||||
endianness(other.endianness), type(other.type), header_string(other.header_string) {
|
||||
frame_shape[0] = other.frame_shape[0];
|
||||
frame_shape[1] = other.frame_shape[1];
|
||||
}
|
||||
@@ -28,6 +28,9 @@ struct FrameMetadata
|
||||
std::string endianness;
|
||||
std::string type;
|
||||
size_t frame_shape[2];
|
||||
|
||||
// Pass the original header as well.
|
||||
std::string header_string;
|
||||
};
|
||||
|
||||
class RingBuffer
|
||||
|
||||
Reference in New Issue
Block a user