|
|
| DQMHistosConsumerBase (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, ConsumerPriority) |
| |
|
std::mutex & | getFillHistoMutex (void) |
| |
|
virtual void | book (void) |
| |
|
virtual void | fill (std::string &, std::map< std::string, std::string >) |
| |
|
virtual void | load (std::string) |
| |
|
void | setDataManager (VisualDataManager *dataManager) |
| |
|
TObject * | get (std::string name) |
| |
|
TFile * | getFile (void) |
| |
|
| DataConsumer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, ConsumerPriority priority) |
| |
|
virtual void | registerToBuffer (void) |
| | mirror DataProducerBase::registerToBuffer
|
| |
|
virtual void | configure (void) |
| |
| virtual void | startProcessingData (std::string runNumber) |
| |
|
virtual void | stopProcessingData (void) |
| |
|
template<class D , class H > |
| int | read (D &buffer, H &header) |
| | Copies the buffer into the passed parameters.
|
| |
|
template<class D , class H > |
| int | read (D *&buffer, H *&header) |
| | Fast version where you point to the buffer without copying.
|
| |
|
template<class D , class H > |
| int | setReadSubBuffer (void) |
| |
|
template<class D , class H > |
| int | read (D &buffer) |
| |
|
ConsumerPriority | getPriority (void) |
| |
|
| DataProcessor (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID) |
| |
|
virtual void | pauseProcessingData (void) |
| |
|
virtual void | resumeProcessingData (void) |
| |
|
const std::string & | getProcessorID (void) const |
| | Getters.
|
| |
|
void | setCircularBuffer (CircularBufferBase *circularBuffer) |
| |
| uint64_t | getStatPackets (void) const |
| |
|
uint64_t | getStatBytes (void) const |
| |
|
uint64_t | getStatErrors (void) const |
| |
|
uint64_t | getStatBusyNanos (void) const |
| |
|
virtual std::map< std::string, std::string > | getExtraStatus (void) const |
| | Plugin-specific status items (e.g. socket backlog) as name/value strings.
|
| |
|
| WorkLoop (const std::string &name) |
| |
|
void | startWorkLoop (void) |
| |
|
bool | stopWorkLoop (void) |
| |
|
bool | isActive (void) const |
| |
|
| enum | ConsumerPriority { LowConsumerPriority
, HighConsumerPriority
} |
| |
|
void | setAutoSave (bool autoSave) |
| | Default is true.
|
| |
|
bool | isFileOpen (void) |
| |
|
virtual void | save (void) |
| |
|
virtual void | openFile (std::string fileName) |
| |
|
virtual void | closeFile (void) |
| |
|
virtual void | autoSave (bool force=false) |
| | The file will be saved if force == true or currentTime - beginTimeTime_ is >= autoSaveInterval_.
|
| |
|
virtual void | setAutoSaveInterval (unsigned int interval) |
| |
|
void | countPacket (uint64_t bytes) |
| |
|
void | countError (void) |
| |
|
void | countBusyNanos (uint64_t nanos) |
| |
|
virtual bool | workLoopThread (toolbox::task::WorkLoop *workLoop)=0 |
| |
|
const std::string & | getWorkLoopName (void) const |
| | Getters.
|
| |
Definition at line 11 of file DQMHistosConsumerBase.h.