drain_msg_ref 282 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_grab_content(ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref, drain_msg_ref 299 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_copy_remove_persistent(ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref, drain_msg_ref 434 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int ft_event_post_drain_message(ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref, drain_msg_ref 1261 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref = NULL; drain_msg_ref 1280 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &drain_msg_ref, drain_msg_ref 1293 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != drain_msg_ref ) { drain_msg_ref 1330 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref = NULL; drain_msg_ref 1349 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &drain_msg_ref, drain_msg_ref 1361 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != drain_msg_ref ) { drain_msg_ref 2065 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref = NULL; drain_msg_ref 2139 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &drain_msg_ref, drain_msg_ref 2148 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &drain_msg_ref, drain_msg_ref 2160 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != drain_msg_ref ) { drain_msg_ref 2165 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = drain_message_copy_remove_persistent(drain_msg_ref, drain_msg_ref 3475 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref = NULL; drain_msg_ref 3516 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &drain_msg_ref); drain_msg_ref 3564 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c opal_list_append(&(drain_msg_ref->msg_contents), &(new_content->super) ); drain_msg_ref 3572 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->active++; drain_msg_ref 3573 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->already_posted++; drain_msg_ref 3585 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_datatype_duplicate(&(ompi_mpi_packed.dt), &(drain_msg_ref->datatype)); drain_msg_ref 3588 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if(drain_msg_ref->count > 0 ) { drain_msg_ref 3589 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c new_content->buffer = (void *) malloc(drain_msg_ref->count * drain_msg_ref->ddt_size); drain_msg_ref 3591 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c new_content->buffer = (void *) malloc(1 * drain_msg_ref->ddt_size); drain_msg_ref 3845 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref = NULL; drain_msg_ref 3858 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &drain_msg_ref, drain_msg_ref 3872 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( NULL != drain_msg_ref ) { drain_msg_ref 3876 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = drain_message_copy_remove(drain_msg_ref, drain_msg_ref 4026 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_grab_content(ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref, drain_msg_ref 4034 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(item = opal_list_get_first(&(drain_msg_ref->msg_contents)); drain_msg_ref 4035 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c item != opal_list_get_end(&(drain_msg_ref->msg_contents)); drain_msg_ref 4050 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_copy_remove_persistent(ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref, drain_msg_ref 4072 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( 0 != (ret = ompi_datatype_copy_content_same_ddt(drain_msg_ref->datatype, drain_msg_ref 4073 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->count, drain_msg_ref 4084 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_message_remove(peer_ref, drain_msg_ref, drain_content_ref); drain_msg_ref 4089 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int drain_message_copy_remove(ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref, drain_msg_ref 4100 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c *src = drain_msg_ref->rank; drain_msg_ref 4104 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c *tag = drain_msg_ref->tag; drain_msg_ref 4133 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_message_remove(peer_ref, drain_msg_ref, drain_content_ref); drain_msg_ref 4802 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t * drain_msg_ref = NULL; drain_msg_ref 4822 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref = (ompi_crcp_bkmrk_pml_drain_message_ref_t*)d_item; drain_msg_ref 4824 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(c_item = opal_list_get_first(&(drain_msg_ref->msg_contents)); drain_msg_ref 4825 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c c_item != opal_list_get_end(&(drain_msg_ref->msg_contents)); drain_msg_ref 4887 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref = (ompi_crcp_bkmrk_pml_drain_message_ref_t*)d_item; drain_msg_ref 4889 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(c_item = opal_list_get_first(&(drain_msg_ref->msg_contents)); drain_msg_ref 4890 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c c_item != opal_list_get_end(&(drain_msg_ref->msg_contents)); drain_msg_ref 4898 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( OMPI_SUCCESS != (ret = ft_event_post_drain_message(drain_msg_ref, content_ref) ) ) { drain_msg_ref 4937 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c static int ft_event_post_drain_message(ompi_crcp_bkmrk_pml_drain_message_ref_t *drain_msg_ref, drain_msg_ref 4957 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(drain_msg_ref->proc_name)) )); drain_msg_ref 4963 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->active++; drain_msg_ref 4971 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(drain_msg_ref->proc_name)), drain_msg_ref 4972 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->rank)); drain_msg_ref 4974 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c (drain_msg_ref->count * drain_msg_ref->ddt_size), drain_msg_ref 4975 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->datatype, drain_msg_ref 4976 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->rank, drain_msg_ref 4977 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->tag, drain_msg_ref 4978 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->comm, drain_msg_ref 4983 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(drain_msg_ref->proc_name)) ); drain_msg_ref 5025 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t * drain_msg_ref = NULL; drain_msg_ref 5110 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref = (ompi_crcp_bkmrk_pml_drain_message_ref_t*)d_item; drain_msg_ref 5113 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(c_item = opal_list_get_first(&(drain_msg_ref->msg_contents)); drain_msg_ref 5114 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c c_item != opal_list_get_end(&(drain_msg_ref->msg_contents)); drain_msg_ref 5128 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_message_remove(cur_peer_ref, drain_msg_ref, content_ref); drain_msg_ref 5131 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->active--; drain_msg_ref 5132 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->already_posted--; drain_msg_ref 5138 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->done++; drain_msg_ref 5139 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref->active--; drain_msg_ref 6456 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_drain_message_ref_t * drain_msg_ref = NULL; drain_msg_ref 6465 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_msg_ref = (ompi_crcp_bkmrk_pml_drain_message_ref_t*)item; drain_msg_ref 6466 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c traffic_message_dump_drain_msg_indv(drain_msg_ref, "Drain", false);