25 #ifndef __MOTR_HA_HA_H__ 26 #define __MOTR_HA_HA_H__ struct m0_tl h_links_outgoing
uint64_t h_link_id_counter
struct m0_ha_entrypoint_client h_entrypoint_client
M0_INTERNAL struct m0_ha_link * m0_ha_connect(struct m0_ha *ha)
M0_INTERNAL void m0_ha_fini(struct m0_ha *ha)
struct m0_ha_entrypoint_server_cfg hcf_entrypoint_server_cfg
M0_INTERNAL void m0_ha_rpc_endpoint(struct m0_ha *ha, struct m0_ha_link *hl, char *buf, m0_bcount_t buf_len)
static struct io_request req
static uint64_t tag(uint8_t code, uint64_t id)
struct m0_reqh_service * h_hl_service
uint64_t h_generation_counter
void(* hao_link_disconnected)(struct m0_ha *ha, struct m0_ha_link *hl)
M0_INTERNAL int m0_ha_start(struct m0_ha *ha)
M0_INTERNAL struct m0_ha_link * m0_ha_outgoing_link(struct m0_ha *ha)
void(* hao_link_connected)(struct m0_ha *ha, const struct m0_uint128 *req_id, struct m0_ha_link *hl)
M0_INTERNAL void m0_ha_send(struct m0_ha *ha, struct m0_ha_link *hl, const struct m0_ha_msg *msg, uint64_t *tag)
void(* hao_link_absent)(struct m0_ha *ha, const struct m0_uint128 *req_id)
struct m0_fop_getxattr_rep * rep
struct m0_reqh * hcf_reqh
void(* hao_entrypoint_request)(struct m0_ha *ha, const struct m0_ha_entrypoint_req *req, const struct m0_uint128 *req_id)
M0_INTERNAL void m0_ha_disconnect(struct m0_ha *ha)
M0_INTERNAL struct m0_rpc_session * m0_ha_outgoing_session(struct m0_ha *ha)
M0_INTERNAL void m0_ha_flush(struct m0_ha *ha, struct m0_ha_link *hl)
M0_INTERNAL void m0_ha_stop(struct m0_ha *ha)
M0_INTERNAL void m0_ha_process_failed(struct m0_ha *ha, const struct m0_fid *process_fid)
struct m0_ha_entrypoint_server h_entrypoint_server
M0_INTERNAL void m0_ha_delivered(struct m0_ha *ha, struct m0_ha_link *hl, struct m0_ha_msg *msg)
void(* hao_link_is_disconnecting)(struct m0_ha *ha, struct m0_ha_link *hl)
struct m0_ha_link * h_link
void(* hao_entrypoint_replied)(struct m0_ha *ha, struct m0_ha_entrypoint_rep *rep)
struct m0_tl h_links_stopping
M0_INTERNAL void m0_ha_mod_fini(void)
struct m0_ha_entrypoint_client_cfg hcf_entrypoint_client_cfg
struct m0_ha_cookie h_cookie_local
bool h_warn_local_link_disconnect
struct m0_ha_cookie h_cookie_remote
struct m0_rpc_machine * hcf_rpc_machine
M0_INTERNAL void m0_ha_disconnect_incoming(struct m0_ha *ha, struct m0_ha_link *hl)
void(* hao_error_no_memory)(struct m0_ha *ha, int unused)
M0_INTERNAL int m0_ha_mod_init(void)
void(* hao_msg_is_delivered)(struct m0_ha *ha, struct m0_ha_link *hl, uint64_t tag)
void(* hao_msg_received)(struct m0_ha *ha, struct m0_ha_link *hl, struct m0_ha_msg *msg, uint64_t tag)
M0_INTERNAL int m0_ha_init(struct m0_ha *ha, struct m0_ha_cfg *ha_cfg)
struct ha_link_ctx * h_link_ctx
struct m0_module h_module
void(* hao_link_reused)(struct m0_ha *ha, const struct m0_uint128 *req_id, struct m0_ha_link *hl)
void(* hao_msg_is_not_delivered)(struct m0_ha *ha, struct m0_ha_link *hl, uint64_t tag)
void m0_ha_entrypoint_reply(struct m0_ha *ha, const struct m0_uint128 *req_id, const struct m0_ha_entrypoint_rep *rep, struct m0_ha_link **hl_ptr)
struct m0_tl h_links_incoming
struct m0_fid hcf_process_fid
static const char * process_fid