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

Add perf measurement to writer

Browse Source
This commit is contained in:
babic_a
2018-07-11 11:47:02 +02:00
parent 6a81e0f86a
commit 9ca9ba226a
1 changed files with 36 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ProcessManager.cpp
+36 -2
View File
@@ -117,6 +117,11 @@ void ProcessManager::write_h5(WriterManager& manager, const H5Format& format, Ri
continue;
}
#ifdef PERF_OUTPUT
using namespace date;
auto start_time_frame = std::chrono::system_clock::now();
#endif
// Write image data.
writer.write_data(raw_frames_dataset_name,
received_data.first->frame_index,
@@ -126,8 +131,25 @@ void ProcessManager::write_h5(WriterManager& manager, const H5Format& format, Ri
received_data.first->type,
received_data.first->endianness);
#ifdef PERF_OUTPUT
using namespace date;
using namespace std::chrono;
auto frame_time_difference = std::chrono::system_clock::now() - start_time_frame;
auto frame_diff_ms = duration<float, milli>(frame_time_difference).count();
cout << "[" << std::chrono::system_clock::now() << "]";
cout << "[ProcessManager::write_h5] Frame index ";
cout << received_data.first->frame_index << " written in " << frame_diff_ms << " ms." << endl;
#endif
ring_buffer.release(received_data.first->buffer_slot_index);
#ifdef PERF_OUTPUT
using namespace date;
auto start_time_metadata = std::chrono::system_clock::now();
#endif
// Write image metadata if mapping specified.
if (header_values_type) {
@@ -150,6 +172,18 @@ void ProcessManager::write_h5(WriterManager& manager, const H5Format& format, Ri
header_data_type.endianness);
}
}
#ifdef PERF_OUTPUT
using namespace date;
using namespace std::chrono;
auto metadata_time_difference = std::chrono::system_clock::now() - start_time_metadata;
auto metadata_diff_ms = duration<float, milli>(metadata_time_difference).count();
cout << "[" << std::chrono::system_clock::now() << "]";
cout << "[ProcessManager::write_h5] Frame metadata index ";
cout << received_data.first->frame_index << " written in " << metadata_diff_ms << " ms." << endl;
#endif
manager.written_frame(received_data.first->frame_index);
}
@@ -175,8 +209,8 @@ void ProcessManager::write_h5(WriterManager& manager, const H5Format& format, Ri
H5FormatUtils::write_format(writer.get_h5_file(), format, parameters);
} catch (const runtime_error& ex) {
using namespace date;
cout << "[" << std::chrono::system_clock::now() << "]";
cout << "[ProcessManager::write] Error while trying to write file format: "<< ex.what() << endl;
std::cout << "[" << std::chrono::system_clock::now() << "]";
std::cout << "[ProcessManager::write] Error while trying to write file format: "<< ex.what() << endl;
}
}
}