Open Model Railroad Network (OpenMRN)
Loading...
Searching...
No Matches
SocketClient Member List

This is the complete list of members for SocketClient, including all inherited members.

address_to_string(struct addrinfo *addr, string *host, int *port)SocketClientstatic
AddrinfoPtr typedefSocketClient
again()StateFlowBaseinlineprotected
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
Attempt enum nameSocketClient
call_immediately(Callback c)StateFlowBaseinlineprotected
Callback typedefStateFlowBaseprotected
callback_SocketClientprivate
cast_allocation_result(T **member)StateFlowBaseinlineprotected
connect(const char *host, int port)SocketClientinlinestatic
connect(const char *host, const char *port_str)SocketClientstatic
connect(struct addrinfo *addr)SocketClientstatic
connect_blocking(const string &host, int port)SocketClientinlineprivate
connect_complete()SocketClientinlineprivate
connect_mdns()SocketClientinlineprivate
connected()SocketClientinlineprivate
connectExecutor_SocketClientprivate
delete_this()StateFlowBaseinlineprotected
DISALLOW_COPY_AND_ASSIGN(SocketClient) (defined in SocketClient)SocketClientprivate
exit()StateFlowBaseinlineprotected
failed_oneshot()SocketClientinlineprivate
fd_SocketClientprivate
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
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_connected()SocketClientinline
is_shutdown()SocketClientinline
is_state(Callback c)StateFlowBaseinlineprotected
is_terminated()StateFlowBaseinlineprotected
isConnected_SocketClientprivate
local_test(struct addrinfo *addr)SocketClientprivatestatic
lock() (defined in Atomic)Atomicinlineprivate
mdns_lookup(string mdns_hostname, string mdns_service)SocketClientinlineprivate
mdnsAddr_SocketClientprivate
mdnsExecutor_SocketClientprivate
mdnsJoin_SocketClientprivate
mdnsPending_SocketClientprivate
mu_Atomicprivate
n_ (defined in SocketClient)SocketClientprivate
nextQMemberprotected
next_step()SocketClientinlineprivate
notify() overrideStateFlowBasevirtual
params_SocketClientprivate
prepare_strategy()SocketClientinlineprivate
QMember()QMemberinlineprotected
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
requestShutdown_SocketClientprivate
reset_flow(Callback c)StateFlowBaseinlineprotected
reset_params(std::unique_ptr< SocketClientParams > params)SocketClientinline
run() overrideStateFlowBasevirtual
service()StateFlowBaseinline
service_StateFlowBaseprivate
set_terminated()StateFlowBaseinlineprotected
shutdown()SocketClientinline
sleep_and_call(::Timer *timer, long long timeout_nsec, Callback c)StateFlowBaseinlineprotected
sleep_done() (defined in SocketClient)SocketClientinlineprivate
sleeping_SocketClientprivate
SocketClient(Service *service, ExecutorBase *connect_executor, ExecutorBase *mdns_executor, std::unique_ptr< SocketClientParams > params, std::function< void(int, Notifiable *)> connect_callback)SocketClientinline
start_connection()SocketClientinlineprivate
start_flow(Callback c)StateFlowBaseinlineprotected
start_mdns()SocketClientinlineprivate
start_shutdown()SocketClientinline
startTime_SocketClientprivate
state_StateFlowBaseprivate
StateFlowBase(Service *service)StateFlowBaseinlineprotected
StateFlowBase()StateFlowBaseprivate
strategyConfig_SocketClientprivate
strategyOffset_SocketClientprivate
string_to_address(const char *host, int port)SocketClientinlinestatic
string_to_address(const char *host, const char *port_str)SocketClientstatic
terminated()StateFlowBaseprivate
test_deletion() (defined in Executable)Executable
timer_SocketClientprivate
to_string(const char *p)SocketClientinlineprivate
try_schedule_connect(SocketClientParams::LogMessage log, string host, int port)SocketClientinlineprivate
unlock() (defined in Atomic)Atomicinlineprivate
wait()StateFlowBaseinlineprotected
wait_and_call(Callback c)StateFlowBaseinlineprotected
wait_and_connect_mdns()SocketClientinlineprivate
wait_retry()SocketClientinlineprivate
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
~SocketClient()SocketClientinline
~StateFlowBase()StateFlowBaseinlineprotected