Lines Matching refs:rtrs_clt_sess
49 struct rtrs_clt_sess *sess; in rtrs_clt_is_connected()
177 struct rtrs_clt_con *rtrs_permit_to_clt_con(struct rtrs_clt_sess *sess, in rtrs_permit_to_clt_con()
200 static bool __rtrs_clt_change_state(struct rtrs_clt_sess *sess, in __rtrs_clt_change_state()
289 static bool rtrs_clt_change_state_from_to(struct rtrs_clt_sess *sess, in rtrs_clt_change_state_from_to()
305 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_rdma_error_recovery()
387 struct rtrs_clt_sess *sess; in complete_rdma_req()
455 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_post_send_rdma()
485 static void process_io_rsp(struct rtrs_clt_sess *sess, u32 msg_id, in process_io_rsp()
503 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_clt_recv_done()
517 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_clt_rkey_rsp_done()
596 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_clt_rdma_done()
687 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in post_recv_io()
704 static int post_recv_sess(struct rtrs_clt_sess *sess) in post_recv_sess()
735 struct rtrs_clt_sess *(*next_path)(struct path_it *it);
767 static struct rtrs_clt_sess *get_next_path_rr(struct path_it *it) in get_next_path_rr()
769 struct rtrs_clt_sess __rcu **ppcpu_path; in get_next_path_rr()
770 struct rtrs_clt_sess *path; in get_next_path_rr()
805 static struct rtrs_clt_sess *get_next_path_min_inflight(struct path_it *it) in get_next_path_min_inflight()
807 struct rtrs_clt_sess *min_path = NULL; in get_next_path_min_inflight()
809 struct rtrs_clt_sess *sess; in get_next_path_min_inflight()
881 struct rtrs_clt_sess *sess, in rtrs_clt_init_req()
913 rtrs_clt_get_req(struct rtrs_clt_sess *sess, in rtrs_clt_get_req()
929 rtrs_clt_get_copy_req(struct rtrs_clt_sess *alive_sess, in rtrs_clt_get_copy_req()
951 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_post_rdma_write_sg()
988 struct rtrs_clt_sess *sess = to_clt_sess(s); in rtrs_clt_write_req()
1062 struct rtrs_clt_sess *sess = to_clt_sess(s); in rtrs_clt_read_req()
1173 struct rtrs_clt_sess *alive_sess; in rtrs_clt_failover_req()
1204 static void fail_all_outstanding_reqs(struct rtrs_clt_sess *sess) in fail_all_outstanding_reqs()
1231 static void free_sess_reqs(struct rtrs_clt_sess *sess) in free_sess_reqs()
1249 static int alloc_sess_reqs(struct rtrs_clt_sess *sess) in alloc_sess_reqs()
1343 static void query_fast_reg_mode(struct rtrs_clt_sess *sess) in query_fast_reg_mode()
1365 static bool rtrs_clt_change_state_get_old(struct rtrs_clt_sess *sess, in rtrs_clt_change_state_get_old()
1379 static bool rtrs_clt_change_state(struct rtrs_clt_sess *sess, in rtrs_clt_change_state()
1394 static void rtrs_clt_init_hb(struct rtrs_clt_sess *sess) in rtrs_clt_init_hb()
1403 static void rtrs_clt_start_hb(struct rtrs_clt_sess *sess) in rtrs_clt_start_hb()
1408 static void rtrs_clt_stop_hb(struct rtrs_clt_sess *sess) in rtrs_clt_stop_hb()
1416 static struct rtrs_clt_sess *alloc_sess(struct rtrs_clt *clt, in alloc_sess()
1421 struct rtrs_clt_sess *sess; in alloc_sess()
1489 void free_sess(struct rtrs_clt_sess *sess) in free_sess()
1498 static int create_con(struct rtrs_clt_sess *sess, unsigned int cid) in create_con()
1519 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in destroy_con()
1527 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in create_con_cq_qp()
1613 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in destroy_con_cq_qp()
1664 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_rdma_route_resolved()
1699 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_rdma_conn_established()
1786 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in flag_success_on_conn()
1823 static void rtrs_clt_close_conns(struct rtrs_clt_sess *sess, bool wait) in rtrs_clt_close_conns()
1834 struct rtrs_clt_sess *sess; in flag_error_on_conn()
1849 struct rtrs_clt_sess *sess = to_clt_sess(s); in rtrs_clt_rdma_cm_handler()
1915 struct rtrs_clt_sess *sess = to_clt_sess(s); in create_cm()
1980 static void rtrs_clt_sess_up(struct rtrs_clt_sess *sess) in rtrs_clt_sess_up()
2011 static void rtrs_clt_sess_down(struct rtrs_clt_sess *sess) in rtrs_clt_sess_down()
2026 static void rtrs_clt_stop_and_destroy_conns(struct rtrs_clt_sess *sess) in rtrs_clt_stop_and_destroy_conns()
2086 static inline bool xchg_sessions(struct rtrs_clt_sess __rcu **rcu_ppcpu_path, in xchg_sessions()
2087 struct rtrs_clt_sess *sess, in xchg_sessions()
2088 struct rtrs_clt_sess *next) in xchg_sessions()
2090 struct rtrs_clt_sess **ppcpu_path; in xchg_sessions()
2097 static void rtrs_clt_remove_path_from_arr(struct rtrs_clt_sess *sess) in rtrs_clt_remove_path_from_arr()
2100 struct rtrs_clt_sess *next; in rtrs_clt_remove_path_from_arr()
2155 struct rtrs_clt_sess __rcu **ppcpu_path; in rtrs_clt_remove_path_from_arr()
2187 static void rtrs_clt_add_path_to_arr(struct rtrs_clt_sess *sess, in rtrs_clt_add_path_to_arr()
2201 struct rtrs_clt_sess *sess; in rtrs_clt_close_work()
2203 sess = container_of(work, struct rtrs_clt_sess, close_work); in rtrs_clt_close_work()
2210 static int init_conns(struct rtrs_clt_sess *sess) in init_conns()
2264 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_clt_info_req_done()
2280 static int process_info_rsp(struct rtrs_clt_sess *sess, in process_info_rsp()
2347 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); in rtrs_clt_info_rsp_done()
2401 static int rtrs_send_sess_info(struct rtrs_clt_sess *sess) in rtrs_send_sess_info()
2475 static int init_sess(struct rtrs_clt_sess *sess) in init_sess()
2499 struct rtrs_clt_sess *sess; in rtrs_clt_reconnect_work()
2504 sess = container_of(to_delayed_work(work), struct rtrs_clt_sess, in rtrs_clt_reconnect_work()
2672 struct rtrs_clt_sess *sess, *tmp; in rtrs_clt_open()
2685 struct rtrs_clt_sess *sess; in rtrs_clt_open()
2744 struct rtrs_clt_sess *sess, *tmp; in rtrs_clt_close()
2761 int rtrs_clt_reconnect_from_sysfs(struct rtrs_clt_sess *sess) in rtrs_clt_reconnect_from_sysfs()
2787 int rtrs_clt_disconnect_from_sysfs(struct rtrs_clt_sess *sess) in rtrs_clt_disconnect_from_sysfs()
2794 int rtrs_clt_remove_path_from_sysfs(struct rtrs_clt_sess *sess, in rtrs_clt_remove_path_from_sysfs()
2865 struct rtrs_clt_sess *sess; in rtrs_clt_request()
2945 struct rtrs_clt_sess *sess; in rtrs_clt_create_path_from_sysfs()