mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-06-07 13:58:40 +02:00
Move public interfaces to include folder
This commit is contained in:
@@ -0,0 +1,36 @@
|
||||
#ifndef PROCESSMANAGER_H
|
||||
#define PROCESSMANAGER_H
|
||||
|
||||
#include "WriterManager.hpp"
|
||||
#include "H5Format.hpp"
|
||||
#include "RingBuffer.hpp"
|
||||
#include "ZmqReceiver.hpp"
|
||||
#include <chrono>
|
||||
#include "date.h"
|
||||
|
||||
class ProcessManager
|
||||
{
|
||||
WriterManager& writer_manager;
|
||||
ZmqReceiver& receiver;
|
||||
RingBuffer& ring_buffer;
|
||||
const H5Format& format;
|
||||
|
||||
uint16_t rest_port;
|
||||
const std::string& bsread_rest_address;
|
||||
hsize_t frames_per_file;
|
||||
|
||||
public:
|
||||
ProcessManager(WriterManager& writer_manager,
|
||||
ZmqReceiver& receiver,
|
||||
RingBuffer& ring_buffer,
|
||||
const H5Format& format,
|
||||
uint16_t rest_port,
|
||||
const std::string& bsread_rest_address,
|
||||
hsize_t frames_per_file=0);
|
||||
|
||||
void receive_zmq();
|
||||
void run_receivers(uint8_t n_receiving_threads);
|
||||
|
||||
};
|
||||
|
||||
#endif
|
||||
Reference in New Issue
Block a user