rb 5517 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c orte_rml_recv_cb_t *rb = NULL; rb 5590 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rb = OBJ_NEW(orte_rml_recv_cb_t); rb 5591 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rb->active = true; rb 5593 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c orte_rml_recv_callback, rb); rb 5594 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ORTE_WAIT_FOR_COMPLETION(rb->active); rb 5596 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, recv_response, 1, OPAL_UINT32, rb 5598 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, num_resolv, 1, OPAL_UINT32, rb 5600 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, p_total_found, 1, OPAL_UINT32, rb 5603 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_RELEASE(rb); rb 5749 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c orte_rml_recv_cb_t *rb = NULL; rb 5756 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rb = OBJ_NEW(orte_rml_recv_cb_t); rb 5757 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c rb->active = true; rb 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); rb 5759 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c ORTE_WAIT_FOR_COMPLETION(rb->active); rb 5762 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, (*comm_id), 1, OPAL_UINT32, rb 5764 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, (*rank), 1, OPAL_INT, rb 5768 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, (*tag), 1, OPAL_INT, rb 5770 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, (*count), 1, OPAL_SIZE, rb 5772 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, (*datatype_size), 1, OPAL_SIZE, rb 5776 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c UNPACK_BUFFER(&rb->data, (*p_num_sent), 1, OPAL_INT, rb 5780 ompi/mca/crcp/bkmrk/crcp_bkmrk_pml.c OBJ_RELEASE(rb); rb 86 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_rshift_caddy_t *rb = (pmix_rshift_caddy_t*)cbdata; rb 87 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_rshift_caddy_t *cd = (pmix_rshift_caddy_t*)rb->cd; rb 90 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c size_t index = rb->index; rb 108 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL == rb->list) { rb 109 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL != rb->hdlr) { rb 110 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(rb->hdlr); rb 112 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (rb->firstoverall) { rb 117 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c } else if (NULL != rb->hdlr) { rb 118 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_remove_item(rb->list, &rb->hdlr->super); rb 119 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(rb->hdlr); rb 136 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL!= rb->info) { rb 137 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_INFO_FREE(rb->info, rb->ninfo); rb 139 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL != rb->codes) { rb 140 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c free(rb->codes); rb 142 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(rb); rb 147 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_rshift_caddy_t *rb = (pmix_rshift_caddy_t*)cbdata; rb 148 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_rshift_caddy_t *cd = (pmix_rshift_caddy_t*)rb->cd; rb 150 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c size_t index = rb->index; rb 154 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL == rb->list) { rb 155 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL != rb->hdlr) { rb 156 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(rb->hdlr); rb 158 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (rb->firstoverall) { rb 163 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c } else if (NULL != rb->hdlr) { rb 164 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_remove_item(rb->list, &rb->hdlr->super); rb 165 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(rb->hdlr); rb 178 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL!= rb->info) { rb 179 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_INFO_FREE(rb->info, rb->ninfo); rb 181 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c if (NULL != rb->codes) { rb 182 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c free(rb->codes); rb 184 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_RELEASE(rb); rb 212 orte/mca/snapc/full/snapc_full_app.c orte_rml_recv_cb_t *rb = NULL; rb 276 orte/mca/snapc/full/snapc_full_app.c rb = OBJ_NEW(orte_rml_recv_cb_t); rb 277 orte/mca/snapc/full/snapc_full_app.c rb->active = true; rb 278 orte/mca/snapc/full/snapc_full_app.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_HNP, ORTE_RML_TAG_SNAPC_FULL, 0, orte_rml_recv_callback, rb); rb 279 orte/mca/snapc/full/snapc_full_app.c ORTE_WAIT_FOR_COMPLETION(rb->active); rb 282 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &command, &count, ORTE_SNAPC_FULL_CMD))) { rb 289 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &op_event, &count, OPAL_INT))) { rb 310 orte/mca/snapc/full/snapc_full_app.c if (NULL != rb) { rb 311 orte/mca/snapc/full/snapc_full_app.c OBJ_RELEASE(rb); rb 312 orte/mca/snapc/full/snapc_full_app.c rb = NULL; rb 1265 orte/mca/snapc/full/snapc_full_app.c orte_rml_recv_cb_t *rb = NULL; rb 1503 orte/mca/snapc/full/snapc_full_app.c rb = OBJ_NEW(orte_rml_recv_cb_t); rb 1504 orte/mca/snapc/full/snapc_full_app.c rb->active = true; rb 1505 orte/mca/snapc/full/snapc_full_app.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_HNP, ORTE_RML_TAG_SNAPC_FULL, 0, orte_rml_recv_callback, rb); rb 1506 orte/mca/snapc/full/snapc_full_app.c ORTE_WAIT_FOR_COMPLETION(rb->active); rb 1509 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &command, &count, ORTE_SNAPC_FULL_CMD))) { rb 1516 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &op_event, &count, OPAL_INT))) { rb 1523 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &op_state, &count, OPAL_INT))) { rb 1568 orte/mca/snapc/full/snapc_full_app.c rb = OBJ_NEW(orte_rml_recv_cb_t); rb 1569 orte/mca/snapc/full/snapc_full_app.c rb->active = true; rb 1570 orte/mca/snapc/full/snapc_full_app.c orte_rml.recv_buffer_nb(ORTE_PROC_MY_HNP, ORTE_RML_TAG_SNAPC_FULL, 0, orte_rml_recv_callback, rb); rb 1571 orte/mca/snapc/full/snapc_full_app.c ORTE_WAIT_FOR_COMPLETION(rb->active); rb 1574 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &command, &count, ORTE_SNAPC_FULL_CMD))) { rb 1581 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &op_event, &count, OPAL_INT))) { rb 1588 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &op_state, &count, OPAL_INT))) { rb 1631 orte/mca/snapc/full/snapc_full_app.c if (NULL != rb) { rb 1632 orte/mca/snapc/full/snapc_full_app.c OBJ_RELEASE(rb); rb 1633 orte/mca/snapc/full/snapc_full_app.c rb = NULL; rb 445 orte/mca/sstore/central/sstore_central_app.c orte_rml_recv_cb_t* rb = NULL; rb 484 orte/mca/sstore/central/sstore_central_app.c rb = OBJ_NEW(orte_rml_recv_cb_t); rb 485 orte/mca/sstore/central/sstore_central_app.c rb->active = true; rb 487 orte/mca/sstore/central/sstore_central_app.c 0, orte_rml_recv_callback, rb); rb 488 orte/mca/sstore/central/sstore_central_app.c ORTE_WAIT_FOR_COMPLETION(rb->active); rb 491 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &command, &count, ORTE_SSTORE_CENTRAL_CMD))) { rb 498 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &loc_id, &count, ORTE_SSTORE_HANDLE))) { rb 508 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &(handle_info->seq_num), &count, OPAL_INT))) { rb 515 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &(handle_info->global_ref_name), &count, OPAL_STRING))) { rb 522 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &(handle_info->local_location), &count, OPAL_STRING))) { rb 529 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &(handle_info->metadata_filename), &count, OPAL_STRING))) { rb 548 orte/mca/sstore/central/sstore_central_app.c if (NULL != rb) { rb 549 orte/mca/sstore/central/sstore_central_app.c OBJ_RELEASE(rb); rb 434 orte/mca/sstore/stage/sstore_stage_app.c orte_rml_recv_cb_t *rb = NULL; rb 473 orte/mca/sstore/stage/sstore_stage_app.c rb = OBJ_NEW(orte_rml_recv_cb_t); rb 474 orte/mca/sstore/stage/sstore_stage_app.c rb->active = true; rb 476 orte/mca/sstore/stage/sstore_stage_app.c 0, orte_rml_recv_callback, rb); rb 477 orte/mca/sstore/stage/sstore_stage_app.c ORTE_WAIT_FOR_COMPLETION(rb->active); rb 480 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &command, &count, ORTE_SSTORE_STAGE_CMD))) { rb 487 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &loc_id, &count, ORTE_SSTORE_HANDLE))) { rb 497 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &(handle_info->seq_num), &count, OPAL_INT))) { rb 504 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &(handle_info->global_ref_name), &count, OPAL_STRING))) { rb 511 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &(handle_info->local_location), &count, OPAL_STRING))) { rb 518 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(&rb->data, &(handle_info->metadata_filename), &count, OPAL_STRING))) { rb 529 orte/mca/sstore/stage/sstore_stage_app.c if (NULL != rb) { rb 530 orte/mca/sstore/stage/sstore_stage_app.c OBJ_RELEASE(rb);