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);