loc_buffer 634 orte/mca/snapc/base/snapc_base_fns.c opal_buffer_t *loc_buffer = NULL; loc_buffer 678 orte/mca/snapc/base/snapc_base_fns.c if (NULL == (loc_buffer = OBJ_NEW(opal_buffer_t))) { loc_buffer 683 orte/mca/snapc/base/snapc_base_fns.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &command, 1, ORTE_SNAPC_CMD)) ) { loc_buffer 686 orte/mca/snapc/base/snapc_base_fns.c OBJ_RELEASE(loc_buffer); loc_buffer 690 orte/mca/snapc/base/snapc_base_fns.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &ckpt_status, 1, OPAL_INT))) { loc_buffer 697 orte/mca/snapc/base/snapc_base_fns.c OBJ_RELEASE(loc_buffer); loc_buffer 747 orte/mca/snapc/base/snapc_base_fns.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &global_snapshot_handle, 1, OPAL_STRING))) { loc_buffer 754 orte/mca/snapc/base/snapc_base_fns.c OBJ_RELEASE(loc_buffer); loc_buffer 758 orte/mca/snapc/base/snapc_base_fns.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &seq_num, 1, OPAL_INT))) { loc_buffer 765 orte/mca/snapc/base/snapc_base_fns.c OBJ_RELEASE(loc_buffer); loc_buffer 770 orte/mca/snapc/base/snapc_base_fns.c if (0 > (ret = orte_rml.send_buffer_nb(peer, loc_buffer, loc_buffer 779 orte/mca/snapc/base/snapc_base_fns.c OBJ_RELEASE(loc_buffer); loc_buffer 886 orte/mca/sstore/central/sstore_central_global.c opal_buffer_t *loc_buffer = NULL; loc_buffer 892 orte/mca/sstore/central/sstore_central_global.c loc_buffer = OBJ_NEW(opal_buffer_t); loc_buffer 895 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &command, 1, ORTE_SSTORE_CENTRAL_CMD))) { loc_buffer 901 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { loc_buffer 907 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->seq_num), 1, OPAL_INT))) { loc_buffer 913 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->ref_name), 1, OPAL_STRING))) { loc_buffer 919 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->app_location_fmt), 1, OPAL_STRING))) { loc_buffer 925 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, loc_buffer 932 orte/mca/sstore/central/sstore_central_global.c loc_buffer = NULL; loc_buffer 935 orte/mca/sstore/central/sstore_central_global.c if (NULL != loc_buffer) { loc_buffer 936 orte/mca/sstore/central/sstore_central_global.c OBJ_RELEASE(loc_buffer); loc_buffer 937 orte/mca/sstore/central/sstore_central_global.c loc_buffer = NULL; loc_buffer 711 orte/mca/sstore/central/sstore_central_local.c opal_buffer_t *loc_buffer = NULL; loc_buffer 723 orte/mca/sstore/central/sstore_central_local.c loc_buffer = OBJ_NEW(opal_buffer_t); loc_buffer 726 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &command, 1, ORTE_SSTORE_CENTRAL_CMD))) { loc_buffer 732 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { loc_buffer 738 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->seq_num), 1, OPAL_INT))) { loc_buffer 744 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->global_ref_name), 1, OPAL_STRING))) { loc_buffer 750 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(app_info->local_location), 1, OPAL_STRING))) { loc_buffer 756 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(app_info->metadata_filename), 1, OPAL_STRING))) { loc_buffer 762 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, loc_buffer 769 orte/mca/sstore/central/sstore_central_local.c loc_buffer = NULL; loc_buffer 772 orte/mca/sstore/central/sstore_central_local.c if (NULL != loc_buffer) { loc_buffer 773 orte/mca/sstore/central/sstore_central_local.c OBJ_RELEASE(loc_buffer); loc_buffer 774 orte/mca/sstore/central/sstore_central_local.c loc_buffer = NULL; loc_buffer 1100 orte/mca/sstore/stage/sstore_stage_global.c opal_buffer_t *loc_buffer = NULL; loc_buffer 1106 orte/mca/sstore/stage/sstore_stage_global.c loc_buffer = OBJ_NEW(opal_buffer_t); loc_buffer 1109 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &command, 1, ORTE_SSTORE_STAGE_CMD))) { loc_buffer 1115 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { loc_buffer 1121 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->seq_num), 1, OPAL_INT))) { loc_buffer 1127 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->ref_name), 1, OPAL_STRING))) { loc_buffer 1133 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->app_local_location_fmt), 1, OPAL_STRING))) { loc_buffer 1140 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->app_local_cache_location_fmt), 1, OPAL_STRING))) { loc_buffer 1153 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, loc_buffer 1160 orte/mca/sstore/stage/sstore_stage_global.c loc_buffer = NULL; loc_buffer 1163 orte/mca/sstore/stage/sstore_stage_global.c if (NULL != loc_buffer) { loc_buffer 1164 orte/mca/sstore/stage/sstore_stage_global.c OBJ_RELEASE(loc_buffer); loc_buffer 1165 orte/mca/sstore/stage/sstore_stage_global.c loc_buffer = NULL; loc_buffer 1521 orte/mca/sstore/stage/sstore_stage_global.c opal_buffer_t *loc_buffer = NULL; loc_buffer 1527 orte/mca/sstore/stage/sstore_stage_global.c loc_buffer = OBJ_NEW(opal_buffer_t); loc_buffer 1530 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &command, 1, ORTE_SSTORE_STAGE_CMD))) { loc_buffer 1536 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { loc_buffer 1547 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = orte_grpcomm.xcast(sig, ORTE_RML_TAG_SSTORE_INTERNAL, loc_buffer))) { loc_buffer 1554 orte/mca/sstore/stage/sstore_stage_global.c loc_buffer = NULL; loc_buffer 1557 orte/mca/sstore/stage/sstore_stage_global.c if (NULL != loc_buffer) { loc_buffer 1558 orte/mca/sstore/stage/sstore_stage_global.c OBJ_RELEASE(loc_buffer); loc_buffer 1559 orte/mca/sstore/stage/sstore_stage_global.c loc_buffer = NULL; loc_buffer 1248 orte/mca/sstore/stage/sstore_stage_local.c opal_buffer_t *loc_buffer = NULL; loc_buffer 1293 orte/mca/sstore/stage/sstore_stage_local.c loc_buffer = OBJ_NEW(opal_buffer_t); loc_buffer 1296 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &command, 1, ORTE_SSTORE_STAGE_CMD))) { loc_buffer 1302 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { loc_buffer 1309 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &list_size, 1, OPAL_SIZE))) { loc_buffer 1315 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, loc_buffer 1329 orte/mca/sstore/stage/sstore_stage_local.c loc_buffer = NULL; loc_buffer 1337 orte/mca/sstore/stage/sstore_stage_local.c if (NULL != loc_buffer) { loc_buffer 1338 orte/mca/sstore/stage/sstore_stage_local.c OBJ_RELEASE(loc_buffer); loc_buffer 1339 orte/mca/sstore/stage/sstore_stage_local.c loc_buffer = NULL; loc_buffer 1348 orte/mca/sstore/stage/sstore_stage_local.c opal_buffer_t *loc_buffer = NULL; loc_buffer 1360 orte/mca/sstore/stage/sstore_stage_local.c loc_buffer = OBJ_NEW(opal_buffer_t); loc_buffer 1363 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &command, 1, ORTE_SSTORE_STAGE_CMD))) { loc_buffer 1369 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { loc_buffer 1375 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->seq_num), 1, OPAL_INT))) { loc_buffer 1381 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(handle_info->global_ref_name), 1, OPAL_STRING))) { loc_buffer 1387 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(app_info->local_location), 1, OPAL_STRING))) { loc_buffer 1393 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(loc_buffer, &(app_info->metadata_filename), 1, OPAL_STRING))) { loc_buffer 1399 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = orte_rml.send_buffer_nb(peer, loc_buffer, ORTE_RML_TAG_SSTORE_INTERNAL, loc_buffer 1407 orte/mca/sstore/stage/sstore_stage_local.c loc_buffer = NULL; loc_buffer 1410 orte/mca/sstore/stage/sstore_stage_local.c if (NULL != loc_buffer) { loc_buffer 1411 orte/mca/sstore/stage/sstore_stage_local.c OBJ_RELEASE(loc_buffer); loc_buffer 1412 orte/mca/sstore/stage/sstore_stage_local.c loc_buffer = NULL;