mpidi_printf.c

来自「mpi并行计算的c++代码 可用vc或gcc编译通过 可以用来搭建并行计算试验环」· C语言 代码 · 共 338 行 · 第 1/2 页

		MPIU_DBG_PRINTF((" count ........ %d\n", pkt->get.count));
		MPIU_DBG_PRINTF((" datatype ..... 0x%08X\n", pkt->get.datatype));
		MPIU_DBG_PRINTF((" dataloop_size. %d\n", pkt->get.dataloop_size));
		MPIU_DBG_PRINTF((" request ...... 0x%08X\n", pkt->get.request_handle));
		MPIU_DBG_PRINTF((" target ....... 0x%08X\n", pkt->get.target_win_handle));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->get.source_win_handle));
		/*
		MPIU_DBG_PRINTF((" request ...... 0x%08X\n", pkt->get.request));
		MPIU_DBG_PRINTF((" win_ptr ...... 0x%08X\n", pkt->get.win_ptr));
		*/
		break;
	    case MPIDI_CH3_PKT_GET_RESP:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_GET_RESP\n"));
		MPIU_DBG_PRINTF((" request ...... 0x%08X\n", pkt->get_resp.request_handle));
		/*MPIU_DBG_PRINTF((" request ...... 0x%08X\n", pkt->get_resp.request));*/
		break;
	    case MPIDI_CH3_PKT_ACCUMULATE:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_ACCUMULATE\n"));
		MPIU_DBG_PRINTF((" addr ......... %p\n", pkt->accum.addr));
		MPIU_DBG_PRINTF((" count ........ %d\n", pkt->accum.count));
		MPIU_DBG_PRINTF((" datatype ..... 0x%08X\n", pkt->accum.datatype));
		MPIU_DBG_PRINTF((" dataloop_size. %d\n", pkt->accum.dataloop_size));
		MPIU_DBG_PRINTF((" op ........... 0x%08X\n", pkt->accum.op));
		MPIU_DBG_PRINTF((" target ....... 0x%08X\n", pkt->accum.target_win_handle));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->accum.source_win_handle));
		/*MPIU_DBG_PRINTF((" win_ptr ...... 0x%08X\n", pkt->accum.win_ptr));*/
		break;
	    case MPIDI_CH3_PKT_LOCK:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_LOCK\n"));
		MPIU_DBG_PRINTF((" lock_type .... %d\n", pkt->lock.lock_type));
		MPIU_DBG_PRINTF((" target ....... 0x%08X\n", pkt->lock.target_win_handle));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->lock.source_win_handle));
		break;
	    case MPIDI_CH3_PKT_LOCK_PUT_UNLOCK:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_LOCK_PUT_UNLOCK\n"));
		MPIU_DBG_PRINTF((" addr ......... %p\n", pkt->lock_put_unlock.addr));
		MPIU_DBG_PRINTF((" count ........ %d\n", pkt->lock_put_unlock.count));
		MPIU_DBG_PRINTF((" datatype ..... 0x%08X\n", pkt->lock_put_unlock.datatype));
		MPIU_DBG_PRINTF((" lock_type .... %d\n", pkt->lock_put_unlock.lock_type));
		MPIU_DBG_PRINTF((" target ....... 0x%08X\n", pkt->lock_put_unlock.target_win_handle));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->lock_put_unlock.source_win_handle));
		break;
	    case MPIDI_CH3_PKT_LOCK_ACCUM_UNLOCK:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_LOCK_ACCUM_UNLOCK\n"));
		MPIU_DBG_PRINTF((" addr ......... %p\n", pkt->lock_accum_unlock.addr));
		MPIU_DBG_PRINTF((" count ........ %d\n", pkt->lock_accum_unlock.count));
		MPIU_DBG_PRINTF((" datatype ..... 0x%08X\n", pkt->lock_accum_unlock.datatype));
		MPIU_DBG_PRINTF((" lock_type .... %d\n", pkt->lock_accum_unlock.lock_type));
		MPIU_DBG_PRINTF((" target ....... 0x%08X\n", pkt->lock_accum_unlock.target_win_handle));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->lock_accum_unlock.source_win_handle));
		break;
	    case MPIDI_CH3_PKT_LOCK_GET_UNLOCK:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_LOCK_GET_UNLOCK\n"));
		MPIU_DBG_PRINTF((" addr ......... %p\n", pkt->lock_get_unlock.addr));
		MPIU_DBG_PRINTF((" count ........ %d\n", pkt->lock_get_unlock.count));
		MPIU_DBG_PRINTF((" datatype ..... 0x%08X\n", pkt->lock_get_unlock.datatype));
		MPIU_DBG_PRINTF((" lock_type .... %d\n", pkt->lock_get_unlock.lock_type));
		MPIU_DBG_PRINTF((" target ....... 0x%08X\n", pkt->lock_get_unlock.target_win_handle));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->lock_get_unlock.source_win_handle));
		MPIU_DBG_PRINTF((" request ...... 0x%08X\n", pkt->lock_get_unlock.request_handle));
		break;
	    case MPIDI_CH3_PKT_PT_RMA_DONE:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_PT_RMA_DONE\n"));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->lock_accum_unlock.source_win_handle));
		break;
	    case MPIDI_CH3_PKT_LOCK_GRANTED:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_LOCK_GRANTED\n"));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->lock_granted.source_win_handle));
		break;
		/*
	    case MPIDI_CH3_PKT_SHARED_LOCK_OPS_DONE:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_SHARED_LOCK_OPS_DONE\n"));
		MPIU_DBG_PRINTF((" source ....... 0x%08X\n", pkt->shared_lock_ops_done.source_win_handle));
		break;
		*/
	    case MPIDI_CH3_PKT_FLOW_CNTL_UPDATE:
		MPIU_DBG_PRINTF((" FLOW_CNTRL_UPDATE\n"));
		break;
#ifdef MPIDI_CH3_CHANNEL_RNDV
	    case MPIDI_CH3_PKT_RTS_IOV:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_RTS_IOV\n"));
		MPIU_DBG_PRINTF((" sreq ......... 0x%08X\n", pkt->rts_iov.sreq));
		MPIU_DBG_PRINTF((" iov_len ...... %d\n", pkt->rts_iov.iov_len));
		break;
	    case MPIDI_CH3_PKT_CTS_IOV:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_CTS_IOV\n"));
		MPIU_DBG_PRINTF((" sreq ......... 0x%08X\n", pkt->cts_iov.sreq));
		MPIU_DBG_PRINTF((" rreq ......... 0x%08X\n", pkt->cts_iov.rreq));
		MPIU_DBG_PRINTF((" iov_len ...... %d\n", pkt->cts_iov.iov_len));
		break;
	    case MPIDI_CH3_PKT_RELOAD:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_RELOAD\n"));
		MPIU_DBG_PRINTF((" send_recv .... %d\n", pkt->reload.send_recv));
		MPIU_DBG_PRINTF((" sreq ......... 0x%08X\n", pkt->reload.sreq));
		MPIU_DBG_PRINTF((" rreq ......... 0x%08X\n", pkt->reload.rreq));
		break;
	    case MPIDI_CH3_PKT_IOV:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_IOV\n"));
		MPIU_DBG_PRINTF((" req .......... 0x%08X\n", pkt->iov.req));
		MPIU_DBG_PRINTF((" send_recv .... %d\n", pkt->iov.send_recv));
		MPIU_DBG_PRINTF((" iov_len ...... %d\n", pkt->iov.iov_len));
		break;
#endif
	    case MPIDI_CH3_PKT_CLOSE:
		MPIU_DBG_PRINTF((" type ......... MPIDI_CH3_PKT_CLOSE\n"));
		MPIU_DBG_PRINTF((" ack ......... %s\n", pkt->close.ack ? "TRUE" : "FALSE"));
		break;
	    
	    default:
		MPIU_DBG_PRINTF((" INVALID PACKET\n"));
		MPIU_DBG_PRINTF((" unknown type ... %d\n", pkt->type));
		MPIU_DBG_PRINTF(("  type .......... EAGER_SEND\n"));
		MPIU_DBG_PRINTF(("   sender_reqid . 0x%08X\n", pkt->eager_send.sender_req_id));
		MPIU_DBG_PRINTF(("   context_id ... %d\n", pkt->eager_send.match.context_id));
		MPIU_DBG_PRINTF(("   data_sz ...... %d\n", pkt->eager_send.data_sz));
		MPIU_DBG_PRINTF(("   tag .......... %d\n", pkt->eager_send.match.tag));
		MPIU_DBG_PRINTF(("   rank ......... %d\n", pkt->eager_send.match.rank));
#ifdef MPID_USE_SEQUENCE_NUMBERS
		MPIU_DBG_PRINTF(("   seqnum ....... %d\n", pkt->eager_send.seqnum));
#endif
		MPIU_DBG_PRINTF(("  type .......... REQ_TO_SEND\n"));
		MPIU_DBG_PRINTF(("   sender_reqid . 0x%08X\n", pkt->rndv_req_to_send.sender_req_id));
		MPIU_DBG_PRINTF(("   context_id ... %d\n", pkt->rndv_req_to_send.match.context_id));
		MPIU_DBG_PRINTF(("   data_sz ...... %d\n", pkt->rndv_req_to_send.data_sz));
		MPIU_DBG_PRINTF(("   tag .......... %d\n", pkt->rndv_req_to_send.match.tag));
		MPIU_DBG_PRINTF(("   rank ......... %d\n", pkt->rndv_req_to_send.match.rank));
#ifdef MPID_USE_SEQUENCE_NUMBERS
		MPIU_DBG_PRINTF(("   seqnum ....... %d\n", pkt->rndv_req_to_send.seqnum));
#endif
		MPIU_DBG_PRINTF(("  type .......... CLR_TO_SEND\n"));
		MPIU_DBG_PRINTF(("   sender_reqid . 0x%08X\n", pkt->rndv_clr_to_send.sender_req_id));
		MPIU_DBG_PRINTF(("   recvr_reqid .. 0x%08X\n", pkt->rndv_clr_to_send.receiver_req_id));
		MPIU_DBG_PRINTF(("  type .......... RNDV_SEND\n"));
		MPIU_DBG_PRINTF(("   recvr_reqid .. 0x%08X\n", pkt->rndv_send.receiver_req_id));
		MPIU_DBG_PRINTF(("  type .......... CANCEL_SEND\n"));
		MPIU_DBG_PRINTF(("   context_id ... %d\n", pkt->cancel_send_req.match.context_id));
		MPIU_DBG_PRINTF(("   tag .......... %d\n", pkt->cancel_send_req.match.tag));
		MPIU_DBG_PRINTF(("   rank ......... %d\n", pkt->cancel_send_req.match.rank));
		MPIU_DBG_PRINTF(("   sender_reqid . 0x%08X\n", pkt->cancel_send_req.sender_req_id));
		MPIU_DBG_PRINTF(("  type .......... CANCEL_SEND_RESP\n"));
		MPIU_DBG_PRINTF(("   sender_reqid . 0x%08X\n", pkt->cancel_send_resp.sender_req_id));
		MPIU_DBG_PRINTF(("   ack .......... %d\n", pkt->cancel_send_resp.ack));
		break;
	}
    }
    MPID_Common_thread_unlock();
}
#endif


const char * MPIDI_VC_Get_state_description(int state)
{
    switch (state)
    {
	case MPIDI_VC_STATE_INACTIVE:
	    return "MPIDI_VC_STATE_INACTIVE";
	case MPIDI_VC_STATE_ACTIVE:
	    return "MPIDI_VC_STATE_ACTIVE";
	case MPIDI_VC_STATE_LOCAL_CLOSE:
	    return "MPIDI_VC_STATE_LOCAL_CLOSE";
	case MPIDI_VC_STATE_REMOTE_CLOSE:
	    return "MPIDI_VC_STATE_REMOTE_CLOSE";
	case MPIDI_VC_STATE_CLOSE_ACKED:
	    return "MPIDI_VC_STATE_CLOSE_ACKED";
	default:
	    return "unknown";
    }
}