Lines Matching refs:rpc
90 lnet_process_id_t dest, srpc_client_rpc_t **rpc)
101 rc = sfw_create_test_rpc(tsu, dest, sn->sn_features, 0, 0, rpc);
105 req = &(*rpc)->crpc_reqstmsg.msg_body.ping_reqst;
121 ping_client_done_rpc (sfw_test_unit_t *tsu, srpc_client_rpc_t *rpc)
125 srpc_ping_reqst_t *reqst = &rpc->crpc_reqstmsg.msg_body.ping_reqst;
126 srpc_ping_reply_t *reply = &rpc->crpc_replymsg.msg_body.ping_reply;
131 if (rpc->crpc_status != 0) {
132 if (!tsi->tsi_stopping) /* rpc could have been aborted */
135 libcfs_id2str(rpc->crpc_dest),
136 reqst->pnr_seq, rpc->crpc_status);
140 if (rpc->crpc_replymsg.msg_magic != SRPC_MSG_MAGIC) {
147 rpc->crpc_status = -EBADMSG;
150 reply->pnr_magic, libcfs_id2str(rpc->crpc_dest),
156 rpc->crpc_status = -EBADMSG;
159 reply->pnr_seq, libcfs_id2str(rpc->crpc_dest),
172 ping_server_handle(struct srpc_server_rpc *rpc)
174 struct srpc_service *sv = rpc->srpc_scd->scd_svc;
175 srpc_msg_t *reqstmsg = &rpc->srpc_reqstbuf->buf_msg;
176 srpc_msg_t *replymsg = &rpc->srpc_replymsg;
178 srpc_ping_reply_t *rep = &rpc->srpc_replymsg.msg_body.ping_reply;
194 req->pnr_magic, libcfs_id2str(rpc->srpc_peer));
210 req->pnr_seq, libcfs_id2str(rpc->srpc_peer));