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

Load buffer implementation

Browse Source
This commit is contained in:
babic_a
2020-05-25 13:39:26 +02:00
parent 61ab922245
commit 360e476afb
2 changed files with 25 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-replay/include/ReplayH5Reader.hpp
+2 -2
View File
@@ -19,8 +19,8 @@ class ReplayH5Reader {
H5::DataSet dset_metadata_;
H5::DataSet dset_frame_;
ModuleFrame* m_buffer;
char* f_buffer;
ModuleFrame* m_buffer_;
char* f_buffer_;
uint64_t buffer_start_pulse_id_;
uint64_t buffer_end_pulse_id_;
sf-replay/src/ReplayH5Reader.cpp
+23 -36
View File
@@ -13,7 +13,6 @@ void ReplayH5Reader::load_buffers(const uint64_t pulse_id)
{
auto pulse_filename = BufferUtils::get_filename(
device_, channel_name_, pulse_id);
auto start_index_in_file = BufferUtils::get_file_frame_index(pulse_id);
if (pulse_filename != current_filename_) {
close_file();
@@ -25,57 +24,45 @@ void ReplayH5Reader::load_buffers(const uint64_t pulse_id)
dset_frame_ = current_file_.openDataSet(BUFFER_H5_FRAME_DATASET);
}
hsize_t b_m_dims[2] = {n_pulses, 1};
auto file_index = BufferUtils::get_file_frame_index(pulse_id);
auto cache_start_index = file_index / REPLAY_READ_BUFFER_SIZE;
cache_start_index *= REPLAY_READ_BUFFER_SIZE;
buffer_start_pulse_id_ = pulse_id - (file_index - cache_start_index);
buffer_end_pulse_id_ = buffer_start_pulse_id_ + REPLAY_READ_BUFFER_SIZE;
hsize_t b_m_dims[2] = {REPLAY_READ_BUFFER_SIZE, ModuleFrame_N_FIELDS};
H5::DataSpace b_m_space (2, b_m_dims);
hsize_t b_m_count[] = {n_pulses, 1};
hsize_t b_m_count[] = {REPLAY_READ_BUFFER_SIZE, ModuleFrame_N_FIELDS};
hsize_t b_m_start[] = {0, 0};
b_m_space.selectHyperslab(H5S_SELECT_SET, b_m_count, b_m_start);
hsize_t f_m_dims[2] = {FILE_MOD, ModuleFrame_N_FIELDS};
H5::DataSpace f_m_space (2, f_m_dims);
hsize_t f_m_count[] = {n_pulses, 1};
hsize_t pulse_id_start[] = {start_index_in_file, 0};
hsize_t f_m_count[] = {REPLAY_READ_BUFFER_SIZE, ModuleFrame_N_FIELDS};
hsize_t pulse_id_start[] = {cache_start_index, 0};
f_m_space.selectHyperslab(H5S_SELECT_SET, f_m_count, pulse_id_start);
dset_metadata_.read(
&(metadata->pulse_id[0]), H5::PredType::NATIVE_UINT64,
b_m_space, f_m_space);
hsize_t frame_index_start[] = {start_index_in_file, 1};
f_m_space.selectHyperslab(H5S_SELECT_SET, f_m_count, frame_index_start);
dset_metadata_.read(
&(metadata->frame_index[0]), H5::PredType::NATIVE_UINT64,
b_m_space, f_m_space);
hsize_t daq_rec_start[] = {start_index_in_file, 2};
f_m_space.selectHyperslab(H5S_SELECT_SET, f_m_count, daq_rec_start);
dset_metadata_.read(
&(metadata->daq_rec[0]), H5::PredType::NATIVE_UINT64,
b_m_space, f_m_space);
hsize_t n_packets_start[] = {start_index_in_file, 3};
f_m_space.selectHyperslab(H5S_SELECT_SET, f_m_count, n_packets_start);
dset_metadata_.read(
&(metadata->n_received_packets[0]), H5::PredType::NATIVE_UINT64,
b_m_space, f_m_space);
m_buffer_, H5::PredType::NATIVE_UINT64, b_m_space, f_m_space);
hsize_t b_f_dims[3] =
{n_pulses, MODULE_Y_SIZE, MODULE_X_SIZE};
{REPLAY_READ_BUFFER_SIZE, MODULE_Y_SIZE, MODULE_X_SIZE};
H5::DataSpace b_f_space (3, b_f_dims);
hsize_t b_f_count[] =
{n_pulses, MODULE_Y_SIZE, MODULE_X_SIZE};
{REPLAY_READ_BUFFER_SIZE, MODULE_Y_SIZE, MODULE_X_SIZE};
hsize_t b_f_start[] = {0, 0, 0};
b_f_space.selectHyperslab(H5S_SELECT_SET, b_f_count, b_f_start);
hsize_t f_frame_dims[3] = {FILE_MOD, MODULE_Y_SIZE, MODULE_X_SIZE};
H5::DataSpace f_f_space (3, f_frame_dims);
hsize_t f_f_count[] =
{n_pulses, MODULE_Y_SIZE, MODULE_X_SIZE};
hsize_t f_f_start[] = {start_index_in_file, 0, 0};
{REPLAY_READ_BUFFER_SIZE, MODULE_Y_SIZE, MODULE_X_SIZE};
hsize_t f_f_start[] = {cache_start_index, 0, 0};
f_f_space.selectHyperslab(H5S_SELECT_SET, f_f_count, f_f_start);
dset_frame_.read(
frame_buffer, H5::PredType::NATIVE_UINT16, b_f_space, f_f_space);
f_buffer_, H5::PredType::NATIVE_UINT16, b_f_space, f_f_space);
}
ReplayH5Reader::ReplayH5Reader(
@@ -86,16 +73,16 @@ ReplayH5Reader::ReplayH5Reader(
channel_name_(channel_name),
source_id_(source_id)
{
m_buffer = new ModuleFrame[REPLAY_READ_BUFFER_SIZE];
f_buffer = new char[MODULE_N_BYTES * REPLAY_READ_BUFFER_SIZE];
m_buffer_ = new ModuleFrame[REPLAY_READ_BUFFER_SIZE];
f_buffer_ = new char[MODULE_N_BYTES * REPLAY_READ_BUFFER_SIZE];
}
ReplayH5Reader::~ReplayH5Reader()
{
close_file();
delete[] m_buffer;
delete[] f_buffer;
delete[] m_buffer_;
delete[] f_buffer_;
}
void ReplayH5Reader::close_file()
@@ -120,6 +107,6 @@ void ReplayH5Reader::get_buffer(
auto buffer_index = pulse_id - buffer_start_pulse_id_;
metadata = m_buffer + (buffer_index * sizeof(ModuleFrame));
data = f_buffer + (buffer_index * MODULE_N_BYTES);
metadata = m_buffer_ + (buffer_index * sizeof(ModuleFrame));
data = f_buffer_ + (buffer_index * MODULE_N_BYTES);
}