Open Model Railroad Network (OpenMRN)
Loading...
Searching...
No Matches
DirectHubPortSelect::DirectHubReadFlow Member List

This is the complete list of members for DirectHubPortSelect::DirectHubReadFlow, including all inherited members.

again()StateFlowBaseinlineprotected
alloc_for_read()DirectHubPortSelect::DirectHubReadFlowinlineprivate
alloc_result(QMember *b) overrideStateFlowBaseinlineprivatevirtual
allocate_and_call(FlowInterface< Buffer< T > > *target_flow, Callback c, Pool *pool=nullptr)StateFlowBaseinlineprotected
allocate_and_call(Callback c, QAsync *queue)StateFlowBaseinlineprotected
allocationResult_StateFlowBaseprivate
barrier_allocated()DirectHubPortSelect::DirectHubReadFlowinlineprivate
buf_DirectHubPortSelect::DirectHubReadFlowprivate
bufferNotifiable_DirectHubPortSelect::DirectHubReadFlowprivate
call_head_segmenter()DirectHubPortSelect::DirectHubReadFlowinlineprivate
call_immediately(Callback c)StateFlowBaseinlineprotected
Callback typedefStateFlowBaseprotected
cast_allocation_result(T **member)StateFlowBaseinlineprotected
delete_this()StateFlowBaseinlineprotected
DirectHubReadFlow(DirectHubPortSelect *parent, std::unique_ptr< MessageSegmenter > segmenter) (defined in DirectHubPortSelect::DirectHubReadFlow)DirectHubPortSelect::DirectHubReadFlowinline
DISALLOW_COPY_AND_ASSIGN(StateFlowBase) (defined in StateFlowBase)StateFlowBaseprivate
do_some_read() (defined in DirectHubPortSelect::DirectHubReadFlow)DirectHubPortSelect::DirectHubReadFlowinlineprivate
eval_segment()DirectHubPortSelect::DirectHubReadFlowinlineprivate
exit()StateFlowBaseinlineprotected
full_allocation_result(FlowInterface< Buffer< T > > *target_flow)StateFlowBaseinlineprotected
full_allocation_result(TypedQAsync< T > *queue)StateFlowBaseinlineprotected
get_allocation_result(FlowInterface< Buffer< T > > *target_flow)StateFlowBaseinlineprotected
get_read_buffer()DirectHubPortSelect::DirectHubReadFlowinlineprivate
helper_DirectHubPortSelect::DirectHubReadFlowprivate
incomplete_message()DirectHubPortSelect::DirectHubReadFlowinlineprivate
init()QMemberinline
inlineCall_DirectHubPortSelect::DirectHubReadFlowprivate
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
nextQMemberprotected
notify() overrideStateFlowBasevirtual
parent_DirectHubPortSelect::DirectHubReadFlowprivate
pendingLimiterPool_DirectHubPortSelect::DirectHubReadFlowprivate
QMember()QMemberinlineprotected
read_done() (defined in DirectHubPortSelect::DirectHubReadFlow)DirectHubPortSelect::DirectHubReadFlowinlineprivate
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_shutdown()DirectHubPortSelect::DirectHubReadFlowinline
read_single(StateFlowSelectHelper *helper, int fd, void *buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)StateFlowBaseinlineprotected
reset_flow(Callback c)StateFlowBaseinlineprotected
run() overrideStateFlowBasevirtual
segmenter_DirectHubPortSelect::DirectHubReadFlowprivate
segmentSize_DirectHubPortSelect::DirectHubReadFlowprivate
send_callback()DirectHubPortSelect::DirectHubReadFlowinlineprivate
send_done()DirectHubPortSelect::DirectHubReadFlowinlineprivate
send_prefix()DirectHubPortSelect::DirectHubReadFlowinlineprivate
sendComplete_DirectHubPortSelect::DirectHubReadFlowprivate
service()StateFlowBaseinline
service_StateFlowBaseprivate
set_terminated()StateFlowBaseinlineprotected
sleep_and_call(::Timer *timer, long long timeout_nsec, Callback c)StateFlowBaseinlineprotected
start()DirectHubPortSelect::DirectHubReadFlowinline
start_flow(Callback c)StateFlowBaseinlineprotected
state_StateFlowBaseprivate
StateFlowBase(Service *service)StateFlowBaseinlineprotected
StateFlowBase()StateFlowBaseprivate
terminated()StateFlowBaseprivate
test_deletion() (defined in Executable)Executable
wait()StateFlowBaseinlineprotected
wait_and_call(Callback c)StateFlowBaseinlineprotected
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
~QMember()QMemberinlineprotected
~StateFlowBase()StateFlowBaseinlineprotected