mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-05-05 12:04:13 +02:00
Improve interface for caching data from file
This commit is contained in:
@@ -8,16 +8,10 @@
|
||||
|
||||
class LiveH5Reader {
|
||||
|
||||
struct LiveBufferMetadata {
|
||||
uint64_t pulse_id[core_buffer::FILE_MOD];
|
||||
uint64_t frame_index[core_buffer::FILE_MOD];
|
||||
uint32_t daq_rec[core_buffer::FILE_MOD];
|
||||
uint16_t n_received_packets[core_buffer::FILE_MOD];
|
||||
};
|
||||
|
||||
const std::string current_filename_;
|
||||
const uint16_t source_id_;
|
||||
std::unique_ptr<LiveBufferMetadata> metadata_buffer_;
|
||||
|
||||
std::unique_ptr<uint64_t[]> pulse_id_buffer_;
|
||||
std::unique_ptr<uint16_t[]> data_buffer_;
|
||||
|
||||
public:
|
||||
@@ -29,7 +23,7 @@ public:
|
||||
uint64_t get_latest_pulse_id();
|
||||
void load_pulse_id(uint64_t pulse_id);
|
||||
|
||||
ModuleFrame* get_metadata();
|
||||
ModuleFrame get_metadata();
|
||||
char* get_data();
|
||||
};
|
||||
|
||||
|
||||
@@ -25,7 +25,7 @@ void sf_live (
|
||||
auto metadata = reader.get_metadata();
|
||||
|
||||
zmq_send(socket,
|
||||
(char*) metadata,
|
||||
&metadata,
|
||||
sizeof(ModuleFrame),
|
||||
ZMQ_SNDMORE);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user