otsdaq  v2_05_02_indev
ots::DataManager Class Reference
Inheritance diagram for ots::DataManager:
ots::Configurable ots::VStateMachine ots::ARTDAQDataManager

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 ConfigurationManagergetConfigurationManager () 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
CoreSupervisorBaseparentSupervisor_
 

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, Bufferbuffers_
 
- 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_
 

Detailed Description

Definition at line 25 of file DataManager.h.

Member Function Documentation

void DataManager::startAllBuffers ( const std::string &  runNumber)
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.


The documentation for this class was generated from the following files: