|
| RawDataSaverConsumer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, const ConfigurationTree &theXDAQContextConfigTree, const std::string &configurationPath) |
|
| RawDataSaverConsumerBase (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, const ConfigurationTree &theXDAQContextConfigTree, const std::string &configurationPath) |
|
| DataConsumer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, ConsumerPriority priority) |
|
virtual void | registerToBuffer (void) |
| mirror DataProducerBase::registerToBuffer
|
|
virtual void | configure (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) |
|
| WorkLoop (const std::string &name) |
|
void | startWorkLoop (void) |
|
bool | stopWorkLoop (void) |
|
bool | isActive (void) const |
|
| Configurable (const ConfigurationTree &theXDAQContextConfigTree, const std::string &theConfigurationPath) |
|
ConfigurationTree | getSelfNode () const |
|
const ConfigurationManager * | getConfigurationManager () const |
|
const std::string & | getContextUID () const |
|
const std::string & | getApplicationUID () const |
|
unsigned int | getApplicationLID () const |
|
std::string | getContextAddress () const |
|
unsigned int | getContextPort () const |
|
|
enum | ConsumerPriority { LowConsumerPriority
, HighConsumerPriority
} |
|
virtual void | openFile (std::string runNumber) |
|
virtual void | closeFile (void) |
|
virtual void | save (const std::string &data) |
|
virtual void | writeHeader (void) |
|
virtual void | writeFooter (void) |
|
virtual void | writePacketHeader (const std::string &) |
|
virtual void | writePacketFooter (const std::string &) |
|
virtual void | startProcessingData (std::string runNumber) override |
|
virtual void | stopProcessingData (void) override |
|
virtual bool | workLoopThread (toolbox::task::WorkLoop *workLoop) override |
|
virtual void | fastRead (void) |
|
virtual void | slowRead (void) |
|
const std::string & | getWorkLoopName (void) const |
| Getters.
|
|
std::ofstream | outFile_ |
|
std::string * | dataP_ |
| For fast read.
|
|
std::map< std::string, std::string > * | headerP_ |
|
std::string | data_ |
| For slow read.
|
|
std::map< std::string, std::string > | header_ |
|
std::string | filePath_ |
|
std::string | fileRadix_ |
|
long | maxFileSize_ |
|
std::string | currentRunNumber_ |
|
unsigned int | currentSubRunNumber_ |
|
const std::string | supervisorApplicationUID_ |
|
const std::string | bufferUID_ |
|
const std::string | processorUID_ |
|
CircularBufferBase * | theCircularBuffer_ |
|
volatile bool | continueWorkLoop_ |
|
const ConfigurationTree | theXDAQContextConfigTree_ |
|
const std::string | theConfigurationPath_ |
|
const std::string | theConfigurationRecordName_ |
|
Definition at line 13 of file RawDataSaverConsumer.h.