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

Unify brackets

Browse Source
This commit is contained in:
babic_a
2020-03-30 10:44:12 +02:00
parent 080b8d1d0e
commit 793fbfe24e
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/WriterManager.cpp
+6 -7
View File
@@ -141,7 +141,6 @@ unordered_map<string, uint64_t> WriterManager::get_statistics() const
return result;
}
void WriterManager::start(const string output_file,
const int n_frames,
const int user_id)
@@ -175,10 +174,8 @@ void WriterManager::start(const string output_file,
new boost::thread(&WriterManager::receive_zmq, this)
));
}
}
bool WriterManager::is_running() const
{
return running_flag.load();
@@ -197,7 +194,8 @@ bool WriterManager::should_receive_frame() {
return false;
}
bool WriterManager::should_write_frame() {
bool WriterManager::should_write_frame()
{
if (n_frames_to_write > 0) {
return (n_frames_to_write.fetch_sub(1) >= 0);
}
@@ -205,7 +203,8 @@ bool WriterManager::should_write_frame() {
return false;
}
void WriterManager::writing_completed() {
void WriterManager::writing_completed()
{
writing_flag = false;
#ifdef DEBUG_OUTPUT
@@ -223,8 +222,8 @@ void WriterManager::writing_error(string error) {
}
void WriterManager::write_h5_format(H5::H5File& file) {
void WriterManager::write_h5_format(H5::H5File& file)
{
try {
H5FormatUtils::write_format(file, format, {});
} catch (const runtime_error& ex) {