28 lines
1.1 KiB
C++
28 lines
1.1 KiB
C++
// Copyright (2019-2024) Paul Scherrer Institute
|
|
|
|
#ifndef JUNGFRAUJOCH_ZMQSTREAM2PUSHERGROUP_H
|
|
#define JUNGFRAUJOCH_ZMQSTREAM2PUSHERGROUP_H
|
|
|
|
#include "ImagePusher.h"
|
|
#include "ZMQStream2Pusher.h"
|
|
#include "../common/ZMQWrappers.h"
|
|
|
|
class ZMQStream2PusherGroup : public ImagePusher {
|
|
std::vector<std::unique_ptr<ZMQStream2Pusher>> pusher;
|
|
int64_t file_count = 1;
|
|
public:
|
|
ZMQStream2PusherGroup(ZMQContext &context, const std::vector<std::string>& addr,
|
|
int32_t send_buffer_high_watermark = -1, int32_t send_buffer_size = -1);
|
|
// High performance implementation, where each socket has dedicated ZMQ context
|
|
explicit ZMQStream2PusherGroup(const std::vector<std::string>& addr,
|
|
int32_t send_buffer_high_watermark = -1, int32_t send_buffer_size = -1);
|
|
|
|
void StartDataCollection(const StartMessage& message) override;
|
|
bool SendImage(const DataMessage& message) override;
|
|
bool EndDataCollection(const EndMessage& message) override;
|
|
|
|
std::vector<std::string> GetAddress();
|
|
};
|
|
|
|
#endif //JUNGFRAUJOCH_ZMQSTREAM2PUSHERGROUP_H
|