| 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 | |