Lines Matching refs:rtrs
294 permit = rtrs_clt_get_permit(sess->rtrs, con_type, wait); in rnbd_get_permit()
309 rtrs_clt_put_permit(sess->rtrs, permit); in rnbd_put_permit()
408 static int send_usr_msg(struct rtrs_clt_sess *rtrs, int dir, in send_usr_msg() argument
422 err = rtrs_clt_request(dir, &req_ops, rtrs, iu->permit, in send_usr_msg()
467 err = send_usr_msg(sess->rtrs, WRITE, iu, &vec, 0, NULL, 0, in send_msg_close()
562 err = send_usr_msg(sess->rtrs, READ, iu, in send_msg_open()
615 err = send_usr_msg(sess->rtrs, READ, iu, in send_msg_sess_info()
673 err = rtrs_clt_query(sess->rtrs, &attrs); in remap_devs()
751 if (!IS_ERR_OR_NULL(sess->rtrs)) { in close_rtrs()
752 rtrs_clt_close(sess->rtrs); in close_rtrs()
753 sess->rtrs = NULL; in close_rtrs()
825 if (IS_ERR_OR_NULL(sess->rtrs)) in wait_for_rtrs_connection()
838 if (IS_ERR_OR_NULL(sess->rtrs)) { in wait_for_rtrs_disconnection()
865 if (sess->rtrs_ready && IS_ERR_OR_NULL(sess->rtrs)) in __find_and_get_sess()
992 struct rtrs_clt_sess *rtrs = dev->sess->rtrs; in rnbd_client_xfer_request() local
1030 err = rtrs_clt_request(rq_data_dir(rq), &req_ops, rtrs, permit, in rnbd_client_xfer_request()
1163 return rtrs_clt_rdma_cq_direct(dev->sess->rtrs, hctx->queue_num); in rnbd_rdma_poll()
1267 sess->rtrs = rtrs_clt_open(&rtrs_ops, sessname, in find_and_get_or_create_sess()
1272 if (IS_ERR(sess->rtrs)) { in find_and_get_or_create_sess()
1273 err = PTR_ERR(sess->rtrs); in find_and_get_or_create_sess()
1277 err = rtrs_clt_query(sess->rtrs, &attrs); in find_and_get_or_create_sess()
1601 ret = send_usr_msg(sess->rtrs, READ, iu, in rnbd_clt_map_device()
1710 if (was_mapped && sess->rtrs) in rnbd_clt_unmap_device()