cur_peer_ref 3126 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *cur_peer_ref; cur_peer_ref 3127 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; cur_peer_ref 3130 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref->proc_name.jobid = OMPI_PROC_MY_NAME->jobid; cur_peer_ref 3903 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *cur_peer_ref = NULL; cur_peer_ref 3911 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; cur_peer_ref 3924 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(cur_peer_ref->proc_name), cur_peer_ref 3930 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_message_find(&(cur_peer_ref->drained_list), cur_peer_ref 3937 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c *peer_ref = cur_peer_ref; cur_peer_ref 4150 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *cur_peer_ref; cur_peer_ref 4151 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; cur_peer_ref 4156 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(cur_peer_ref->proc_name), cur_peer_ref 4158 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c return cur_peer_ref; cur_peer_ref 4801 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *cur_peer_ref = NULL; cur_peer_ref 4811 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; cur_peer_ref 4815 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(cur_peer_ref->proc_name)) ) { cur_peer_ref 4819 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(d_item = opal_list_get_first(&(cur_peer_ref->drained_list)); cur_peer_ref 4820 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c d_item != opal_list_get_end(&(cur_peer_ref->drained_list)); cur_peer_ref 4875 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; cur_peer_ref 4880 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(cur_peer_ref->proc_name)) ) { cur_peer_ref 4884 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(d_item = opal_list_get_first(&(cur_peer_ref->drained_list)); cur_peer_ref 4885 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c d_item != opal_list_get_end(&(cur_peer_ref->drained_list)); cur_peer_ref 4903 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref->ack_required = true; cur_peer_ref 4926 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(cur_peer_ref->proc_name)), cur_peer_ref 5024 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ompi_crcp_bkmrk_pml_peer_ref_t *cur_peer_ref = NULL; cur_peer_ref 5061 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref = (ompi_crcp_bkmrk_pml_peer_ref_t*)item; cur_peer_ref 5065 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c &(cur_peer_ref->proc_name)) ) { cur_peer_ref 5072 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if( cur_peer_ref->ack_required ) { cur_peer_ref 5079 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OMPI_NAME_PRINT(&(cur_peer_ref->proc_name)) )); cur_peer_ref 5090 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c if (ORTE_SUCCESS != (ret = ompi_rte_send_buffer_nb(&(cur_peer_ref->proc_name), cur_peer_ref 5102 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c cur_peer_ref->ack_required = false; cur_peer_ref 5107 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c for(d_item = opal_list_get_first(&(cur_peer_ref->drained_list)); cur_peer_ref 5108 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c d_item != opal_list_get_end(&(cur_peer_ref->drained_list)); cur_peer_ref 5128 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c drain_message_remove(cur_peer_ref, drain_msg_ref, content_ref);