![]() |
Project
|
Control for the message dispatching within message context. Depending on dispatching policy, objects which get ready to be sent during computing can be scheduled to be sent immediately. The trigger callback is used to decide when to sent the scheduled messages via the actual dispatch callback. More...
#include <DispatchControl.h>
Public Types | |
using | DispatchCallback = std::function< void(fair::mq::Parts &&message, ChannelIndex index, int)> |
using | DispatchTrigger = std::function< bool(o2::header::DataHeader const &)> |
Public Attributes | |
DispatchCallback | dispatch |
DispatchTrigger | trigger |
Control for the message dispatching within message context. Depending on dispatching policy, objects which get ready to be sent during computing can be scheduled to be sent immediately. The trigger callback is used to decide when to sent the scheduled messages via the actual dispatch callback.
Definition at line 35 of file DispatchControl.h.
using o2::framework::DispatchControl::DispatchCallback = std::function<void(fair::mq::Parts&& message, ChannelIndex index, int)> |
Definition at line 36 of file DispatchControl.h.
using o2::framework::DispatchControl::DispatchTrigger = std::function<bool(o2::header::DataHeader const&)> |
Definition at line 37 of file DispatchControl.h.
DispatchCallback o2::framework::DispatchControl::dispatch |
Definition at line 39 of file DispatchControl.h.
DispatchTrigger o2::framework::DispatchControl::trigger |
Definition at line 41 of file DispatchControl.h.