Files
Jungfraujoch/writer/HDF5DataFilePluginReflection.cpp
Filip Leonarski 2be7780bc4
Some checks failed
Build Packages / build:rpm (ubuntu2404_nocuda) (push) Successful in 12m30s
Build Packages / build:rpm (ubuntu2204_nocuda) (push) Successful in 13m30s
Build Packages / build:rpm (rocky8_nocuda) (push) Successful in 14m10s
Build Packages / Generate python client (push) Successful in 12s
Build Packages / build:rpm (rocky8) (push) Successful in 14m14s
Build Packages / build:rpm (rocky8_sls9) (push) Successful in 14m23s
Build Packages / Create release (push) Has been skipped
Build Packages / build:rpm (rocky9_nocuda) (push) Successful in 14m56s
Build Packages / Build documentation (push) Successful in 39s
Build Packages / build:rpm (rocky9) (push) Successful in 14m58s
Build Packages / build:rpm (rocky9_sls9) (push) Successful in 15m12s
Build Packages / build:rpm (ubuntu2404) (push) Successful in 7m29s
Build Packages / build:rpm (ubuntu2204) (push) Successful in 8m44s
Build Packages / Unit tests (push) Failing after 3h12m6s
jfjoch_writer: Reserve all metadata vectors when opening file
2026-03-04 20:15:54 +01:00

75 lines
2.8 KiB
C++

// SPDX-FileCopyrightText: 2024 Filip Leonarski, Paul Scherrer Institute <filip.leonarski@psi.ch>
// SPDX-License-Identifier: GPL-3.0-only
#include "HDF5DataFilePluginReflection.h"
#include "../include/spdlog/fmt/fmt.h"
#include "../common/Reflection.h"
void HDF5DataFilePluginReflection::OpenFile(HDF5File &data_file, const DataMessage &msg, size_t images_per_file) {
reflection_group = std::make_unique<HDF5Group>(data_file, "/entry/reflections");
reflection_group->NXClass("NXcollection");
}
void HDF5DataFilePluginReflection::Write(const DataMessage &msg, uint64_t image_number) {
if (!reflection_group || msg.reflections.empty())
return;
std::vector<int32_t> h, k, l;
std::vector<float> I, sigma, d, lp;
std::vector<float> image, phi, pred_x, pred_y, bkg, partiality, zeta;
h.reserve(msg.reflections.size());
k.reserve(msg.reflections.size());
l.reserve(msg.reflections.size());
I.reserve(msg.reflections.size());
sigma.reserve(msg.reflections.size());
d.reserve(msg.reflections.size());
pred_x.reserve(msg.reflections.size());
pred_y.reserve(msg.reflections.size());
bkg.reserve(msg.reflections.size());
lp.reserve(msg.reflections.size());
partiality.reserve(msg.reflections.size());
image.reserve(msg.reflections.size());
phi.reserve(msg.reflections.size());
zeta.reserve(msg.reflections.size());
for (const auto &refl : msg.reflections) {
image.emplace_back(refl.image_number);
h.emplace_back(refl.h);
k.emplace_back(refl.k);
l.emplace_back(refl.l);
I.emplace_back(refl.I);
sigma.emplace_back(refl.sigma);
d.emplace_back(refl.d);
pred_x.emplace_back(refl.predicted_x);
pred_y.emplace_back(refl.predicted_y);
bkg.emplace_back(refl.bkg);
lp.emplace_back(1.0/refl.rlp);
partiality.emplace_back(refl.partiality);
phi.emplace_back(refl.delta_phi_deg);
zeta.emplace_back(refl.zeta);
}
std::string image_group_name = fmt::format("image_{:06d}", image_number);
HDF5Group image_group(*reflection_group, image_group_name);
image_group.NXClass("NXreflections");
image_group.SaveVector("h", h);
image_group.SaveVector("k", k);
image_group.SaveVector("l", l);
image_group.SaveVector("d", d)->Units("Angstrom");
image_group.SaveVector("delta_phi", phi);
image_group.SaveVector("predicted_x", pred_x);
image_group.SaveVector("predicted_y", pred_y);
image_group.SaveVector("int_sum", I);
image_group.SaveVector("int_err", sigma);
image_group.SaveVector("background_mean", bkg);
image_group.SaveVector("observed_frame", image);
image_group.SaveVector("lp", lp);
image_group.SaveVector("partiality", partiality);
image_group.SaveVector("zeta", zeta);
}
void HDF5DataFilePluginReflection::WriteFinal(HDF5File &data_file) {
}