25 #ifndef __MOTR_RPC_MACHINE_H__ 26 #define __MOTR_RPC_MACHINE_H__ 205 uint32_t max_per_source);
struct m0_tlink mw_linkage
struct m0_rpc_machine * mw_mach
void m0_rpc_machine_fini(struct m0_rpc_machine *machine)
struct m0_chan rm_nb_idle
void(* mw_conn_added)(struct m0_rpc_machine_watch *w, struct m0_rpc_conn *conn)
static const char * ep_addr
uint64_t rs_nr_resend_attempts
struct m0_tl rm_outgoing_conns
uint64_t rs_nr_resent_items
uint64_t rs_nr_ha_timedout_items
uint64_t rs_nr_ha_noted_conns
M0_INTERNAL const char * m0_rpc_machine_ep(const struct m0_rpc_machine *rmach)
struct m0_sm_group rm_sm_grp
uint64_t rs_nr_failed_packets
M0_INTERNAL bool m0_rpc_machine_is_locked(const struct m0_rpc_machine *machine)
void m0_rpc_machine_get_stats(struct m0_rpc_machine *machine, struct m0_rpc_stats *stats, bool reset)
M0_BOB_DECLARE(extern, m0_rpc_machine)
void(* mw_session_added)(struct m0_rpc_machine_watch *w, struct m0_rpc_session *session)
uint64_t rs_nr_failed_items
m0_bcount_t rm_bulk_cutoff
M0_INTERNAL void m0_rpc_machine_unlock(struct m0_rpc_machine *machine)
struct m0_reqh_service * rm_service
uint64_t rs_nr_rcvd_items
struct m0_net_transfer_mc rm_tm
uint64_t rs_nr_rcvd_bytes
uint64_t rs_nr_sent_items_uniq
uint32_t rm_min_recv_size
M0_INTERNAL int m0_rpc_machine_init(struct m0_rpc_machine *machine, struct m0_net_domain *net_dom, const char *ep_addr, struct m0_reqh *reqh, struct m0_net_buffer_pool *receive_pool, uint32_t colour, m0_bcount_t msg_size, uint32_t queue_len)
uint64_t rs_nr_dropped_items
void m0_rpc_machine_watch_attach(struct m0_rpc_machine_watch *watch)
void m0_rpc_machine_watch_detach(struct m0_rpc_machine_watch *watch)
struct m0_tl rm_incoming_conns
struct m0_rpc_machine machine
struct m0_thread rm_worker
void(* mw_mach_terminated)(struct m0_rpc_machine_watch *w)
M0_INTERNAL bool m0_rpc_machine_is_not_locked(const struct m0_rpc_machine *machine)
uint64_t rs_nr_sent_packets
M0_INTERNAL void m0_rpc_machine_lock(struct m0_rpc_machine *machine)
uint64_t rs_nr_sent_bytes
M0_INTERNAL void m0_rpc_machine_drain_item_sources(struct m0_rpc_machine *machine, uint32_t max_per_source)
uint64_t rs_nr_timedout_items
struct m0_tlink rm_rh_linkage
struct m0_rpc_stats rm_stats
uint64_t rs_nr_sent_items
struct m0_mutex_addb2 rm_lock_stats
uint64_t rs_nr_rcvd_packets