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

Implement DummyBufferedWriter

Browse Source
This commit is contained in:
babic_a
2019-01-30 14:04:07 +01:00
parent 6d0c41a818
commit 4d05595f87
2 changed files with 26 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/src/BufferedWriter.cpp
-5
View File
@@ -52,11 +52,6 @@ void BufferedWriter::write_metadata_to_file()
}
}
DummyBufferedWriter::DummyBufferedWriter() : BufferedWriter("/dev/null", 0, 0, 0, 0){}
void DummyBufferedWriter::cache_metadata(string name, uint64_t frame_index, const char* data){}
void DummyBufferedWriter::write_metadata_to_file() {}
std::unique_ptr<BufferedWriter> get_buffered_writer(const string& filename, size_t total_frames,
std::unique_ptr<MetadataBuffer> metadata_buffer, hsize_t frames_per_file, hsize_t dataset_increase_step)
{
lib/src/BufferedWriter.hpp
+26 -4
View File
@@ -16,12 +16,34 @@ class BufferedWriter : public H5Writer
virtual void write_metadata_to_file();
};
class DummyBufferedWriter : public BufferedWriter
class DummyBufferedWriter : public BufferedWriter, public DummyH5Writer
{
public:
DummyBufferedWriter();
void cache_metadata(std::string name, uint64_t frame_index, const char* data) override;
void write_metadata_to_file() override;
DummyBufferedWriter() : BufferedWriter("/dev/null", 0, 0, 0, 0) {}
void cache_metadata(std::string name, uint64_t frame_index, const char* data) override {}
void write_metadata_to_file() override {}
bool is_file_open() const override
{ return DummyH5Writer::is_file_open(); }
void create_file(const hsize_t frame_chunk=1) override
{ return DummyH5Writer::create_file(frame_chunk); }
void close_file() override
{ return DummyH5Writer::close_file(); }
void write_data(const std::string& dataset_name, const size_t data_index, const char* data, const std::vector<size_t>& data_shape,
const size_t data_bytes_size, const std::string& data_type, const std::string& endianness) override
{
return DummyH5Writer::write_data (
dataset_name, data_index, data, data_shape, data_bytes_size, data_type, endianness );
}
H5::H5File& get_h5_file() override
{ return DummyH5Writer::get_h5_file(); }
bool is_data_for_current_file(const size_t data_index) override
{ return DummyH5Writer::is_data_for_current_file(data_index); }
};
std::unique_ptr<BufferedWriter> get_buffered_writer(const std::string& filename, size_t total_frames,