Lines Matching refs:rtrs
318 permit = rtrs_clt_get_permit(sess->rtrs, con_type, in rnbd_get_permit()
335 rtrs_clt_put_permit(sess->rtrs, permit); in rnbd_put_permit()
425 static int send_usr_msg(struct rtrs_clt *rtrs, int dir, in send_usr_msg() argument
439 err = rtrs_clt_request(dir, &req_ops, rtrs, iu->permit, in send_usr_msg()
485 err = send_usr_msg(sess->rtrs, WRITE, iu, &vec, 0, NULL, 0, in send_msg_close()
573 err = send_usr_msg(sess->rtrs, READ, iu, in send_msg_open()
627 err = send_usr_msg(sess->rtrs, READ, iu, in send_msg_sess_info()
682 err = rtrs_clt_query(sess->rtrs, &attrs); in remap_devs()
760 if (!IS_ERR_OR_NULL(sess->rtrs)) { in close_rtrs()
761 rtrs_clt_close(sess->rtrs); in close_rtrs()
762 sess->rtrs = NULL; in close_rtrs()
834 if (IS_ERR_OR_NULL(sess->rtrs)) in wait_for_rtrs_connection()
847 if (IS_ERR_OR_NULL(sess->rtrs)) { in wait_for_rtrs_disconnection()
874 if (sess->rtrs_ready && IS_ERR_OR_NULL(sess->rtrs)) in __find_and_get_sess()
1001 struct rtrs_clt *rtrs = dev->sess->rtrs; in rnbd_client_xfer_request() local
1040 err = rtrs_clt_request(rq_data_dir(rq), &req_ops, rtrs, permit, in rnbd_client_xfer_request()
1208 sess->rtrs = rtrs_clt_open(&rtrs_ops, sessname, in find_and_get_or_create_sess()
1214 if (IS_ERR(sess->rtrs)) { in find_and_get_or_create_sess()
1215 err = PTR_ERR(sess->rtrs); in find_and_get_or_create_sess()
1219 err = rtrs_clt_query(sess->rtrs, &attrs); in find_and_get_or_create_sess()
1606 if (was_mapped && sess->rtrs) in rnbd_clt_unmap_device()