Lines Matching defs:rtrs
294 permit = rtrs_clt_get_permit(sess->rtrs, con_type, wait);
309 rtrs_clt_put_permit(sess->rtrs, permit);
341 * released (rtrs_permit returned to rtrs) only after both
408 static int send_usr_msg(struct rtrs_clt_sess *rtrs, int dir,
422 err = rtrs_clt_request(dir, &req_ops, rtrs, iu->permit,
467 err = send_usr_msg(sess->rtrs, WRITE, iu, &vec, 0, NULL, 0,
562 err = send_usr_msg(sess->rtrs, READ, iu,
615 err = send_usr_msg(sess->rtrs, READ, iu,
673 err = rtrs_clt_query(sess->rtrs, &attrs);
751 if (!IS_ERR_OR_NULL(sess->rtrs)) {
752 rtrs_clt_close(sess->rtrs);
753 sess->rtrs = NULL;
825 if (IS_ERR_OR_NULL(sess->rtrs))
838 if (IS_ERR_OR_NULL(sess->rtrs)) {
865 if (sess->rtrs_ready && IS_ERR_OR_NULL(sess->rtrs))
992 struct rtrs_clt_sess *rtrs = dev->sess->rtrs;
1030 err = rtrs_clt_request(rq_data_dir(rq), &req_ops, rtrs, permit,
1163 return rtrs_clt_rdma_cq_direct(dev->sess->rtrs, hctx->queue_num);
1265 * Nothing was found, establish rtrs connection and proceed further.
1267 sess->rtrs = rtrs_clt_open(&rtrs_ops, sessname,
1269 0, /* Do not use pdu of rtrs */
1272 if (IS_ERR(sess->rtrs)) {
1273 err = PTR_ERR(sess->rtrs);
1277 err = rtrs_clt_query(sess->rtrs, &attrs);
1601 ret = send_usr_msg(sess->rtrs, READ, iu,
1710 if (was_mapped && sess->rtrs)