mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-13 08:41:16 +00:00
231c7c8f7e
git-svn-id: https://subversion.gsi.de/fairroot/fairbase/trunk@20162 0381ead4-6506-0410-b988-94b70fbc4730
75 lines
2.0 KiB
C++
75 lines
2.0 KiB
C++
/**
|
|
* FairMQDevice.h
|
|
*
|
|
* @since Oct 25, 2012
|
|
* @authors: D. Klein
|
|
*/
|
|
|
|
#ifndef FAIRMQDEVICE_H_
|
|
#define FAIRMQDEVICE_H_
|
|
|
|
#include "FairMQConfigurable.h"
|
|
#include "FairMQStateMachine.h"
|
|
#include <vector>
|
|
#include "FairMQContext.h"
|
|
#include "FairMQSocket.h"
|
|
#include <stdexcept>
|
|
//#include "FairMQLogger.h"
|
|
#include "Rtypes.h"
|
|
#include "TString.h"
|
|
|
|
|
|
class FairMQDevice : /*public FairMQStateMachine,*/ public FairMQConfigurable
|
|
{
|
|
protected:
|
|
TString fId;
|
|
Int_t fNumIoThreads;
|
|
FairMQContext* fPayloadContext;
|
|
std::vector<TString> *fBindAddress;
|
|
std::vector<Int_t> *fBindSocketType;
|
|
std::vector<Int_t> *fBindSndBufferSize;
|
|
std::vector<Int_t> *fBindRcvBufferSize;
|
|
std::vector<TString> *fConnectAddress;
|
|
std::vector<Int_t> *fConnectSocketType;
|
|
std::vector<Int_t> *fConnectSndBufferSize;
|
|
std::vector<Int_t> *fConnectRcvBufferSize;
|
|
std::vector<FairMQSocket*> *fPayloadInputs;
|
|
std::vector<FairMQSocket*> *fPayloadOutputs;
|
|
Int_t fLogIntervalInMs;
|
|
Int_t fNumInputs;
|
|
Int_t fNumOutputs;
|
|
public:
|
|
enum {
|
|
Id = FairMQConfigurable::Last,
|
|
NumIoThreads,
|
|
NumInputs,
|
|
NumOutputs,
|
|
BindAddress,
|
|
BindSocketType,
|
|
BindSndBufferSize,
|
|
BindRcvBufferSize,
|
|
ConnectAddress,
|
|
ConnectSocketType,
|
|
ConnectSndBufferSize,
|
|
ConnectRcvBufferSize,
|
|
LogIntervalInMs,
|
|
Last
|
|
};
|
|
FairMQDevice();
|
|
virtual void Init();
|
|
virtual void Bind();
|
|
virtual void Connect();
|
|
virtual void Run();
|
|
virtual void Pause();
|
|
virtual void Shutdown();
|
|
virtual void* LogSocketRates();
|
|
static void* callLogSocketRates(void* arg) { return ((FairMQDevice*)arg)->LogSocketRates(); }
|
|
virtual void SetProperty(Int_t key, TString value, Int_t slot = 0);
|
|
virtual TString GetProperty(Int_t key, TString default_ = "", Int_t slot = 0);
|
|
virtual void SetProperty(Int_t key, Int_t value, Int_t slot = 0);
|
|
virtual Int_t GetProperty(Int_t key, Int_t default_ = 0, Int_t slot = 0);
|
|
virtual ~FairMQDevice();
|
|
};
|
|
|
|
#endif /* FAIRMQDEVICE_H_ */
|