mirror of
https://github.com/slsdetectorgroup/slsDetectorPackage.git
synced 2026-02-06 11:48:40 +01:00
Dhanya Thattil
7494e41862
* wip: draft of frame synchronizer, semaphores not done yet * signal handler not affecting semaphore inside lambda function * finally works with sem * install targets cmake error fix * reducing the number of data call backs. incoming from developer * WIP: of synchronisation (#969) * WIP of synchronisation * working so far if everything goes right * added all information into json headers * valid json * allow frame synchronizer to have access to static libzmq when compiling on conda (libzeromq-devel not installed by default * upto date with multirecieverapp for invalid arguments and help * formatting * remove warnings * changes to print * removed prints * no need for print frames to be called * minor * commnet * adding json header in start callback, imagesize in data callback and formatted * fixed sanitizer issues. 1 left for ctrl+C - zmq_msg_t should be deleted, not freed. Same with the char arrays and semaphores. * fixed sanitizer issues and made it more readable * moving clearing old frames to new startacq just in case it has to process soem frames before the callback * created a callback mutex to register the callbacks when using threads for different Receiver objects instead of child processes, remove the clean up of the frames (deleting from a signal is thread unsafe) from the siginterrupt handler, reading or setting terminate should also be inside the mutex, pass receiver object index so that only the first one cleans up the shared structure --------- Co-authored-by: Felix Engelmann <felix-github@nlogn.org>
202 lines
8.4 KiB
C++
202 lines
8.4 KiB
C++
// SPDX-License-Identifier: LGPL-3.0-or-other
|
|
// Copyright (C) 2021 Contributors to the SLS Detector Package
|
|
#pragma once
|
|
#include "Implementation.h"
|
|
#include "receiver_defs.h"
|
|
#include "sls/ServerSocket.h"
|
|
#include "sls/sls_detector_defs.h"
|
|
#include "sls/sls_detector_funcs.h"
|
|
|
|
#include <atomic>
|
|
#include <future>
|
|
|
|
namespace sls {
|
|
|
|
class ServerInterface;
|
|
|
|
class ClientInterface : private virtual slsDetectorDefs {
|
|
enum numberMode { DEC, HEX };
|
|
detectorType detType;
|
|
uint16_t portNumber{0};
|
|
ServerSocket server;
|
|
std::unique_ptr<Implementation> receiver;
|
|
std::unique_ptr<std::thread> tcpThread;
|
|
int ret{OK};
|
|
int fnum{-1};
|
|
int lockedByClient{0};
|
|
|
|
std::atomic<bool> killTcpThread{false};
|
|
|
|
public:
|
|
virtual ~ClientInterface();
|
|
ClientInterface(uint16_t portNumber = DEFAULT_TCP_RX_PORTNO);
|
|
std::string getReceiverVersion();
|
|
|
|
//***callback functions***
|
|
/** params: file path, file name, file index, image size */
|
|
void registerCallBackStartAcquisition(int (*func)(const startCallbackHeader,
|
|
void *),
|
|
void *arg);
|
|
|
|
/** params: total frames caught */
|
|
void registerCallBackAcquisitionFinished(
|
|
void (*func)(const endCallbackHeader, void *), void *arg);
|
|
|
|
/** params: sls_receiver_header, pointer to data, image size */
|
|
void registerCallBackRawDataReady(void (*func)(sls_receiver_header &,
|
|
const dataCallbackHeader,
|
|
char *, size_t &, void *),
|
|
void *arg);
|
|
|
|
private:
|
|
void startTCPServer();
|
|
int functionTable();
|
|
int decodeFunction(ServerInterface &socket);
|
|
void functionNotImplemented();
|
|
void modeNotImplemented(const std::string &modename, int mode);
|
|
template <typename T>
|
|
void validate(T arg, T retval, const std::string &modename, numberMode hex);
|
|
void verifyLock();
|
|
void verifyIdle(ServerInterface &socket);
|
|
|
|
int lock_receiver(ServerInterface &socket);
|
|
int get_last_client_ip(ServerInterface &socket);
|
|
int get_version(ServerInterface &socket);
|
|
int setup_receiver(ServerInterface &socket);
|
|
void setDetectorType(detectorType arg);
|
|
int set_detector_roi(ServerInterface &socket);
|
|
int set_num_frames(ServerInterface &socket);
|
|
int set_num_triggers(ServerInterface &socket);
|
|
int set_num_bursts(ServerInterface &socket);
|
|
int set_num_add_storage_cells(ServerInterface &socket);
|
|
int set_timing_mode(ServerInterface &socket);
|
|
int set_burst_mode(ServerInterface &socket);
|
|
int set_num_analog_samples(ServerInterface &socket);
|
|
int set_num_digital_samples(ServerInterface &socket);
|
|
int set_exptime(ServerInterface &socket);
|
|
int set_period(ServerInterface &socket);
|
|
int set_subexptime(ServerInterface &socket);
|
|
int set_subdeadtime(ServerInterface &socket);
|
|
int set_dynamic_range(ServerInterface &socket);
|
|
int set_streaming_frequency(ServerInterface &socket);
|
|
int get_streaming_frequency(ServerInterface &socket);
|
|
int get_status(ServerInterface &socket);
|
|
int start_receiver(ServerInterface &socket);
|
|
int stop_receiver(ServerInterface &socket);
|
|
int set_file_dir(ServerInterface &socket);
|
|
int get_file_dir(ServerInterface &socket);
|
|
int set_file_name(ServerInterface &socket);
|
|
int get_file_name(ServerInterface &socket);
|
|
int set_file_index(ServerInterface &socket);
|
|
int get_file_index(ServerInterface &socket);
|
|
int get_frame_index(ServerInterface &socket);
|
|
int get_missing_packets(ServerInterface &socket);
|
|
int get_frames_caught(ServerInterface &socket);
|
|
int set_file_write(ServerInterface &socket);
|
|
int get_file_write(ServerInterface &socket);
|
|
int set_master_file_write(ServerInterface &socket);
|
|
int get_master_file_write(ServerInterface &socket);
|
|
int enable_compression(ServerInterface &socket);
|
|
int set_overwrite(ServerInterface &socket);
|
|
int get_overwrite(ServerInterface &socket);
|
|
int enable_tengiga(ServerInterface &socket);
|
|
int set_fifo_depth(ServerInterface &socket);
|
|
int set_activate(ServerInterface &socket);
|
|
int set_streaming(ServerInterface &socket);
|
|
int get_streaming(ServerInterface &socket);
|
|
int set_streaming_timer(ServerInterface &socket);
|
|
int get_flip_rows(ServerInterface &socket);
|
|
int set_flip_rows(ServerInterface &socket);
|
|
int set_file_format(ServerInterface &socket);
|
|
int get_file_format(ServerInterface &socket);
|
|
int set_streaming_port(ServerInterface &socket);
|
|
int get_streaming_port(ServerInterface &socket);
|
|
int set_silent_mode(ServerInterface &socket);
|
|
int get_silent_mode(ServerInterface &socket);
|
|
int restream_stop(ServerInterface &socket);
|
|
int set_additional_json_header(ServerInterface &socket);
|
|
int get_additional_json_header(ServerInterface &socket);
|
|
int set_udp_socket_buffer_size(ServerInterface &socket);
|
|
int get_real_udp_socket_buffer_size(ServerInterface &socket);
|
|
int set_frames_per_file(ServerInterface &socket);
|
|
int get_frames_per_file(ServerInterface &socket);
|
|
int set_discard_policy(ServerInterface &socket);
|
|
int get_discard_policy(ServerInterface &socket);
|
|
int set_padding_enable(ServerInterface &socket);
|
|
int get_padding_enable(ServerInterface &socket);
|
|
int set_readout_mode(ServerInterface &socket);
|
|
int set_adc_mask(ServerInterface &socket);
|
|
int set_dbit_list(ServerInterface &socket);
|
|
int get_dbit_list(ServerInterface &socket);
|
|
int set_dbit_offset(ServerInterface &socket);
|
|
int get_dbit_offset(ServerInterface &socket);
|
|
int set_quad_type(ServerInterface &socket);
|
|
int set_read_n_rows(ServerInterface &socket);
|
|
MacAddr setUdpIp(IpAddr arg);
|
|
int set_udp_ip(ServerInterface &socket);
|
|
MacAddr setUdpIp2(IpAddr arg);
|
|
int set_udp_ip2(ServerInterface &socket);
|
|
int set_udp_port(ServerInterface &socket);
|
|
int set_udp_port2(ServerInterface &socket);
|
|
int set_num_interfaces(ServerInterface &socket);
|
|
int set_adc_mask_10g(ServerInterface &socket);
|
|
int set_counter_mask(ServerInterface &socket);
|
|
int increment_file_index(ServerInterface &socket);
|
|
int set_additional_json_parameter(ServerInterface &socket);
|
|
int get_additional_json_parameter(ServerInterface &socket);
|
|
int get_progress(ServerInterface &socket);
|
|
int set_num_gates(ServerInterface &socket);
|
|
int set_gate_delay(ServerInterface &socket);
|
|
int get_thread_ids(ServerInterface &socket);
|
|
int get_streaming_start_fnum(ServerInterface &socket);
|
|
int set_streaming_start_fnum(ServerInterface &socket);
|
|
int set_rate_correct(ServerInterface &socket);
|
|
int set_scan(ServerInterface &socket);
|
|
int set_threshold(ServerInterface &socket);
|
|
int get_streaming_hwm(ServerInterface &socket);
|
|
int set_streaming_hwm(ServerInterface &socket);
|
|
int set_all_threshold(ServerInterface &socket);
|
|
int set_detector_datastream(ServerInterface &socket);
|
|
int get_arping(ServerInterface &socket);
|
|
int set_arping(ServerInterface &socket);
|
|
int get_receiver_roi(ServerInterface &socket);
|
|
int set_receiver_roi(ServerInterface &socket);
|
|
int set_receiver_roi_metadata(ServerInterface &socket);
|
|
int set_num_transceiver_samples(ServerInterface &socket);
|
|
int set_transceiver_mask(ServerInterface &socket);
|
|
int set_row(ServerInterface &socket);
|
|
int set_column(ServerInterface &socket);
|
|
|
|
Implementation *impl() {
|
|
if (receiver != nullptr) {
|
|
return receiver.get();
|
|
} else {
|
|
throw SocketError(
|
|
"Receiver not set up. Please use rx_hostname first.\n");
|
|
}
|
|
}
|
|
|
|
int (ClientInterface::*flist[NUM_REC_FUNCTIONS])(ServerInterface &socket);
|
|
|
|
//***callback parameters***
|
|
|
|
int (*startAcquisitionCallBack)(const startCallbackHeader,
|
|
void *) = nullptr;
|
|
void *pStartAcquisition{nullptr};
|
|
void (*acquisitionFinishedCallBack)(const endCallbackHeader,
|
|
void *) = nullptr;
|
|
void *pAcquisitionFinished{nullptr};
|
|
void (*rawDataReadyCallBack)(sls_receiver_header &, dataCallbackHeader,
|
|
char *, size_t &, void *) = nullptr;
|
|
void *pRawDataReady{nullptr};
|
|
|
|
pid_t parentThreadId{0};
|
|
pid_t tcpThreadId{0};
|
|
std::vector<std::string> udpips =
|
|
std::vector<std::string>(MAX_NUMBER_OF_LISTENING_THREADS);
|
|
// necessary if Receiver objects using threads with callbacks
|
|
static std::mutex callbackMutex;
|
|
};
|
|
|
|
} // namespace sls
|