peer_ref 136 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 139 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 142 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 145 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 151 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_append(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 166 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 215 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_find_recv(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 229 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 236 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_append(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 246 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_remove(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 277 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t **peer_ref); peer_ref 294 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref); peer_ref 303 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref); peer_ref 314 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t **peer_ref); peer_ref 366 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int send_msg_details(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 373 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int do_send_msg_detail(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 382 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int recv_msg_details(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 388 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int do_recv_msg_detail(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 398 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int do_recv_msg_detail_check_drain(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 407 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int do_recv_msg_detail_resp(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 565 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static void traffic_message_dump_peer(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, char * msg, bool root_only); peer_ref 623 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define HOKE_PEER_REF_ALLOC(peer_ref) \ peer_ref 625 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t *) \ peer_ref 629 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c #define HOKE_PEER_REF_RETURN(peer_ref) \ peer_ref 632 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (opal_free_list_item_t*)peer_ref); \ peer_ref 698 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c void ompi_crcp_bkmrk_pml_peer_ref_construct(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref) { peer_ref 699 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.jobid = ORTE_JOBID_INVALID; peer_ref 700 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.vpid = ORTE_VPID_INVALID; peer_ref 702 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&peer_ref->send_list, opal_list_t); peer_ref 703 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&peer_ref->isend_list, opal_list_t); peer_ref 704 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&peer_ref->send_init_list, opal_list_t); peer_ref 706 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&peer_ref->recv_list, opal_list_t); peer_ref 707 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&peer_ref->irecv_list, opal_list_t); peer_ref 708 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&peer_ref->recv_init_list, opal_list_t); peer_ref 710 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_CONSTRUCT(&peer_ref->drained_list, opal_list_t); peer_ref 712 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent = 0; peer_ref 713 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent = 0; peer_ref 715 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd = 0; peer_ref 716 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_recvd = 0; peer_ref 718 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_drained_msgs = 0; peer_ref 720 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->ack_required = false; peer_ref 723 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c void ompi_crcp_bkmrk_pml_peer_ref_destruct( ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref) { peer_ref 726 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.jobid = ORTE_JOBID_INVALID; peer_ref 727 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.vpid = ORTE_VPID_INVALID; peer_ref 729 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&peer_ref->send_list)) ) { peer_ref 732 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&peer_ref->send_list); peer_ref 733 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&peer_ref->isend_list)) ) { peer_ref 736 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&peer_ref->isend_list); peer_ref 737 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&peer_ref->send_init_list)) ) { peer_ref 740 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&peer_ref->send_init_list); peer_ref 742 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&peer_ref->recv_list)) ) { peer_ref 745 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&peer_ref->recv_list); peer_ref 746 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&peer_ref->irecv_list)) ) { peer_ref 749 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&peer_ref->irecv_list); peer_ref 750 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&peer_ref->recv_init_list)) ) { peer_ref 753 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&peer_ref->recv_init_list); peer_ref 755 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c while( NULL != (item = opal_list_remove_first(&peer_ref->drained_list)) ) { peer_ref 758 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_DESTRUCT(&peer_ref->drained_list); peer_ref 760 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent = 0; peer_ref 761 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent = 0; peer_ref 763 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd = 0; peer_ref 764 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_recvd = 0; peer_ref 766 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_drained_msgs = 0; peer_ref 768 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->ack_required = false; peer_ref 992 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c coord_state->peer_ref = v_peer_ref; \ peer_ref 1000 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c v_peer_ref = v_coord_state->peer_ref; \ peer_ref 1510 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 1527 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(comm, dst, &peer_ref) ) ){ peer_ref 1537 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_append(peer_ref, &(peer_ref->send_init_list), peer_ref 1544 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 1557 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 1586 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 1600 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &peer_ref) ) ){ peer_ref 1608 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->send_init_list), peer_ref 1629 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, peer_ref 1631 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(peer_ref->send_init_list), peer_ref 1636 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent += 1; peer_ref 1645 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 1656 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->send_init_list), peer_ref 1684 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref->total_msgs_recvd, peer_ref 1696 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Request Complete (Send_init) --", true)); peer_ref 1708 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref->total_msgs_recvd)); peer_ref 1723 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 1740 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(comm, dst, &peer_ref) ) ){ peer_ref 1750 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_append(peer_ref, &(peer_ref->isend_list), peer_ref 1756 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent += 1; peer_ref 1760 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 1773 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 1788 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Append Message (isend) --", true)); peer_ref 1802 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 1813 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->isend_list), peer_ref 1841 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref->total_msgs_recvd, peer_ref 1849 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent)); peer_ref 1863 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Request Complete (iSend) --", true)); peer_ref 1867 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref->total_msgs_recvd)); peer_ref 1881 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 1898 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(comm, dst, &peer_ref) ) ){ peer_ref 1908 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_append(peer_ref, &(peer_ref->send_list), peer_ref 1914 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent += 1; peer_ref 1920 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 1932 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 1943 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "Send done", true)); peer_ref 1965 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 2003 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(comm, src, &peer_ref) ) ){ peer_ref 2013 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_append(peer_ref, &(peer_ref->recv_init_list), peer_ref 2019 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 2034 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 2063 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 2081 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &peer_ref) ) ){ peer_ref 2088 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->recv_init_list), peer_ref 2135 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != peer_ref ) { peer_ref 2136 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = drain_message_find(&(peer_ref->drained_list), peer_ref 2150 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &peer_ref) ) ) { peer_ref 2169 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref) ) ) { peer_ref 2175 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_drained_msgs -= 1; peer_ref 2185 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 2199 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &peer_ref) ) ){ peer_ref 2206 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->recv_init_list), peer_ref 2223 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, peer_ref 2225 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(peer_ref->recv_init_list), peer_ref 2268 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 2281 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->recv_init_list), peer_ref 2318 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, &(peer_ref->recv_init_list), peer_ref 2343 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref->total_msgs_recvd, peer_ref 2363 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += 1; peer_ref 2374 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Request Complete (Recv_Init) --", true)); peer_ref 2376 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Request Complete (Recv_init - Unknown) --", true)); peer_ref 2381 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref->total_msgs_recvd)); peer_ref 2395 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 2452 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(comm, src, &peer_ref) ) ){ peer_ref 2462 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_append(peer_ref, &(peer_ref->irecv_list), peer_ref 2468 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 2484 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 2499 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Append Message (irecv) --", true)); peer_ref 2513 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 2526 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->irecv_list), peer_ref 2563 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, &(peer_ref->irecv_list), peer_ref 2588 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref->total_msgs_recvd, peer_ref 2600 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += 1; peer_ref 2611 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Request Complete (iRecv) --", true)); peer_ref 2613 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Request Complete (iRecv - Unknown) --", true)); peer_ref 2618 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd)); peer_ref 2632 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 2688 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(comm, src, &peer_ref) ) ){ peer_ref 2695 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_append(peer_ref, &(peer_ref->recv_list), peer_ref 2701 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 2720 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, msg_ref); peer_ref 2726 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == peer_ref ) { peer_ref 2729 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(comm, src, &peer_ref) ) ){ peer_ref 2740 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, &(peer_ref->recv_list), peer_ref 2754 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += 1; peer_ref 2758 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "Recv Done", true)); peer_ref 2883 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 2913 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(breq->req_comm, request->req_status.MPI_SOURCE, &peer_ref) ) ){ peer_ref 2920 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = find_peer_in_comm(breq->req_comm, src, &peer_ref) ) ){ peer_ref 2936 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = ompi_crcp_bkmrk_request_complete_isend(request, peer_ref, peer_ref 2946 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = ompi_crcp_bkmrk_request_complete_isend_init(request, peer_ref, peer_ref 2961 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = ompi_crcp_bkmrk_request_complete_irecv(request, peer_ref, peer_ref 2971 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = ompi_crcp_bkmrk_request_complete_irecv_init(request, peer_ref, peer_ref 3178 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_append(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 3225 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != peer_ref ) { peer_ref 3228 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.jobid, peer_ref 3229 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.vpid); peer_ref 3252 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != peer_ref ) { peer_ref 3254 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Append Message (send) --", true)); peer_ref 3257 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Append Message (send_init) --", true)); peer_ref 3260 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Append Message (recv) --", true)); peer_ref 3263 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Append Message (recv_init) --", true)); peer_ref 3269 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Append Message (Unknown) --", true)); peer_ref 3277 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 3471 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 3500 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 3509 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_message_append(peer_ref, peer_ref 3528 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 3600 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_drained_msgs += *num_posted; peer_ref 3606 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 3608 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (int)opal_list_get_size(&(peer_ref->drained_list)) )); peer_ref 3613 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int traffic_message_find_recv(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 3633 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->recv_list), peer_ref 3646 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->irecv_list), peer_ref 3659 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = traffic_message_find(&(peer_ref->recv_init_list), peer_ref 3767 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_append(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 3782 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = drain_message_find(&(peer_ref->drained_list), peer_ref 3796 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.jobid, peer_ref 3797 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.vpid); peer_ref 3803 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_append(&(peer_ref->drained_list), &((*msg_ref)->super)); peer_ref 3810 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_remove(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 3826 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_remove_item(&(peer_ref->drained_list), &(msg_ref->super)); peer_ref 3844 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref = NULL; peer_ref 3860 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &peer_ref) ) ) { peer_ref 3880 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref) ) ) { peer_ref 3888 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_drained_msgs -= 1; peer_ref 3901 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t **peer_ref) peer_ref 3936 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != peer_ref ) { peer_ref 3937 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c *peer_ref = cur_peer_ref; peer_ref 4054 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref) peer_ref 4084 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_message_remove(peer_ref, drain_msg_ref, drain_content_ref); peer_ref 4095 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref) peer_ref 4133 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_message_remove(peer_ref, drain_msg_ref, drain_content_ref); peer_ref 4166 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t **peer_ref) peer_ref 4168 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c *peer_ref = find_peer(*(ompi_process_name_t *)&comm->c_remote_group->grp_proc_pointers[proc_idx]->super.proc_name); peer_ref 4170 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == *peer_ref) { peer_ref 4313 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref; peer_ref 4314 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; peer_ref 4318 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(peer_ref->proc_name)) ) { peer_ref 4319 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(10, (peer_ref, "finalize_exchange", false)); peer_ref 4322 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent = 0; peer_ref 4323 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd = 0; peer_ref 4325 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent = 0; peer_ref 4326 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_recvd = 0; peer_ref 4328 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->ack_required = false; peer_ref 4331 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(rm_item = opal_list_get_last(&peer_ref->send_list); peer_ref 4332 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rm_item != opal_list_get_begin(&peer_ref->send_list); peer_ref 4351 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(rm_item = opal_list_get_last(&peer_ref->isend_list); peer_ref 4352 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rm_item != opal_list_get_begin(&peer_ref->isend_list); peer_ref 4371 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(rm_item = opal_list_get_last(&peer_ref->send_list); peer_ref 4372 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rm_item != opal_list_get_begin(&peer_ref->send_list); peer_ref 4391 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(rm_item = opal_list_get_last(&peer_ref->recv_list); peer_ref 4392 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rm_item != opal_list_get_begin(&peer_ref->recv_list); peer_ref 4400 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(rm_item = opal_list_get_last(&peer_ref->irecv_list); peer_ref 4401 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rm_item != opal_list_get_begin(&peer_ref->irecv_list); peer_ref 4409 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(rm_item = opal_list_get_last(&peer_ref->recv_list); peer_ref 4410 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rm_item != opal_list_get_begin(&peer_ref->recv_list); peer_ref 4481 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref; peer_ref 4484 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; peer_ref 4486 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c t_send = peer_ref->total_msgs_sent; peer_ref 4487 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c m_send = peer_ref->matched_msgs_sent; peer_ref 4488 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c t_recv = peer_ref->total_msgs_recvd; peer_ref 4489 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c m_recv = peer_ref->matched_msgs_recvd; peer_ref 4494 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.vpid, peer_ref 4509 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref; peer_ref 4510 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; peer_ref 4514 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(peer_ref->proc_name)) ) { peer_ref 4518 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "-- Bookmark Details --", false)); peer_ref 4521 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_PROC_MY_NAME->vpid < peer_ref->proc_name.vpid ) { peer_ref 4526 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c p_n_to_p_m = peer_ref->total_msgs_sent; peer_ref 4527 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c p_n_from_p_m = peer_ref->matched_msgs_recvd; peer_ref 4536 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 4550 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 4560 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = send_msg_details(peer_ref, p_n_to_p_m, p_n_from_p_m) ) ) { peer_ref 4563 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&peer_ref->proc_name), peer_ref 4573 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c p_n_to_p_m = peer_ref->matched_msgs_sent; peer_ref 4574 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c p_n_from_p_m = peer_ref->total_msgs_recvd; peer_ref 4583 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 4597 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 4606 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = recv_msg_details(peer_ref, p_n_to_p_m, p_n_from_p_m) ) ) { peer_ref 4609 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&peer_ref->proc_name), peer_ref 4621 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c p_n_to_p_m = peer_ref->matched_msgs_sent; peer_ref 4622 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c p_n_from_p_m = peer_ref->total_msgs_recvd; peer_ref 4631 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 4645 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 4654 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = recv_msg_details(peer_ref, p_n_to_p_m, p_n_from_p_m) ) ) { peer_ref 4657 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&peer_ref->proc_name), peer_ref 4667 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c p_n_to_p_m = peer_ref->total_msgs_sent; peer_ref 4668 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c p_n_from_p_m = peer_ref->matched_msgs_recvd; peer_ref 4677 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 4691 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 4701 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = send_msg_details(peer_ref, p_n_to_p_m, p_n_from_p_m) ) ) { peer_ref 4704 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&peer_ref->proc_name), peer_ref 5252 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref; peer_ref 5265 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == (peer_ref = find_peer(peer_name))) { peer_ref 5277 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref 5278 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd)); peer_ref 5288 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c PACK_BUFFER(buffer, (peer_ref->total_msgs_sent), 1, OPAL_UINT32, peer_ref 5290 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c PACK_BUFFER(buffer, (peer_ref->total_msgs_recvd), 1, OPAL_UINT32, peer_ref 5343 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref; peer_ref 5353 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL == (peer_ref = find_peer(*sender))) { peer_ref 5363 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent = tmp_int; peer_ref 5367 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_recvd = tmp_int; peer_ref 5373 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent, peer_ref 5374 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_recvd, peer_ref 5375 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref 5376 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd, peer_ref 5385 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int send_msg_details(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 5409 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c search_list = &(peer_ref->send_list); peer_ref 5434 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if(OMPI_SUCCESS != (ret = do_send_msg_detail(peer_ref, msg_ref, &num_matches, &p_total_found, &finished)) ) { peer_ref 5438 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5465 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c search_list = &(peer_ref->isend_list); peer_ref 5475 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c search_list = &(peer_ref->send_init_list); peer_ref 5493 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c d_msg_ack->peer.jobid = peer_ref->proc_name.jobid; peer_ref 5494 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c d_msg_ack->peer.vpid = peer_ref->proc_name.vpid; peer_ref 5501 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)))); peer_ref 5504 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c DISPLAY_INDV_TIMER(CRCP_TIMER_CKPT_CHECK_PEER_S, peer_ref->proc_name.vpid, total_details_sent); peer_ref 5509 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int do_send_msg_detail(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 5575 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if (ORTE_SUCCESS != (ret = ompi_rte_send_buffer_nb(&peer_ref->proc_name, buffer, peer_ref 5580 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&peer_ref->proc_name), peer_ref 5592 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_rte_recv_buffer_nb(&peer_ref->proc_name, OMPI_CRCP_COORD_BOOKMARK_TAG, 0, peer_ref 5638 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int recv_msg_details(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 5669 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = do_recv_msg_detail(peer_ref, peer_ref 5678 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5689 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = do_recv_msg_detail_check_drain(peer_ref, peer_ref 5699 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5711 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5725 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if(OMPI_SUCCESS != (ret = do_recv_msg_detail_resp(peer_ref, response, num_resolved, found))) { peer_ref 5729 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5739 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c DISPLAY_INDV_TIMER(CRCP_TIMER_CKPT_CHECK_PEER_R, peer_ref->proc_name.vpid, total_details_recv); peer_ref 5744 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int do_recv_msg_detail(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 5758 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_rte_recv_buffer_nb(&peer_ref->proc_name, OMPI_CRCP_COORD_BOOKMARK_TAG, 0, orte_rml_recv_callback, rb); peer_ref 5784 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int do_recv_msg_detail_check_drain(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 5811 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5812 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd, peer_ref 5813 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent, peer_ref 5817 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c TRAFFIC_MSG_DUMP_PEER(15, (peer_ref, "Recv Check...", true)); peer_ref 5822 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ret = traffic_message_find_recv(peer_ref, /* Peer to resolve with */ peer_ref 5834 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5884 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5885 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd, peer_ref 5886 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent, peer_ref 5969 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 5970 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd, peer_ref 5971 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent, peer_ref 6018 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)) )); peer_ref 6027 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 6042 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, peer_ref 6047 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += num_posted; peer_ref 6050 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, peer_ref 6055 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += num_posted; peer_ref 6058 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, peer_ref 6063 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += num_posted; peer_ref 6066 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, peer_ref 6071 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += num_posted; peer_ref 6074 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, peer_ref 6079 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += num_posted; peer_ref 6086 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 6087 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd, peer_ref 6088 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent, peer_ref 6105 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.jobid, peer_ref 6106 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->proc_name.vpid); peer_ref 6109 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref, peer_ref 6114 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd += num_posted; peer_ref 6123 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 6124 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd, peer_ref 6125 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent, peer_ref 6137 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int do_recv_msg_detail_resp(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, peer_ref 6156 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if (ORTE_SUCCESS != (ret = ompi_rte_send_buffer_nb(&peer_ref->proc_name, buffer, peer_ref 6161 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&peer_ref->proc_name), peer_ref 6471 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static void traffic_message_dump_peer(ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref, char * msg, bool root_only) peer_ref 6482 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(peer_ref->proc_name)), peer_ref 6483 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_sent, peer_ref 6484 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_sent, peer_ref 6485 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->total_msgs_recvd, peer_ref 6486 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c peer_ref->matched_msgs_recvd); peer_ref 6489 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_msg_list(&(peer_ref->send_list), false); peer_ref 6490 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_msg_list(&(peer_ref->isend_list), false); peer_ref 6491 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_msg_list(&(peer_ref->send_init_list), false); peer_ref 6493 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_msg_list(&(peer_ref->recv_list), false); peer_ref 6494 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_msg_list(&(peer_ref->irecv_list), false); peer_ref 6495 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_msg_list(&(peer_ref->recv_init_list), false); peer_ref 6497 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_msg_list(&(peer_ref->drained_list), true); peer_ref 441 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.h ompi_crcp_bkmrk_pml_peer_ref_t *peer_ref;