Lines Matching refs:rtrs_clt_sess
52 static inline bool rtrs_clt_is_connected(const struct rtrs_clt_sess *clt) in rtrs_clt_is_connected()
69 __rtrs_get_permit(struct rtrs_clt_sess *clt, enum rtrs_clt_con_type con_type) in __rtrs_get_permit()
96 static inline void __rtrs_put_permit(struct rtrs_clt_sess *clt, in __rtrs_put_permit()
116 struct rtrs_permit *rtrs_clt_get_permit(struct rtrs_clt_sess *clt, in rtrs_clt_get_permit()
151 void rtrs_clt_put_permit(struct rtrs_clt_sess *clt, in rtrs_clt_put_permit()
746 struct rtrs_clt_sess *clt;
783 struct rtrs_clt_sess *clt; in get_next_path_rr()
823 struct rtrs_clt_sess *clt = it->clt; in get_next_path_min_inflight()
874 struct rtrs_clt_sess *clt = it->clt; in get_next_path_min_latency()
904 static inline void path_it_init(struct path_it *it, struct rtrs_clt_sess *clt) in path_it_init()
1282 static int rtrs_clt_failover_req(struct rtrs_clt_sess *clt, in rtrs_clt_failover_req()
1317 struct rtrs_clt_sess *clt = clt_path->clt; in fail_all_outstanding_reqs()
1406 static int alloc_permits(struct rtrs_clt_sess *clt) in alloc_permits()
1439 static void free_permits(struct rtrs_clt_sess *clt) in free_permits()
1513 struct rtrs_clt_sess *clt; in rtrs_clt_err_recovery_work()
1525 static struct rtrs_clt_path *alloc_path(struct rtrs_clt_sess *clt, in alloc_path()
1790 struct rtrs_clt_sess *clt = clt_path->clt; in rtrs_rdma_route_resolved()
1825 struct rtrs_clt_sess *clt = clt_path->clt; in rtrs_rdma_conn_established()
2104 struct rtrs_clt_sess *clt = clt_path->clt; in rtrs_clt_path_up()
2135 struct rtrs_clt_sess *clt = clt_path->clt; in rtrs_clt_path_down()
2213 struct rtrs_clt_sess *clt = clt_path->clt; in rtrs_clt_remove_path_from_arr()
2303 struct rtrs_clt_sess *clt = clt_path->clt; in rtrs_clt_add_path_to_arr()
2639 struct rtrs_clt_sess *clt; in rtrs_clt_reconnect_work()
2676 struct rtrs_clt_sess *clt = container_of(dev, struct rtrs_clt_sess, in rtrs_clt_dev_release()
2684 static struct rtrs_clt_sess *alloc_clt(const char *sessname, size_t paths_num, in alloc_clt()
2691 struct rtrs_clt_sess *clt; in alloc_clt()
2766 static void free_clt(struct rtrs_clt_sess *clt) in free_clt()
2794 struct rtrs_clt_sess *rtrs_clt_open(struct rtrs_clt_ops *ops, in rtrs_clt_open()
2802 struct rtrs_clt_sess *clt; in rtrs_clt_open()
2876 void rtrs_clt_close(struct rtrs_clt_sess *clt) in rtrs_clt_close()
2953 void rtrs_clt_set_max_reconnect_attempts(struct rtrs_clt_sess *clt, int value) in rtrs_clt_set_max_reconnect_attempts()
2958 int rtrs_clt_get_max_reconnect_attempts(const struct rtrs_clt_sess *clt) in rtrs_clt_get_max_reconnect_attempts()
2988 struct rtrs_clt_sess *clt, struct rtrs_permit *permit, in rtrs_clt_request()
3048 int rtrs_clt_rdma_cq_direct(struct rtrs_clt_sess *clt, unsigned int index) in rtrs_clt_rdma_cq_direct()
3082 int rtrs_clt_query(struct rtrs_clt_sess *clt, struct rtrs_attrs *attr) in rtrs_clt_query()
3097 int rtrs_clt_create_path_from_sysfs(struct rtrs_clt_sess *clt, in rtrs_clt_create_path_from_sysfs()