otsdaq
v2_05_02_indev
|
Classes | |
struct | Buffer |
Public Member Functions | |
DataManager (const ConfigurationTree &theXDAQContextConfigTree, const std::string &supervisorConfigurationPath) | |
virtual void | configure (void) |
virtual void | halt (void) |
virtual void | pause (void) |
virtual void | resume (void) |
virtual void | start (std::string runNumber) |
virtual void | stop (void) |
template<class D , class H > | |
void | configureBuffer (const std::string &bufferUID) |
void | registerProducer (const std::string &bufferUID, DataProducerBase *producer) |
void | registerConsumer (const std::string &bufferUID, DataConsumer *consumer) |
void | unregisterFEProducer (const std::string &bufferID, const std::string &feProducerID) |
void | dumpStatus (std::ostream *out=(std::ostream *)&(std::cout)) const |
const std::map< std::string, Buffer > & | getBuffers (void) const |
Public Member Functions inherited from ots::Configurable | |
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 |
Public Member Functions inherited from ots::VStateMachine | |
VStateMachine (const std::string &name) | |
virtual bool | running (void) |
virtual void | paused (void) |
virtual void | halted (void) |
virtual void | configured (void) |
virtual void | initial (void) |
virtual void | inError (void) |
virtual std::string | getStatusProgressDetail (void) |
void | setTransitionName (const std::string &transitionName) |
const std::string & | getTransitionName (void) |
void | setIterationIndex (unsigned int i) |
void | setSubIterationIndex (unsigned int i) |
unsigned int | getIterationIndex (void) |
unsigned int | getSubIterationIndex (void) |
void | indicateIterationWork (void) |
void | clearIterationWork (void) |
bool | getIterationWork (void) |
void | indicateSubIterationWork (void) |
void | clearSubIterationWork (void) |
bool | getSubIterationWork (void) |
Public Attributes | |
bool | parentSupervisorHasFrontends_ |
Public Attributes inherited from ots::VStateMachine | |
CoreSupervisorBase * | parentSupervisor_ |
Protected Types | |
enum | BufferStatus { Initialized, Running } |
Protected Member Functions | |
void | destroyBuffers (void) |
void | startAllBuffers (const std::string &runNumber) |
void | stopAllBuffers (void) |
void | resumeAllBuffers (void) |
void | pauseAllBuffers (void) |
void | startBuffer (const std::string &bufferUID, std::string runNumber) |
void | stopBuffer (const std::string &bufferUID) |
void | resumeBuffer (const std::string &bufferUID) |
void | pauseBuffer (const std::string &bufferUID) |
Protected Attributes | |
std::map< std::string, Buffer > | buffers_ |
Protected Attributes inherited from ots::Configurable | |
const ConfigurationTree | theXDAQContextConfigTree_ |
const std::string | theConfigurationPath_ |
const std::string | theConfigurationRecordName_ |
Protected Attributes inherited from ots::VStateMachine | |
std::map< std::string, std::map< unsigned int, std::string > > | iterationAliasMap_ |
std::map< std::string, std::map< unsigned int, std::string > > | subIterationAliasMap_ |
Definition at line 25 of file DataManager.h.
|
protected |
!!!!Delete all Buffers and all the pointers of the producers and consumers
Definition at line 654 of file DataManager.cc.
void DataManager::unregisterFEProducer | ( | const std::string & | bufferID, |
const std::string & | feProducerID | ||
) |
{__CFG_SS__; dumpStatus((std::ostream*)&ss); __CFG_COUT__ << ss.str() <<
E;} {CFG_SS; dumpStatus((std::ostream*)&ss); CFG_COUT << ss.str() < E;}
Definition at line 542 of file DataManager.cc.