Lines Matching refs:rtrs_clt
49 static inline bool rtrs_clt_is_connected(const struct rtrs_clt *clt) in rtrs_clt_is_connected()
63 __rtrs_get_permit(struct rtrs_clt *clt, enum rtrs_clt_con_type con_type) in __rtrs_get_permit()
90 static inline void __rtrs_put_permit(struct rtrs_clt *clt, in __rtrs_put_permit()
110 struct rtrs_permit *rtrs_clt_get_permit(struct rtrs_clt *clt, in rtrs_clt_get_permit()
145 void rtrs_clt_put_permit(struct rtrs_clt *clt, struct rtrs_permit *permit) in rtrs_clt_put_permit()
306 struct rtrs_clt *clt = sess->clt; in rtrs_rdma_error_recovery()
743 struct rtrs_clt *clt;
780 struct rtrs_clt *clt; in get_next_path_rr()
817 struct rtrs_clt *clt = it->clt; in get_next_path_min_inflight()
868 struct rtrs_clt *clt = it->clt; in get_next_path_min_latency()
898 static inline void path_it_init(struct path_it *it, struct rtrs_clt *clt) in path_it_init()
1280 static int rtrs_clt_failover_req(struct rtrs_clt *clt, in rtrs_clt_failover_req()
1315 struct rtrs_clt *clt = sess->clt; in fail_all_outstanding_reqs()
1402 static int alloc_permits(struct rtrs_clt *clt) in alloc_permits()
1436 static void free_permits(struct rtrs_clt *clt) in free_permits()
1507 static struct rtrs_clt_sess *alloc_sess(struct rtrs_clt *clt, in alloc_sess()
1768 struct rtrs_clt *clt = sess->clt; in rtrs_rdma_route_resolved()
1803 struct rtrs_clt *clt = sess->clt; in rtrs_rdma_conn_established()
2092 struct rtrs_clt *clt = sess->clt; in rtrs_clt_sess_up()
2123 struct rtrs_clt *clt = sess->clt; in rtrs_clt_sess_down()
2211 struct rtrs_clt *clt = sess->clt; in rtrs_clt_remove_path_from_arr()
2301 struct rtrs_clt *clt = sess->clt; in rtrs_clt_add_path_to_arr()
2623 struct rtrs_clt *clt; in rtrs_clt_reconnect_work()
2665 struct rtrs_clt *clt = container_of(dev, struct rtrs_clt, dev); in rtrs_clt_dev_release()
2670 static struct rtrs_clt *alloc_clt(const char *sessname, size_t paths_num, in alloc_clt()
2677 struct rtrs_clt *clt; in alloc_clt()
2752 static void free_clt(struct rtrs_clt *clt) in free_clt()
2780 struct rtrs_clt *rtrs_clt_open(struct rtrs_clt_ops *ops, in rtrs_clt_open()
2788 struct rtrs_clt *clt; in rtrs_clt_open()
2856 void rtrs_clt_close(struct rtrs_clt *clt) in rtrs_clt_close()
2930 void rtrs_clt_set_max_reconnect_attempts(struct rtrs_clt *clt, int value) in rtrs_clt_set_max_reconnect_attempts()
2935 int rtrs_clt_get_max_reconnect_attempts(const struct rtrs_clt *clt) in rtrs_clt_get_max_reconnect_attempts()
2965 struct rtrs_clt *clt, struct rtrs_permit *permit, in rtrs_clt_request()
3025 int rtrs_clt_rdma_cq_direct(struct rtrs_clt *clt, unsigned int index) in rtrs_clt_rdma_cq_direct()
3059 int rtrs_clt_query(struct rtrs_clt *clt, struct rtrs_attrs *attr) in rtrs_clt_query()
3074 int rtrs_clt_create_path_from_sysfs(struct rtrs_clt *clt, in rtrs_clt_create_path_from_sysfs()