Lines Matching refs:rtrs_clt
45 static inline bool rtrs_clt_is_connected(const struct rtrs_clt *clt) in rtrs_clt_is_connected()
59 __rtrs_get_permit(struct rtrs_clt *clt, enum rtrs_clt_con_type con_type) in __rtrs_get_permit()
86 static inline void __rtrs_put_permit(struct rtrs_clt *clt, in __rtrs_put_permit()
106 struct rtrs_permit *rtrs_clt_get_permit(struct rtrs_clt *clt, in rtrs_clt_get_permit()
141 void rtrs_clt_put_permit(struct rtrs_clt *clt, struct rtrs_permit *permit) in rtrs_clt_put_permit()
308 struct rtrs_clt *clt = sess->clt; in rtrs_rdma_error_recovery()
733 struct rtrs_clt *clt;
770 struct rtrs_clt *clt; in get_next_path_rr()
807 struct rtrs_clt *clt = it->clt; in get_next_path_min_inflight()
834 static inline void path_it_init(struct path_it *it, struct rtrs_clt *clt) in path_it_init()
1166 static int rtrs_clt_failover_req(struct rtrs_clt *clt, in rtrs_clt_failover_req()
1202 struct rtrs_clt *clt = sess->clt; in fail_all_outstanding_reqs()
1249 struct rtrs_clt *clt = sess->clt; in alloc_sess_reqs()
1292 static int alloc_permits(struct rtrs_clt *clt) in alloc_permits()
1326 static void free_permits(struct rtrs_clt *clt) in free_permits()
1407 static struct rtrs_clt_sess *alloc_sess(struct rtrs_clt *clt, in alloc_sess()
1654 struct rtrs_clt *clt = sess->clt; in rtrs_rdma_route_resolved()
1688 struct rtrs_clt *clt = sess->clt; in rtrs_rdma_conn_established()
1962 struct rtrs_clt *clt = sess->clt; in rtrs_clt_sess_up()
1993 struct rtrs_clt *clt = sess->clt; in rtrs_clt_sess_down()
2079 struct rtrs_clt *clt = sess->clt; in rtrs_clt_remove_path_from_arr()
2170 struct rtrs_clt *clt = sess->clt; in rtrs_clt_add_path_to_arr()
2480 struct rtrs_clt *clt; in rtrs_clt_reconnect_work()
2522 struct rtrs_clt *clt = container_of(dev, struct rtrs_clt, dev); in rtrs_clt_dev_release()
2527 static struct rtrs_clt *alloc_clt(const char *sessname, size_t paths_num, in alloc_clt()
2536 struct rtrs_clt *clt; in alloc_clt()
2613 static void wait_for_inflight_permits(struct rtrs_clt *clt) in wait_for_inflight_permits()
2623 static void free_clt(struct rtrs_clt *clt) in free_clt()
2653 struct rtrs_clt *rtrs_clt_open(struct rtrs_clt_ops *ops, in rtrs_clt_open()
2663 struct rtrs_clt *clt; in rtrs_clt_open()
2726 void rtrs_clt_close(struct rtrs_clt *clt) in rtrs_clt_close()
2808 void rtrs_clt_set_max_reconnect_attempts(struct rtrs_clt *clt, int value) in rtrs_clt_set_max_reconnect_attempts()
2813 int rtrs_clt_get_max_reconnect_attempts(const struct rtrs_clt *clt) in rtrs_clt_get_max_reconnect_attempts()
2843 struct rtrs_clt *clt, struct rtrs_permit *permit, in rtrs_clt_request()
2911 int rtrs_clt_query(struct rtrs_clt *clt, struct rtrs_attrs *attr) in rtrs_clt_query()
2925 int rtrs_clt_create_path_from_sysfs(struct rtrs_clt *clt, in rtrs_clt_create_path_from_sysfs()