Lines Matching refs:rep

523 	struct rpcrdma_rep *rep = req->rl_reply;  in rpcrdma_sendctx_done()  local
525 rpcrdma_complete_rqst(rep); in rpcrdma_sendctx_done()
526 rep->rr_rxprt->rx_stats.reply_waits_for_send++; in rpcrdma_sendctx_done()
1121 rpcrdma_is_bcall(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep) in rpcrdma_is_bcall() argument
1125 struct xdr_stream *xdr = &rep->rr_stream; in rpcrdma_is_bcall()
1128 if (rep->rr_proc != rdma_msg) in rpcrdma_is_bcall()
1143 if (*p++ != rep->rr_xid) in rpcrdma_is_bcall()
1159 rpcrdma_bc_receive_call(r_xprt, rep); in rpcrdma_is_bcall()
1262 rpcrdma_decode_msg(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep, in rpcrdma_decode_msg() argument
1265 struct xdr_stream *xdr = &rep->rr_stream; in rpcrdma_decode_msg()
1292 rpcrdma_decode_nomsg(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep) in rpcrdma_decode_nomsg() argument
1294 struct xdr_stream *xdr = &rep->rr_stream; in rpcrdma_decode_nomsg()
1317 rpcrdma_decode_error(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep, in rpcrdma_decode_error() argument
1320 struct xdr_stream *xdr = &rep->rr_stream; in rpcrdma_decode_error()
1352 void rpcrdma_unpin_rqst(struct rpcrdma_rep *rep) in rpcrdma_unpin_rqst() argument
1354 struct rpc_xprt *xprt = &rep->rr_rxprt->rx_xprt; in rpcrdma_unpin_rqst()
1355 struct rpc_rqst *rqst = rep->rr_rqst; in rpcrdma_unpin_rqst()
1359 rep->rr_rqst = NULL; in rpcrdma_unpin_rqst()
1374 void rpcrdma_complete_rqst(struct rpcrdma_rep *rep) in rpcrdma_complete_rqst() argument
1376 struct rpcrdma_xprt *r_xprt = rep->rr_rxprt; in rpcrdma_complete_rqst()
1378 struct rpc_rqst *rqst = rep->rr_rqst; in rpcrdma_complete_rqst()
1381 switch (rep->rr_proc) { in rpcrdma_complete_rqst()
1383 status = rpcrdma_decode_msg(r_xprt, rep, rqst); in rpcrdma_complete_rqst()
1386 status = rpcrdma_decode_nomsg(r_xprt, rep); in rpcrdma_complete_rqst()
1389 status = rpcrdma_decode_error(r_xprt, rep, rqst); in rpcrdma_complete_rqst()
1405 trace_xprtrdma_reply_hdr_err(rep); in rpcrdma_complete_rqst()
1427 void rpcrdma_reply_handler(struct rpcrdma_rep *rep) in rpcrdma_reply_handler() argument
1429 struct rpcrdma_xprt *r_xprt = rep->rr_rxprt; in rpcrdma_reply_handler()
1444 xdr_init_decode(&rep->rr_stream, &rep->rr_hdrbuf, in rpcrdma_reply_handler()
1445 rep->rr_hdrbuf.head[0].iov_base, NULL); in rpcrdma_reply_handler()
1446 p = xdr_inline_decode(&rep->rr_stream, 4 * sizeof(*p)); in rpcrdma_reply_handler()
1449 rep->rr_xid = *p++; in rpcrdma_reply_handler()
1450 rep->rr_vers = *p++; in rpcrdma_reply_handler()
1452 rep->rr_proc = *p++; in rpcrdma_reply_handler()
1454 if (rep->rr_vers != rpcrdma_version) in rpcrdma_reply_handler()
1457 if (rpcrdma_is_bcall(r_xprt, rep)) in rpcrdma_reply_handler()
1464 rqst = xprt_lookup_rqst(xprt, rep->rr_xid); in rpcrdma_reply_handler()
1482 req->rl_reply = rep; in rpcrdma_reply_handler()
1483 rep->rr_rqst = rqst; in rpcrdma_reply_handler()
1485 trace_xprtrdma_reply(rqst->rq_task, rep, credits); in rpcrdma_reply_handler()
1487 if (rep->rr_wc_flags & IB_WC_WITH_INVALIDATE) in rpcrdma_reply_handler()
1488 frwr_reminv(rep, &req->rl_registered); in rpcrdma_reply_handler()
1497 trace_xprtrdma_reply_vers_err(rep); in rpcrdma_reply_handler()
1502 trace_xprtrdma_reply_rqst_err(rep); in rpcrdma_reply_handler()
1506 trace_xprtrdma_reply_short_err(rep); in rpcrdma_reply_handler()
1509 rpcrdma_rep_put(buf, rep); in rpcrdma_reply_handler()