#include <DQMEventStore.h>
Public Member Functions | |
void | addDQMEvent (EventType const &) |
void | clear () |
bool | doProcessCompletedTopLevelFolders () |
DQMEventStore (xdaq::ApplicationDescriptor *, DQMEventQueueCollectionPtr, DQMEventMonitorCollection &, ConnectionType *, size_t(ConnectionType::*getExpectedUpdatesCount)() const, StateMachineType *, void(StateMachineType::*moveToFailedState)(xcept::Exception &), AlarmHandlerPtr) | |
bool | empty () |
void | moveToFailedState (xcept::Exception &sentinelException) |
void | purge () |
void | setParameters (DQMProcessingParams const &) |
~DQMEventStore () | |
Private Types | |
typedef std::map< DQMKey, DQMTopLevelFolderPtr > | DQMTopLevelFolderMap |
Private Member Functions | |
void | addDQMEventToReadyToServe (EventType const &) |
void | addDQMEventToStore (EventType const &) |
DQMEventStore (DQMEventStore const &) | |
template<> | |
DQMEventMsgView | getDQMEventView (I2OChain const &dqmEvent) |
DQMEventMsgView | getDQMEventView (EventType const &) |
bool | getNextReadyTopLevelFolder (DQMTopLevelFolderPtr &) |
bool | handleNextCompletedTopLevelFolder () |
DQMTopLevelFolderPtr | makeDQMTopLevelFolder (EventType const &) |
DQMEventStore & | operator= (DQMEventStore const &) |
void | stopProcessingCompletedTopLevelFolders () |
Static Private Member Functions | |
static void | processCompletedTopLevelFolders (void *arg) |
Private Attributes | |
AlarmHandlerPtr | alarmHandler_ |
xdaq::ApplicationDescriptor * | appDescriptor_ |
TThread * | completedFolderThread_ |
ConnectionType * | connectionType_ |
DQMEventMonitorCollection & | dqmEventMonColl_ |
DQMEventQueueCollectionPtr | dqmEventQueueCollection_ |
DQMProcessingParams | dqmParams_ |
size_t(ConnectionType::* | getExpectedUpdatesCount_ )() const |
void(StateMachineType::* | moveToFailedState_ )(xcept::Exception &) |
bool | processCompletedTopLevelFolders_ |
StateMachineType * | stateMachineType_ |
DQMTopLevelFolderMap | store_ |
std::vector< unsigned char > | tempEventArea_ |
Static Private Attributes | |
static boost::mutex | storeMutex_ |
Stores and collates DQM events Note that this code is not thread safe as it uses a class wide temporary buffer to convert I2OChains into DQMEventMsgViews.
Definition at line 42 of file DQMEventStore.h.
|
private |
Definition at line 121 of file DQMEventStore.h.
stor::DQMEventStore< EventType, ConnectionType, StateMachineType >::DQMEventStore | ( | xdaq::ApplicationDescriptor * | , |
DQMEventQueueCollectionPtr | , | ||
DQMEventMonitorCollection & | , | ||
ConnectionType * | , | ||
size_t(ConnectionType::*)() const | getExpectedUpdatesCount, | ||
StateMachineType * | , | ||
void(StateMachineType::*)(xcept::Exception &) | moveToFailedState, | ||
AlarmHandlerPtr | |||
) |
stor::DQMEventStore< EventType, ConnectionType, StateMachineType >::~DQMEventStore | ( | ) |
|
private |
void stor::DQMEventStore< EventType, ConnectionType, StateMachineType >::addDQMEvent | ( | EventType const & | ) |
Adds the DQM event found in EventType to the store. If a matching DQMEventRecord is found, the histograms are added unless collateDQM is false.
|
private |
|
private |
void stor::DQMEventStore< EventType, ConnectionType, StateMachineType >::clear | ( | ) |
Clears all data hold by the DQM event store
Referenced by Vispa.Views.WidgetView.WidgetView::closeEvent(), Vispa.Views.BoxDecayView.BoxDecayView::closeEvent(), Vispa.Share.FindAlgorithm.FindAlgorithm::findUsingFindDialog(), Vispa.Views.LineDecayView.LineDecayView::setDataObjects(), Vispa.Views.WidgetView.WidgetView::setDataObjects(), Vispa.Views.TreeView.TreeView::updateContent(), Vispa.Views.TableView.TableView::updateContent(), Vispa.Views.BoxDecayView.BoxDecayView::updateContent(), and Vispa.Views.PropertyView.PropertyView::updateContent().
|
inline |
Definition at line 92 of file DQMEventStore.h.
|
inline |
Checks if the DQM event store is empty
Definition at line 86 of file DQMEventStore.h.
Referenced by Vispa.Gui.VispaWidget.TextField::setAutosizeFont(), and Vispa.Gui.VispaWidget.TextField::setAutotruncate().
|
private |
Definition at line 24 of file DQMEventProcessor.cc.
References stor::I2OChain::copyFragmentsIntoBuffer().
|
private |
|
private |
|
private |
|
private |
|
inline |
Definition at line 89 of file DQMEventStore.h.
|
private |
|
staticprivate |
void stor::DQMEventStore< EventType, ConnectionType, StateMachineType >::purge | ( | ) |
Process completed top level folders, then clear the DQM event store
void stor::DQMEventStore< EventType, ConnectionType, StateMachineType >::setParameters | ( | DQMProcessingParams const & | ) |
Set the DQMProcessingParams to be used. This clears everything in the store.
|
private |
|
private |
Definition at line 119 of file DQMEventStore.h.
|
private |
Definition at line 111 of file DQMEventStore.h.
|
private |
Definition at line 125 of file DQMEventStore.h.
|
private |
Definition at line 115 of file DQMEventStore.h.
|
private |
Definition at line 114 of file DQMEventStore.h.
|
private |
Definition at line 113 of file DQMEventStore.h.
|
private |
Definition at line 112 of file DQMEventStore.h.
|
private |
Definition at line 116 of file DQMEventStore.h.
|
private |
Definition at line 118 of file DQMEventStore.h.
|
private |
Definition at line 126 of file DQMEventStore.h.
|
private |
Definition at line 117 of file DQMEventStore.h.
|
private |
Definition at line 122 of file DQMEventStore.h.
Referenced by stor::DQMEventStore< smproxy::DQMEventMsg, smproxy::EventRetriever< RegInfo, QueueCollectionPtr >, smproxy::StateMachine >::empty().
|
staticprivate |
Definition at line 123 of file DQMEventStore.h.
|
private |
Definition at line 128 of file DQMEventStore.h.