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

Change scalar write for SWMR

Browse Source
This commit is contained in:
babic_a
2020-04-20 16:36:30 +02:00
parent e6188bf840
commit 0171b61e8e
2 changed files with 70 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-buffer/src/FastH5Writer.cpp
+68 -7
View File
@@ -174,19 +174,80 @@ void FastH5Writer::write_data(const char *buffer)
H5::PredType::NATIVE_UINT16,
buffer_space,
disk_space);
H5Dflush(current_image_dataset_.getId());
}
void FastH5Writer::write_scalar_metadata(
template <>
void FastH5Writer::write_scalar_metadata<uint64_t>(
const std::string& name,
const void* value,
const size_t value_n_bytes)
const void* value)
{
auto& buffer_ptr = buffers_.at(name);
auto dataset = datasets_.at(name);
::memcpy(
buffer_ptr+(current_frame_index_*value_n_bytes),
hsize_t buff_dim[1] = {1};
H5::DataSpace buffer_space (1, buff_dim);
hsize_t disk_dim[2] = {n_frames_per_file_, 1};
H5::DataSpace disk_space(1, disk_dim);
hsize_t count[] = {1, 1};
hsize_t start[] = {current_frame_index_, 0};
disk_space.selectHyperslab(H5S_SELECT_SET, count, start);
dataset.write(
value,
value_n_bytes);
H5::PredType::NATIVE_UINT64,
buffer_space,
disk_space);
}
template <>
void FastH5Writer::write_scalar_metadata<uint32_t>(
const std::string& name,
const void* value)
{
auto dataset = datasets_.at(name);
hsize_t buff_dim[1] = {1};
H5::DataSpace buffer_space (1, buff_dim);
hsize_t disk_dim[2] = {n_frames_per_file_, 1};
H5::DataSpace disk_space(1, disk_dim);
hsize_t count[] = {1, 1};
hsize_t start[] = {current_frame_index_, 0};
disk_space.selectHyperslab(H5S_SELECT_SET, count, start);
dataset.write(
value,
H5::PredType::NATIVE_UINT32,
buffer_space,
disk_space);
}
template <>
void FastH5Writer::write_scalar_metadata<uint16_t>(
const std::string& name,
const void* value)
{
auto dataset = datasets_.at(name);
hsize_t buff_dim[1] = {1};
H5::DataSpace buffer_space (1, buff_dim);
hsize_t disk_dim[2] = {n_frames_per_file_, 1};
H5::DataSpace disk_space(1, disk_dim);
hsize_t count[] = {1, 1};
hsize_t start[] = {current_frame_index_, 0};
disk_space.selectHyperslab(H5S_SELECT_SET, count, start);
dataset.write(
value,
H5::PredType::NATIVE_UINT16,
buffer_space,
disk_space);
}
template <>