 |
Belle II Software
release-05-01-25
|
10 #include <framework/pcore/zmq/processModules/ProcessedEventsBackupList.h>
15 const unsigned int workerId)
17 EventMetaData eventMetaData(evtMetaData->getEvent(), evtMetaData->getRun(), evtMetaData->getExperiment());
29 B2WARNING(
"Event: " << evtMetaData.
getEvent() <<
", no matching event backup found in backup list");
38 if (std::chrono::system_clock::now() -
m_evtBackupVector[0].getTimestamp() > timeout) {
void removeEvent(const EventMetaData &evtMetaData)
Remove all backups with the given event meta data (on confirmation)
std::vector< ProcessedEventBackup > m_evtBackupVector
The vector where the event backups are stored.
int checkForTimeout(const Duration &timeout) const
Check the items for timeout. Returns -1 if no timeout happened and the worker id, if it did.
Abstract base class for different kinds of events.
Type-safe access to single objects in the data store.
std::chrono::milliseconds Duration
Short for the class of a duration (always measured in milliseconds)
unsigned int size() const
Check the size.
void storeEvent(std::unique_ptr< EvtMessage > evtMsg, const StoreObjPtr< EventMetaData > &evtMetaData, const unsigned int workerId)
Add a new event backup with the given information. Takes ownership of the evt message.