Lines Matching defs:rep
539 struct rpcrdma_rep *rep = req->rl_reply;
541 rpcrdma_complete_rqst(rep);
542 rep->rr_rxprt->rx_stats.reply_waits_for_send++;
1137 rpcrdma_is_bcall(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep)
1141 struct xdr_stream *xdr = &rep->rr_stream;
1144 if (rep->rr_proc != rdma_msg)
1159 if (*p++ != rep->rr_xid)
1175 rpcrdma_bc_receive_call(r_xprt, rep);
1282 rpcrdma_decode_msg(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep,
1285 struct xdr_stream *xdr = &rep->rr_stream;
1312 rpcrdma_decode_nomsg(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep)
1314 struct xdr_stream *xdr = &rep->rr_stream;
1337 rpcrdma_decode_error(struct rpcrdma_xprt *r_xprt, struct rpcrdma_rep *rep,
1340 struct xdr_stream *xdr = &rep->rr_stream;
1355 be32_to_cpu(rep->rr_xid));
1360 be32_to_cpu(rep->rr_xid));
1365 be32_to_cpup(p), be32_to_cpu(rep->rr_xid));
1373 * the rep, rqst, and rq_task pointers remain stable.
1375 void rpcrdma_complete_rqst(struct rpcrdma_rep *rep)
1377 struct rpcrdma_xprt *r_xprt = rep->rr_rxprt;
1379 struct rpc_rqst *rqst = rep->rr_rqst;
1382 switch (rep->rr_proc) {
1384 status = rpcrdma_decode_msg(r_xprt, rep, rqst);
1387 status = rpcrdma_decode_nomsg(r_xprt, rep);
1390 status = rpcrdma_decode_error(r_xprt, rep, rqst);
1406 trace_xprtrdma_reply_hdr(rep);
1423 * @rep: Incoming rpcrdma_rep object to process
1428 void rpcrdma_reply_handler(struct rpcrdma_rep *rep)
1430 struct rpcrdma_xprt *r_xprt = rep->rr_rxprt;
1445 xdr_init_decode(&rep->rr_stream, &rep->rr_hdrbuf,
1446 rep->rr_hdrbuf.head[0].iov_base, NULL);
1447 p = xdr_inline_decode(&rep->rr_stream, 4 * sizeof(*p));
1450 rep->rr_xid = *p++;
1451 rep->rr_vers = *p++;
1453 rep->rr_proc = *p++;
1455 if (rep->rr_vers != rpcrdma_version)
1458 if (rpcrdma_is_bcall(r_xprt, rep))
1465 rqst = xprt_lookup_rqst(xprt, rep->rr_xid);
1485 req->rl_reply = rep;
1486 rep->rr_rqst = rqst;
1488 trace_xprtrdma_reply(rqst->rq_task, rep, req, credits);
1490 if (rep->rr_wc_flags & IB_WC_WITH_INVALIDATE)
1491 frwr_reminv(rep, &req->rl_registered);
1500 trace_xprtrdma_reply_vers(rep);
1505 trace_xprtrdma_reply_rqst(rep);
1509 trace_xprtrdma_reply_short(rep);
1512 rpcrdma_recv_buffer_put(rep);