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

Pass frames per file forward

Browse Source
This commit is contained in:
babic_a
2018-09-26 17:26:08 +02:00
parent 52b7e40010
commit 18e5f88bac
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/src/ProcessManager.cpp
+3 -3
View File
@@ -15,9 +15,9 @@
using namespace std;
ProcessManager::ProcessManager(WriterManager& writer_manager, ZmqReceiver& receiver, RingBuffer& ring_buffer,
const H5Format& format, uint16_t rest_port, const string& bsread_rest_address) :
const H5Format& format, uint16_t rest_port, const string& bsread_rest_address, hsize_t frames_per_file) :
writer_manager(writer_manager), receiver(receiver), ring_buffer(ring_buffer), format(format), rest_port(rest_port),
bsread_rest_address(bsread_rest_address)
bsread_rest_address(bsread_rest_address), frames_per_file(frames_per_file)
{
}
@@ -152,7 +152,7 @@ void ProcessManager::receive_zmq()
void ProcessManager::write_h5()
{
auto writer = get_h5_writer(writer_manager.get_output_file(), 0, config::initial_dataset_size, config::dataset_increase_step);
auto writer = get_h5_writer(writer_manager.get_output_file(), frames_per_file, config::initial_dataset_size, config::dataset_increase_step);
auto raw_frames_dataset_name = config::raw_image_dataset_name;
uint64_t last_pulse_id = 0;