|
|
|
| typedef boost::shared_ptr<AlarmHandler> stor::AlarmHandlerPtr |
Definition at line 116 of file AlarmHandler.h.
| typedef ConcurrentQueue<EventPtr_t> stor::CommandQueue |
Definition at line 22 of file CommandQueue.h.
| typedef boost::shared_ptr<CommandQueue> stor::CommandQueuePtr |
Definition at line 23 of file CommandQueue.h.
| typedef boost::shared_ptr<Configuration> stor::ConfigurationPtr |
Definition at line 406 of file Configuration.h.
| typedef boost::shared_ptr<CurlInterface> stor::CurlInterfacePtr |
Definition at line 71 of file CurlInterface.h.
| typedef boost::shared_ptr<DbFileHandler> stor::DbFileHandlerPtr |
Definition at line 71 of file DbFileHandler.h.
| typedef boost::shared_ptr<DiscardManager> stor::DiscardManagerPtr |
Definition at line 108 of file DiscardManager.h.
| typedef boost::shared_ptr<DiskWriterResources> stor::DiskWriterResourcesPtr |
Definition at line 128 of file DiskWriterResources.h.
| typedef boost::shared_ptr<stor::DQMEventConsumerRegistrationInfo> stor::DQMEventConsRegPtr |
Definition at line 85 of file DQMEventConsumerRegistrationInfo.h.
| typedef boost::shared_ptr<DQMEventProcessorResources> stor::DQMEventProcessorResourcesPtr |
Definition at line 102 of file DQMEventProcessorResources.h.
| typedef ConcurrentQueue< I2OChain, KeepNewest<I2OChain> > stor::DQMEventQueue |
Queue holding I2OChains of complete DQM events (histograms) waiting to be processed by the DQMEventProcessor
Definition at line 22 of file DQMEventQueue.h.
A collection of ConcurrentQueue<DQMEventRecord>.
Definition at line 21 of file DQMEventQueueCollection.h.
| typedef boost::shared_ptr<DQMEventQueueCollection> stor::DQMEventQueueCollectionPtr |
Definition at line 22 of file DQMEventQueueCollection.h.
| typedef boost::shared_ptr<DQMEventQueue> stor::DQMEventQueuePtr |
Definition at line 23 of file DQMEventQueue.h.
| typedef boost::shared_ptr<DQMTopLevelFolder> stor::DQMTopLevelFolderPtr |
Definition at line 186 of file DQMTopLevelFolder.h.
Definition at line 605 of file DataSenderMonitorCollection.cc.
| typedef std::vector<ErrorStreamConfigurationInfo> stor::ErrStrConfigList |
Definition at line 65 of file ErrorStreamConfigurationInfo.h.
| typedef boost::shared_ptr<ErrStrConfigList> stor::ErrStrConfigListPtr |
Definition at line 66 of file ErrorStreamConfigurationInfo.h.
| typedef boost::shared_ptr<stor::EventConsumerRegistrationInfo> stor::EventConsRegPtr |
Definition at line 93 of file EventConsumerRegistrationInfo.h.
| typedef boost::shared_ptr<boost::statechart::event_base> stor::EventPtr_t |
Concurrent queue holding state machine events
Definition at line 21 of file CommandQueue.h.
A collection of ConcurrentQueue<I2OChain>.
Definition at line 21 of file EventQueueCollection.h.
| typedef boost::shared_ptr<EventQueueCollection> stor::EventQueueCollectionPtr |
Definition at line 22 of file EventQueueCollection.h.
| typedef std::vector<EventStreamConfigurationInfo> stor::EvtStrConfigList |
Definition at line 82 of file EventStreamConfigurationInfo.h.
| typedef boost::shared_ptr<EvtStrConfigList> stor::EvtStrConfigListPtr |
Definition at line 83 of file EventStreamConfigurationInfo.h.
| typedef ConcurrentQueue<I2OChain> stor::FragmentQueue |
Queue holding I2OChains of event fragments
Definition at line 21 of file FragmentQueue.h.
| typedef boost::shared_ptr<FragmentQueue> stor::FragmentQueuePtr |
Definition at line 22 of file FragmentQueue.h.
| typedef std::vector<unsigned char> stor::InitMsgBuffer |
This class is used to manage the unique set of INIT messages that have been received by the storage manager and will be sent to event consumers and written to output streams.
Definition at line 20 of file InitMsgCollection.h.
| typedef boost::shared_ptr<InitMsgCollection> stor::InitMsgCollectionPtr |
Definition at line 179 of file InitMsgCollection.h.
| typedef boost::shared_ptr<InitMsgBuffer> stor::InitMsgSharedPtr |
Definition at line 33 of file InitMsgCollection.h.
| typedef boost::shared_ptr<MonitoredQuantity> stor::MonitoredQuantityPtr |
Definition at line 256 of file MonitoredQuantity.h.
| typedef std::vector<QueueID> stor::QueueIDs |
| typedef boost::shared_ptr<RegistrationCollection> stor::RegistrationCollectionPtr |
Definition at line 99 of file RegistrationCollection.h.
| typedef ConcurrentQueue<RegPtr> stor::RegistrationQueue |
Concurrent queue holding consumer registrations
Definition at line 21 of file RegistrationQueue.h.
| typedef boost::shared_ptr<RegistrationQueue> stor::RegistrationQueuePtr |
Definition at line 22 of file RegistrationQueue.h.
| typedef boost::shared_ptr<RegistrationInfoBase> stor::RegPtr |
Definition at line 141 of file RegistrationInfoBase.h.
| typedef boost::shared_ptr<SharedResources> stor::SharedResourcesPtr |
Definition at line 65 of file SharedResources.h.
| typedef boost::shared_ptr<StateMachine> stor::StateMachinePtr |
Definition at line 587 of file StateMachine.h.
| typedef boost::shared_ptr<StatisticsReporter> stor::StatisticsReporterPtr |
Definition at line 203 of file StatisticsReporter.h.
| typedef size_t stor::StreamID |
Definition of the StreamID used in the storage manager
Definition at line 19 of file StreamID.h.
| typedef ConcurrentQueue<I2OChain> stor::StreamQueue |
Queue holding I2OChains of events to be written to disk
Definition at line 21 of file StreamQueue.h.
| typedef boost::shared_ptr<StreamQueue> stor::StreamQueuePtr |
Definition at line 22 of file StreamQueue.h.
| typedef boost::shared_ptr<TriggerSelector> stor::TriggerSelectorPtr |
Definition at line 162 of file TriggerSelector.h.
| bool stor::compareRBResultPtrValues | ( | DataSenderMonitorCollection::RBResultPtr | firstValue, |
| DataSenderMonitorCollection::RBResultPtr | secondValue | ||
| ) |
Definition at line 836 of file DataSenderMonitorCollection.cc.
Referenced by stor::SMWebPageHelper::addResourceBrokerList().
{
return *firstValue < *secondValue;
}
| std::ostream & stor::operator<< | ( | std::ostream & | os, |
| const ErrorStreamConfigurationInfo & | ci | ||
| ) |
Definition at line 20 of file ErrorStreamConfigurationInfo.cc.
{
os << "ErrorStreamConfigurationInfo:" << std::endl
<< " Stream label: " << ci.streamLabel() << std::endl
<< " Maximum file size, MB: " << ci.maxFileSizeMB() << std::endl
<< " Stream Id: " << ci.streamId() << std::endl;
return os;
}
| std::ostream & stor::operator<< | ( | std::ostream & | os, |
| RegistrationInfoBase const & | ri | ||
| ) |
Definition at line 173 of file RegistrationInfoBase.cc.
References stor::RegistrationInfoBase::consumerId(), stor::RegistrationInfoBase::consumerName(), stor::RegistrationInfoBase::queueId(), stor::RegistrationInfoBase::queuePolicy(), stor::RegistrationInfoBase::queueSize(), stor::RegistrationInfoBase::remoteHost(), stor::RegistrationInfoBase::secondsToStale(), and stor::RegistrationInfoBase::sourceURL().
{
os << "\n Consumer name: " << ri.consumerName()
<< "\n Consumer id: " << ri.consumerId()
<< "\n Source URL: " << ri.sourceURL()
<< "\n Remote Host: " << ri.remoteHost()
<< "\n Queue id: " << ri.queueId()
<< "\n Maximum size of queue: " << ri.queueSize()
<< "\n Policy used if queue is full: " << ri.queuePolicy()
<< "\n Time until queue becomes stale (seconds): " << ri.secondsToStale().total_seconds();
return os;
}
| std::ostream& stor::operator<< | ( | std::ostream & | os, |
| const QueueID & | queueId | ||
| ) | [inline] |
Definition at line 140 of file QueueID.h.
References stor::QueueID::index(), and stor::QueueID::policy().
{
os << "policy: " << queueId.policy() <<
" index: " << queueId.index();
return os;
}
| std::ostream & stor::operator<< | ( | std::ostream & | os, |
| const EventStreamConfigurationInfo & | ci | ||
| ) |
Definition at line 29 of file EventStreamConfigurationInfo.cc.
References i.
{
os << "EventStreamConfigurationInfo:" << std::endl
<< " Stream label: " << ci.streamLabel() << std::endl
<< " Maximum file size, MB: " << ci.maxFileSizeMB() << std::endl
<< " HLT output: " << ci.outputModuleLabel() << std::endl
<< " Fraction of events written to disk: " << ci.fractionToDisk() << std::endl
<< " Stream Id: " << ci.streamId() << std::endl;
os << " Event filters:";
if (ci.triggerSelection().size()) {
os << std::endl << ci.triggerSelection();
}
else
for( unsigned int i = 0; i < ci.eventSelection().size(); ++i )
{
os << std::endl << " " << ci.eventSelection()[i];
}
return os;
}
| std::ostream & stor::operator<< | ( | std::ostream & | os, |
| const TransitionRecord & | tr | ||
| ) |
Definition at line 23 of file TransitionRecord.cc.
References stor::TransitionRecord::isEntry(), stor::TransitionRecord::stateName(), and stor::TransitionRecord::timeStamp().
| std::ostream& stor::operator<< | ( | std::ostream & | os, |
| ConsumerID | id | ||
| ) | [inline] |
Definition at line 69 of file ConsumerID.h.
{
return os << id.value;
}
| void stor::parseStreamConfiguration | ( | std::string | cfgString, |
| EvtStrConfigListPtr | evtCfgList, | ||
| ErrStrConfigListPtr | errCfgList | ||
| ) |
Free function to parse a storage manager configuration string into the appropriate "configuration info" objects.
Definition at line 550 of file Configuration.cc.
References edm::ParameterSet::empty(), edm::EventSelector::getEventSelectionVString(), edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), PythonProcessDesc::processDesc(), and StorageManager_cfg::streamLabel.
Referenced by stor::Ready::do_entryActionWork().
{
if (cfgString == "") return;
PythonProcessDesc py_pdesc(cfgString.c_str());
boost::shared_ptr<edm::ProcessDesc> pdesc = py_pdesc.processDesc();
boost::shared_ptr<edm::ParameterSet> smPSet = pdesc->getProcessPSet();
// loop over each end path
std::vector<std::string> allEndPaths =
smPSet->getParameter<std::vector<std::string> >("@end_paths");
for(std::vector<std::string>::iterator endPathIter = allEndPaths.begin();
endPathIter != allEndPaths.end(); ++endPathIter) {
// loop over each element in the end path list (not sure why...)
std::vector<std::string> anEndPath =
smPSet->getParameter<std::vector<std::string> >((*endPathIter));
for(std::vector<std::string>::iterator ep2Iter = anEndPath.begin();
ep2Iter != anEndPath.end(); ++ep2Iter) {
// fetch the end path parameter set
edm::ParameterSet endPathPSet =
smPSet->getParameter<edm::ParameterSet>((*ep2Iter));
if (! endPathPSet.empty()) {
std::string mod_type =
endPathPSet.getParameter<std::string> ("@module_type");
if (mod_type == "EventStreamFileWriter") {
std::string streamLabel =
endPathPSet.getParameter<std::string> ("streamLabel");
int maxFileSizeMB = endPathPSet.getParameter<int> ("maxSize");
std::string newRequestedEvents = endPathPSet.getUntrackedParameter("TriggerSelector",std::string());
Strings requestedEvents =
edm::EventSelector::getEventSelectionVString(endPathPSet);
std::string requestedOMLabel =
endPathPSet.getUntrackedParameter<std::string>("SelectHLTOutput",
std::string());
double fractionToDisk =
endPathPSet.getUntrackedParameter<double>("fractionToDisk", 1);
EventStreamConfigurationInfo cfgInfo(streamLabel,
maxFileSizeMB,
newRequestedEvents,
requestedEvents,
requestedOMLabel,
fractionToDisk);
evtCfgList->push_back(cfgInfo);
}
else if (mod_type == "ErrorStreamFileWriter" ||
mod_type == "FRDStreamFileWriter") {
std::string streamLabel =
endPathPSet.getParameter<std::string> ("streamLabel");
int maxFileSizeMB = endPathPSet.getParameter<int> ("maxSize");
ErrorStreamConfigurationInfo cfgInfo(streamLabel,
maxFileSizeMB);
errCfgList->push_back(cfgInfo);
}
}
}
}
}
1.7.3