Open Model Railroad Network (OpenMRN)
Loading...
Searching...
No Matches
DispatchFlow< MessageType, NUM_PRIO > Member List

This is the complete list of members for DispatchFlow< MessageType, NUM_PRIO >, including all inherited members.

Action typedefDispatchFlow< MessageType, NUM_PRIO >
again()DispatchFlowBase< BASE_NUM_PRIO >inlineprotected
alloc()FlowInterface< MessageType >inline
alloc_async(Executable *target)FlowInterface< MessageType >inline
alloc_result(QMember *b) overrideStateFlowBaseinlineprivatevirtual
allocate_and_call(FlowInterface< Buffer< T > > *target_flow, Callback c, Pool *pool=nullptr)DispatchFlow< MessageType, NUM_PRIO >inline
allocate_and_call(Callback c, QAsync *queue)DispatchFlow< MessageType, NUM_PRIO >inline
allocate_and_clone() OVERRIDEDispatchFlow< MessageType, NUM_PRIO >inlineprotectedvirtual
allocationResult_StateFlowBaseprivate
Base typedefDispatchFlow< MessageType, NUM_PRIO >
call_immediately(Callback c)DispatchFlow< MessageType, NUM_PRIO >inline
Callback typedefUntypedStateFlow< QList< NUM_PRIO > >protected
cast_alloc(QMember *entry)FlowInterface< MessageType >inlinestatic
cast_allocation_result(T **member)StateFlowBaseinlineprotected
clone()DispatchFlow< MessageType, NUM_PRIO >inlineprotected
clone_done()DispatchFlowBase< BASE_NUM_PRIO >protected
currentIndex_DispatchFlowBase< BASE_NUM_PRIO >private
currentMessage_StateFlowWithQueueprivate
currentPriority_StateFlowWithQueueprivate
delete_this()StateFlowBaseinlineprotected
DISALLOW_COPY_AND_ASSIGN(StateFlowBase) (defined in StateFlowBase)StateFlowBaseprivate
DispatchFlow(Service *service)DispatchFlow< MessageType, NUM_PRIO >inline
DispatchFlowBase(Service *service)DispatchFlowBase< BASE_NUM_PRIO >
entry() OVERRIDEDispatchFlow< MessageType, NUM_PRIO >inlinevirtual
exit()StateFlowWithQueueinlineprotected
fallbackHandler_DispatchFlowBase< BASE_NUM_PRIO >protected
full_allocation_result(FlowInterface< Buffer< T > > *target_flow)StateFlowBaseinlineprotected
full_allocation_result(TypedQAsync< T > *queue)StateFlowBaseinlineprotected
get_allocation_result(FlowInterface< Buffer< T > > *target_flow)DispatchFlow< MessageType, NUM_PRIO >inline
get_message_id() OVERRIDEDispatchFlow< MessageType, NUM_PRIO >inlineprotectedvirtual
handlers_DispatchFlowBase< BASE_NUM_PRIO >private
HandlerType typedefDispatchFlow< MessageType, NUM_PRIO >
head_LinkedObject< StateFlowWithQueue >protectedstatic
head_mu()LinkedObject< StateFlowWithQueue >inlinestatic
ID typedefDispatchFlow< MessageType, NUM_PRIO >
init()QMemberinline
internal_try_read()StateFlowBaseinlineprotected
internal_try_write()StateFlowBaseinlineprotected
invoke_subflow_and_ignore_result(FlowInterface< Buffer< T > > *target_flow, Args &&... args)StateFlowBaseinlinestatic
invoke_subflow_and_wait(FlowInterface< Buffer< T > > *target_flow, Callback c, Args &&... args)StateFlowBaseinlineprotected
is_state(Callback c)StateFlowBaseinlineprotected
is_terminated()StateFlowBaseinlineprotected
is_waiting()StateFlowWithQueueinline
isWaiting_StateFlowWithQueueprivate
iterate()DispatchFlowBase< BASE_NUM_PRIO >protected
iteration_done()DispatchFlowBase< BASE_NUM_PRIO >protected
lastHandlerToCall_DispatchFlowBase< BASE_NUM_PRIO >protected
link_LinkedObject< StateFlowWithQueue >protected
link_head()LinkedObject< StateFlowWithQueue >inlinestatic
link_next()LinkedObject< StateFlowWithQueue >inline
link_this()LinkedObject< StateFlowWithQueue >inlineprotected
LinkedObject()LinkedObject< StateFlowWithQueue >inlineprotected
lock() (defined in Atomic)Atomicinlineprotected
lock_DispatchFlowBase< BASE_NUM_PRIO >private
MAX_PRIORITY_StateFlowWithQueueprivatestatic
message()TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >inlineprotected
message_type typedefFlowInterface< MessageType >
mu_Atomicprivate
negateMatch_DispatchFlowBase< BASE_NUM_PRIO >private
nextQMemberprotected
notify() overrideStateFlowWithQueuevirtual
pool()FlowInterface< MessageType >inlinevirtual
priority()StateFlowWithQueueinlineprotected
QMember()QMemberinlineprotected
queue_UntypedStateFlow< QList< NUM_PRIO > >private
queue_empty() OVERRIDEUntypedStateFlow< QList< NUM_PRIO > >inlineprotectedvirtual
queue_next(unsigned *priority) OVERRIDEUntypedStateFlow< QList< NUM_PRIO > >inlineprotectedvirtual
queueSize_StateFlowWithQueueprivate
read_nonblocking(StateFlowSelectHelper *helper, int fd, void *buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)StateFlowBaseinlineprotected
read_repeated(StateFlowSelectHelper *helper, int fd, void *buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)StateFlowBaseinlineprotected
read_repeated_with_timeout(StateFlowTimedSelectHelper *helper, long long timeout_nsec, int fd, void *buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)StateFlowBaseinlineprotected
read_single(StateFlowSelectHelper *helper, int fd, void *buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)StateFlowBaseinlineprotected
register_fallback_handler(HandlerType *handler)DispatchFlow< MessageType, NUM_PRIO >inline
TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >::register_fallback_handler(UntypedHandler *handler)DispatchFlowBase< BASE_NUM_PRIO >inlineprotected
register_handler(HandlerType *handler, ID id, ID mask)DispatchFlow< MessageType, NUM_PRIO >inline
TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >::register_handler(UntypedHandler *handler, ID id, ID mask)DispatchFlowBase< BASE_NUM_PRIO >protected
release() OVERRIDETypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >inlineprotectedvirtual
release_and_exit()DispatchFlowBase< BASE_NUM_PRIO >inlineprotected
reset_flow(Callback c)StateFlowBaseinlineprotected
reset_message(BufferBase *message, unsigned priority)StateFlowWithQueueinlineprotected
return_buffer()TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >inlineprotected
run() overrideStateFlowBasevirtual
send(MessageType *msg, unsigned priority=UINT_MAX) OVERRIDETypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >inlinevirtual
DispatchFlowBase< BASE_NUM_PRIO >::send(BufferBase *msg, unsigned priority=UINT_MAX)UntypedStateFlow< QList< NUM_PRIO > >inlineprotected
send_transfer() OVERRIDEDispatchFlow< MessageType, NUM_PRIO >inlineprotectedvirtual
service()StateFlowBaseinline
service_StateFlowBaseprivate
set_priority(unsigned priority)StateFlowWithQueueinlineprotected
set_terminated()StateFlowBaseinlineprotected
size()DispatchFlowBase< BASE_NUM_PRIO >
sleep_and_call(::Timer *timer, long long timeout_nsec, Callback c)StateFlowBaseinlineprotected
start_flow(Callback c)StateFlowBaseinlineprotected
start_flow_at_init(Callback c)StateFlowWithQueueinlineprotected
state_StateFlowBaseprivate
StateFlowBase(Service *service)StateFlowBaseinlineprotected
StateFlowBase()StateFlowBaseprivate
StateFlowWithQueue(Service *service)StateFlowWithQueueprotected
terminated()StateFlowBaseprivate
test_deletion() (defined in Executable)Executable
transfer_message()TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >inlineprotected
type_helper()FlowInterface< MessageType >inlinevirtual
TypedStateFlow(Service *service)TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >inline
unlock() (defined in Atomic)Atomicinlineprotected
unregister_handler(HandlerType *handler, ID id, ID mask)DispatchFlow< MessageType, NUM_PRIO >inline
TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >::unregister_handler(UntypedHandler *handler, ID id, ID mask)DispatchFlowBase< BASE_NUM_PRIO >protected
unregister_handler_all(HandlerType *handler)DispatchFlow< MessageType, NUM_PRIO >inline
TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >::unregister_handler_all(UntypedHandler *handler)DispatchFlowBase< BASE_NUM_PRIO >protected
UntypedHandler typedefDispatchFlowBase< BASE_NUM_PRIO >protected
UntypedStateFlow(Service *service)UntypedStateFlow< QList< NUM_PRIO > >inline
wait()StateFlowBaseinlineprotected
wait_and_call(Callback c)StateFlowBaseinlineprotected
wait_for_message() (defined in StateFlowWithQueue)StateFlowWithQueueprivate
write_repeated(StateFlowSelectHelper *helper, int fd, const void *buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)StateFlowBaseinlineprotected
yield()StateFlowBaseinlineprotected
yield_and_call(Callback c)StateFlowBaseinlineprotected
~Destructable() (defined in Destructable)Destructableinlinevirtual
~Executable() (defined in Executable)Executablevirtual
~FlowInterface() (defined in FlowInterface< MessageType >)FlowInterface< MessageType >inlinevirtual
~LinkedObject()LinkedObject< StateFlowWithQueue >inlineprotected
~QMember()QMemberinlineprotected
~StateFlowBase()StateFlowBaseinlineprotected
~StateFlowWithQueue() (defined in StateFlowWithQueue)StateFlowWithQueue
~TypedStateFlow()TypedStateFlow< MessageType, DispatchFlowBase< BASE_NUM_PRIO > >inlinevirtual