Filip Leonarski
31a357fa57
All checks were successful
Build Packages / build:rpm (rocky8_nocuda) (push) Successful in 11m0s
Build Packages / build:rpm (ubuntu2204_nocuda) (push) Successful in 11m2s
Build Packages / build:rpm (rocky9_nocuda) (push) Successful in 11m54s
Build Packages / build:rpm (ubuntu2404_nocuda) (push) Successful in 8m20s
Build Packages / Generate python client (push) Successful in 24s
Build Packages / Build documentation (push) Successful in 56s
Build Packages / Create release (push) Has been skipped
Build Packages / build:rpm (rocky8) (push) Successful in 8m51s
Build Packages / build:rpm (rocky8_sls9) (push) Successful in 9m9s
Build Packages / build:rpm (ubuntu2204) (push) Successful in 8m53s
Build Packages / build:rpm (ubuntu2404) (push) Successful in 8m21s
Build Packages / build:rpm (rocky9) (push) Successful in 9m47s
Build Packages / Unit tests (push) Successful in 1h13m38s
This is an UNSTABLE release and not recommended for production use (please use rc.111 instead). * jfjoch_broker: Improve handling of rotation indexing * jfjoch_broker: More information saved in CBOR end message (WIP) * jfjoch_writer: Save rotation indexing lattice parameters and Niggli class * jfjoch_viewer: Remove (for now) primitive cell information Reviewed-on: #19 Co-authored-by: Filip Leonarski <filip.leonarski@psi.ch> Co-committed-by: Filip Leonarski <filip.leonarski@psi.ch>
128 lines
4.1 KiB
C++
128 lines
4.1 KiB
C++
// SPDX-FileCopyrightText: 2024 Filip Leonarski, Paul Scherrer Institute <filip.leonarski@psi.ch>
|
|
// SPDX-License-Identifier: GPL-3.0-only
|
|
|
|
#ifndef JFJOCH_JFJOCHRECEIVER_H
|
|
#define JFJOCH_JFJOCHRECEIVER_H
|
|
|
|
#include <mutex>
|
|
#include <atomic>
|
|
#include <chrono>
|
|
|
|
#include "../common/DiffractionExperiment.h"
|
|
#include "../image_analysis/spot_finding/SpotFindingSettings.h"
|
|
#include "JFJochReceiverOutput.h"
|
|
#include "../image_puller/ZMQImagePuller.h"
|
|
#include "../common/ImageBuffer.h"
|
|
#include "../image_pusher/ImagePusher.h"
|
|
#include "../preview/ZMQPreviewSocket.h"
|
|
#include "../preview/ZMQMetadataSocket.h"
|
|
#include "../preview/PreviewImage.h"
|
|
#include "JFJochReceiverPlots.h"
|
|
#include "LossyFilter.h"
|
|
#include "../common/MovingAverage.h"
|
|
#include "../common/NUMAHWPolicy.h"
|
|
#include "../common/ScanResultGenerator.h"
|
|
#include "../image_analysis/indexing/IndexerThreadPool.h"
|
|
#include "../image_analysis/IndexAndRefine.h"
|
|
|
|
class JFJochReceiver {
|
|
protected:
|
|
Logger &logger;
|
|
|
|
DiffractionExperiment experiment;
|
|
|
|
SpotFindingSettings spot_finding_settings;
|
|
std::mutex spot_finding_settings_mutex;
|
|
SpotFindingSettings GetSpotFindingSettings();
|
|
|
|
std::atomic<bool> writer_queue_full{false};
|
|
std::atomic<bool> cancelled{false};
|
|
bool push_images_to_writer;
|
|
|
|
std::atomic<size_t> compressed_size{0};
|
|
std::atomic<uint64_t> uncompressed_size{0};
|
|
std::atomic<size_t> images_sent{0};
|
|
std::atomic<size_t> images_collected{0};
|
|
std::atomic<size_t> images_skipped{0};
|
|
|
|
std::chrono::time_point<std::chrono::system_clock> start_time;
|
|
std::chrono::time_point<std::chrono::system_clock> end_time;
|
|
|
|
int64_t max_image_number_sent = 0;
|
|
std::mutex max_image_number_sent_mutex;
|
|
void UpdateMaxImageSent(int64_t image_number);
|
|
|
|
int64_t max_image_number_received = 0;
|
|
std::mutex max_image_number_received_mutex;
|
|
void UpdateMaxImageReceived(int64_t image_number);
|
|
|
|
ImageBuffer &image_buffer;
|
|
ImagePusher &image_pusher;
|
|
|
|
PreviewImage &preview_image;
|
|
ZMQPreviewSocket *zmq_preview_socket;
|
|
ZMQMetadataSocket *zmq_metadata_socket;
|
|
|
|
JFJochReceiverCurrentStatus ¤t_status;
|
|
JFJochReceiverPlots &plots;
|
|
|
|
ScanResultGenerator scan_result;
|
|
|
|
LossyFilter serialmx_filter;
|
|
|
|
MovingAverage saturated_pixels{1000};
|
|
MovingAverage error_pixels{1000};
|
|
MovingAverage roi_beam_npixel{1000};
|
|
MovingAverage roi_beam_sum{1000};
|
|
|
|
NUMAHWPolicy numa_policy;
|
|
|
|
std::vector<std::unique_ptr<ADUHistogram>> adu_histogram_module;
|
|
PixelMask pixel_mask;
|
|
|
|
AzimuthalIntegration az_int_mapping;
|
|
|
|
std::optional<uint64_t> max_delay;
|
|
std::mutex max_delay_mutex;
|
|
|
|
IndexAndRefine indexer;
|
|
std::optional<CrystalLattice> rotation_indexing_lattice;
|
|
|
|
std::string writer_error;
|
|
|
|
void UpdateMaxDelay(uint64_t delay);
|
|
JFJochReceiverStatus GetStatus() const;
|
|
void SendStartMessage();
|
|
void SendEndMessage();
|
|
void SaveStartMessageToImageBuffer(const StartMessage &msg);
|
|
virtual void Cancel(const JFJochException &e);
|
|
public:
|
|
JFJochReceiver(const DiffractionExperiment& experiment,
|
|
ImageBuffer &image_buffer,
|
|
ImagePusher &image_pusher,
|
|
PreviewImage &preview_image,
|
|
JFJochReceiverCurrentStatus ¤t_status,
|
|
JFJochReceiverPlots &plots,
|
|
const SpotFindingSettings &spot_finding_settings,
|
|
Logger &logger,
|
|
const NUMAHWPolicy &numa_policy,
|
|
const PixelMask &pixel_mask,
|
|
ZMQPreviewSocket *zmq_preview_socket = nullptr,
|
|
ZMQMetadataSocket *zmq_metadata_socket = nullptr,
|
|
IndexerThreadPool *indexing_thread_pool = nullptr);
|
|
virtual ~JFJochReceiver();
|
|
|
|
virtual void StopReceiver() = 0;
|
|
|
|
virtual float GetEfficiency() const = 0;
|
|
virtual void Cancel(bool silent);
|
|
virtual float GetProgress() const = 0;
|
|
|
|
virtual void SetSpotFindingSettings(const SpotFindingSettings &spot_finding_settings) = 0;
|
|
|
|
virtual JFJochReceiverOutput GetFinalStatistics() const;
|
|
};
|
|
|
|
|
|
#endif //JFJOCH_JFJOCHRECEIVER_H
|