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

Refactor buffered writer

Browse Source
This commit is contained in:
babic_a
2019-01-30 09:59:33 +01:00
parent 594931d39a
commit 1aba1c4e86
2 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/src/BufferedWriter.cpp
+3 -5
View File
@@ -52,13 +52,11 @@ void BufferedWriter::write_metadata_to_file()
}
}
void BufferedWriter::close_file()
{
H5Writer::close_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
+4 -3
View File
@@ -12,15 +12,16 @@ class BufferedWriter : public H5Writer
public:
BufferedWriter(const std::string& filename, size_t total_frames, std::unique_ptr<MetadataBuffer>&& metadata_buffer,
hsize_t frames_per_file=0, hsize_t initial_dataset_size=1000, hsize_t dataset_increase_step=1000);
void cache_metadata(std::string name, uint64_t frame_index, const char* data);
void write_metadata_to_file();
virtual void close_file() override;
virtual void cache_metadata(std::string name, uint64_t frame_index, const char* data);
virtual void write_metadata_to_file();
};
class DummyBufferedWriter : public BufferedWriter
{
public:
DummyBufferedWriter();
void cache_metadata(std::string name, uint64_t frame_index, const char* data) override;
void write_metadata_to_file() override;
};
std::unique_ptr<BufferedWriter> get_buffered_writer(const std::string& filename, size_t total_frames,