Cross Reference: /drivers/staging/lustre/lnet/selftest/brw

Lines Matching refs:rpc
261 	srpc_client_rpc_t   *rpc;
293 	rc = sfw_create_test_rpc(tsu, dest, sn->sn_features, npg, len, &rpc);
297 	memcpy(&rpc->crpc_bulk, bulk, offsetof(srpc_bulk_t, bk_iovs[npg]));
299 		brw_fill_bulk(&rpc->crpc_bulk, flags, BRW_MAGIC);
301 		brw_fill_bulk(&rpc->crpc_bulk, flags, BRW_POISON);
303 	req = &rpc->crpc_reqstmsg.msg_body.brw_reqst;
308 	*rpcpp = rpc;
313 brw_client_done_rpc(sfw_test_unit_t *tsu, srpc_client_rpc_t *rpc)
318 	srpc_msg_t	  *msg = &rpc->crpc_replymsg;
320 	srpc_brw_reqst_t    *reqst = &rpc->crpc_reqstmsg.msg_body.brw_reqst;
324 	if (rpc->crpc_status != 0) {
326 			libcfs_id2str(rpc->crpc_dest), rpc->crpc_status);
327 		if (!tsi->tsi_stopping) /* rpc could have been aborted */
339 		libcfs_id2str(rpc->crpc_dest), reply->brw_status);
343 		rpc->crpc_status = -(int)reply->brw_status;
350 	if (brw_check_bulk(&rpc->crpc_bulk, reqst->brw_flags, magic) != 0) {
352 			libcfs_id2str(rpc->crpc_dest));
354 		rpc->crpc_status = -EBADMSG;
362 brw_server_rpc_done(srpc_server_rpc_t *rpc)
364 	srpc_bulk_t *blk = rpc->srpc_bulk;
369 	if (rpc->srpc_status != 0)
372 			libcfs_id2str(rpc->srpc_peer), rpc->srpc_status);
376 			libcfs_id2str(rpc->srpc_peer));
378 	sfw_free_pages(rpc);
382 brw_bulk_ready(srpc_server_rpc_t *rpc, int status)
385 	srpc_brw_reply_t *reply = &rpc->srpc_replymsg.msg_body.brw_reply;
389 	LASSERT(rpc->srpc_bulk != NULL);
390 	LASSERT(rpc->srpc_reqstbuf != NULL);
392 	reqstmsg = &rpc->srpc_reqstbuf->buf_msg;
398 			libcfs_id2str(rpc->srpc_peer), status);
408 	if (brw_check_bulk(rpc->srpc_bulk, reqst->brw_flags, magic) != 0) {
410 			libcfs_id2str(rpc->srpc_peer));
418 brw_server_handle(struct srpc_server_rpc *rpc)
420 	struct srpc_service	*sv = rpc->srpc_scd->scd_svc;
421 	srpc_msg_t       *replymsg = &rpc->srpc_replymsg;
422 	srpc_msg_t       *reqstmsg = &rpc->srpc_reqstbuf->buf_msg;
442 	rpc->srpc_done = brw_server_rpc_done;
477 	rc = sfw_alloc_pages(rpc, rpc->srpc_scd->scd_cpt, npg,
484 		brw_fill_bulk(rpc->srpc_bulk, reqst->brw_flags, BRW_MAGIC);
486 		brw_fill_bulk(rpc->srpc_bulk, reqst->brw_flags, BRW_POISON);