clear() | o2::framework::DataRelayer | |
consumeAllInputsForTimeslice(TimesliceSlot id) | o2::framework::DataRelayer | |
consumeExistingInputsForTimeslice(TimesliceSlot id) | o2::framework::DataRelayer | |
DataRelayer(CompletionPolicy const &, std::vector< InputRoute > const &routes, TimesliceIndex &, ServiceRegistryRef) | o2::framework::DataRelayer | |
getCacheSize() const | o2::framework::DataRelayer | inline |
getCreationTimeForSlot(TimesliceSlot slot) | o2::framework::DataRelayer | |
getFirstTFCounterForSlot(TimesliceSlot slot) | o2::framework::DataRelayer | |
getFirstTFOrbitForSlot(TimesliceSlot slot) | o2::framework::DataRelayer | |
getNumberOfTimeslices() const | o2::framework::DataRelayer | inline |
getNumberOfUniqueInputs() const | o2::framework::DataRelayer | inline |
getOldestPossibleOutput() const | o2::framework::DataRelayer | |
getParallelTimeslices() const | o2::framework::DataRelayer | |
getReadyToProcess(std::vector< RecordAction > &completed) | o2::framework::DataRelayer | |
getRunNumberForSlot(TimesliceSlot slot) | o2::framework::DataRelayer | |
getTimesliceForSlot(TimesliceSlot slot) | o2::framework::DataRelayer | |
InputType enum name | o2::framework::DataRelayer | |
OnDropCallback typedef | o2::framework::DataRelayer | |
processDanglingInputs(std::vector< ExpirationHandler > const &, ServiceRegistryRef context, bool createNew) | o2::framework::DataRelayer | |
pruneCache(TimesliceSlot slot, OnDropCallback onDrop=nullptr) | o2::framework::DataRelayer | |
prunePending(OnDropCallback) | o2::framework::DataRelayer | |
publishMetrics() | o2::framework::DataRelayer | |
relay(void const *rawHeader, std::unique_ptr< fair::mq::Message > *messages, InputInfo const &info, size_t nMessages, size_t nPayloads=1, OnDropCallback onDrop=nullptr) | o2::framework::DataRelayer | |
rescan() | o2::framework::DataRelayer | inline |
sendContextState() | o2::framework::DataRelayer | |
service_kind | o2::framework::DataRelayer | static |
setOldestPossibleInput(TimesliceId timeslice, ChannelIndex channel) | o2::framework::DataRelayer | |
setPipelineLength(size_t s) | o2::framework::DataRelayer | |
updateCacheStatus(TimesliceSlot slot, CacheEntryStatus oldStatus, CacheEntryStatus newStatus) | o2::framework::DataRelayer | |