Lines Matching refs:xprt
382 struct rpc_xprt *xprt = rqst->rq_xprt; in rpcrdma_marshal_req() local
383 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in rpcrdma_marshal_req()
697 struct rpc_xprt *xprt = &r_xprt->rx_xprt; in rpcrdma_connect_worker() local
699 spin_lock_bh(&xprt->transport_lock); in rpcrdma_connect_worker()
700 if (++xprt->connect_cookie == 0) /* maintain a reserved value */ in rpcrdma_connect_worker()
701 ++xprt->connect_cookie; in rpcrdma_connect_worker()
703 if (!xprt_test_and_set_connected(xprt)) in rpcrdma_connect_worker()
704 xprt_wake_pending_tasks(xprt, 0); in rpcrdma_connect_worker()
706 if (xprt_test_and_clear_connected(xprt)) in rpcrdma_connect_worker()
707 xprt_wake_pending_tasks(xprt, -ENOTCONN); in rpcrdma_connect_worker()
709 spin_unlock_bh(&xprt->transport_lock); in rpcrdma_connect_worker()
735 struct rpc_xprt *xprt = rep->rr_xprt; in rpcrdma_reply_handler() local
736 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); in rpcrdma_reply_handler()
763 spin_lock(&xprt->transport_lock); in rpcrdma_reply_handler()
764 rqst = xprt_lookup_rqst(xprt, headerp->rm_xid); in rpcrdma_reply_handler()
766 spin_unlock(&xprt->transport_lock); in rpcrdma_reply_handler()
783 spin_unlock(&xprt->transport_lock); in rpcrdma_reply_handler()
797 xprt->reestablish_timeout = 0; in rpcrdma_reply_handler()
880 cwnd = xprt->cwnd; in rpcrdma_reply_handler()
881 xprt->cwnd = credits << RPC_CWNDSHIFT; in rpcrdma_reply_handler()
882 if (xprt->cwnd > cwnd) in rpcrdma_reply_handler()
886 __func__, xprt, rqst, status); in rpcrdma_reply_handler()
888 spin_unlock(&xprt->transport_lock); in rpcrdma_reply_handler()