lvm/rpc.mdcommd/mdmn_subr.c

553 	md_mn_mce_t	*mce;
556 	mce = mdmn_get_mce_by_msg(msg);
557 	if (mce == (md_mn_mce_t *)-1) {
560 	offset_in_page = (uint_t)(caddr_t)mce % sysconf(_SC_PAGESIZE);
562 	(void) memset(mce, 0, sizeof (md_mn_mce_t));
564 	MSGID_COPY(&msg->msg_msgid, &mce->mce_result.mmr_msgid);
566 		mce->mce_flags = MDMN_MCT_IN_PROGRESS;
583 	mce->mce_flags = MDMN_MCT_DONE;
585 	mce->mce_result.mmr_msgtype	    = result->mmr_msgtype;
586 	mce->mce_result.mmr_setno	    = result->mmr_setno;
587 	mce->mce_result.mmr_flags	    = result->mmr_flags;
588 	mce->mce_result.mmr_sender	    = result->mmr_sender;
589 	mce->mce_result.mmr_failing_node    = result->mmr_failing_node;
590 	mce->mce_result.mmr_comm_state	    = result->mmr_comm_state;
591 	mce->mce_result.mmr_exitval	    = result->mmr_exitval;
596 			(void) memcpy(mce->mce_data, result->mmr_out,
598 			mce->mce_result.mmr_out_size = result->mmr_out_size;
602 			mce->mce_result.mmr_err_size = result->mmr_err_size;
603 			(void) memcpy(mce->mce_data, result->mmr_err,
612 	(void) msync((caddr_t)mce - offset_in_page,
632 	md_mn_mce_t	*mce;
636 	mce = mdmn_get_mce_by_msg(msg);
637 	if (mce == (md_mn_mce_t *)MDMN_MCT_ERROR) {
640 	if (MSGID_CMP(&(msg->msg_msgid), &(mce->mce_result.mmr_msgid))) {
642 		if (mce->mce_flags & MDMN_MCT_IN_PROGRESS) {
655 		if ((mce->mce_flags & MDMN_MCT_DONE) == 0) {
667 		MSGID_COPY(&(mce->mce_result.mmr_msgid), &result->mmr_msgid);
668 		result->mmr_msgtype	    = mce->mce_result.mmr_msgtype;
669 		result->mmr_setno	    = mce->mce_result.mmr_setno;
670 		result->mmr_flags	    = mce->mce_result.mmr_flags;
671 		result->mmr_sender	    = mce->mce_result.mmr_sender;
672 		result->mmr_failing_node    = mce->mce_result.mmr_failing_node;
673 		result->mmr_comm_state	    = mce->mce_result.mmr_comm_state;
674 		result->mmr_exitval	    = mce->mce_result.mmr_exitval;
677 		outsize = result->mmr_out_size = mce->mce_result.mmr_out_size;
678 		errsize = result->mmr_err_size = mce->mce_result.mmr_err_size;
686 				(void) memcpy(result->mmr_out, mce->mce_data,
692 				(void) memcpy(result->mmr_err, mce->mce_data,