Motr
M0
|
#include "fop/fom.h"
#include "lib/chan.h"
#include "lib/mutex.h"
#include "lib/time.h"
#include "lib/tlist.h"
#include "rpc/conn.h"
#include "rpc/session.h"
Go to the source code of this file.
Data Structures | |
struct | m0_rpc_link |
Macros | |
#define | __MOTR_RPC_LINK_H__ |
Enumerations | |
enum | m0_rpc_link_states { M0_RLS_INIT = M0_FOM_PHASE_INIT, M0_RLS_FINI = M0_FOM_PHASE_FINISH, M0_RLS_CONN_FAILURE, M0_RLS_SESS_FAILURE, M0_RLS_CONN_CONNECTING, M0_RLS_SESS_ESTABLISHING, M0_RLS_SESS_WAIT_IDLE, M0_RLS_SESS_TERMINATING, M0_RLS_CONN_TERMINATING } |
Functions | |
M0_INTERNAL int | m0_rpc_link_module_init (void) |
M0_INTERNAL void | m0_rpc_link_module_fini (void) |
M0_INTERNAL int | m0_rpc_link_init (struct m0_rpc_link *rlink, struct m0_rpc_machine *mach, struct m0_fid *svc_fid, const char *ep, uint64_t max_rpcs_in_flight) |
M0_INTERNAL void | m0_rpc_link_fini (struct m0_rpc_link *rlink) |
M0_INTERNAL void | m0_rpc_link_reset (struct m0_rpc_link *rlink) |
M0_INTERNAL void | m0_rpc_link_connect_async (struct m0_rpc_link *rlink, m0_time_t abs_timeout, struct m0_clink *wait_clink) |
M0_INTERNAL int | m0_rpc_link_connect_sync (struct m0_rpc_link *rlink, m0_time_t abs_timeout) |
M0_INTERNAL void | m0_rpc_link_disconnect_async (struct m0_rpc_link *rlink, m0_time_t abs_timeout, struct m0_clink *wait_clink) |
M0_INTERNAL int | m0_rpc_link_disconnect_sync (struct m0_rpc_link *rlink, m0_time_t abs_timeout) |
M0_INTERNAL bool | m0_rpc_link_is_connected (const struct m0_rpc_link *rlink) |
M0_INTERNAL const char * | m0_rpc_link_end_point (const struct m0_rpc_link *rlink) |