mx/Jungfraujoch
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 44 Wiki Activity

Track bunchID, info, and timestamp from AcquisitionDevice to HDF5DataFile

Browse Source
This commit is contained in:
leonarski_f
2023-04-14 13:41:31 +02:00
parent 637b710899
commit a8f036da5b
12 changed files with 128 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
writer/HDF5DataFile.cpp
View File

@@ -35,6 +35,12 @@ HDF5DataFile::~HDF5DataFile() {
group.SaveVector("peakYPosRaw", spot_y, dims, CompressionAlgorithm::BSHUF_LZ4);
group.SaveVector("peakTotalIntensity", spot_intensity, dims, CompressionAlgorithm::BSHUF_LZ4);
group.SaveVector("indexingResult", indexing_result);
HDF5Group group_exp(*data_file, "/entry/jungfrau");
group_exp.NXClass("NXcollection");
group_exp.SaveVector("bunch_id", bunch_id);
group_exp.SaveVector("info", jf_info);
group_exp.SaveVector("timestamp", timestamp);
}
data_file.reset();
@@ -53,6 +59,9 @@ void HDF5DataFile::CreateFile() {
spot_y.resize(max_spots);
spot_intensity.resize(max_spots);
indexing_result.resize(1);
bunch_id.resize(1);
jf_info.resize(1);
timestamp.resize(1);
}
void HDF5DataFile::Write(const DataMessage &msg, uint64_t image_number) {
@@ -68,6 +77,9 @@ void HDF5DataFile::Write(const DataMessage &msg, uint64_t image_number) {
spot_y.resize(max_spots * (max_image_number + 1));
spot_intensity.resize(max_spots * (max_image_number + 1));
indexing_result.resize(max_image_number + 1);
bunch_id.resize(max_image_number + 1);
jf_info.resize(max_image_number + 1);
timestamp.resize(max_image_number + 1);
}
nimages++;
@@ -84,6 +96,9 @@ void HDF5DataFile::Write(const DataMessage &msg, uint64_t image_number) {
}
indexing_result[image_number] = msg.indexing_result;
bunch_id[image_number] = msg.bunch_id;
jf_info[image_number] = msg.jf_info;
timestamp[image_number] = msg.timestamp;
}
size_t HDF5DataFile::GetMaxImageNumber() const {