app_info 585 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_app_snapshot_info_t *app_info = NULL; app_info 587 orte/mca/sstore/central/sstore_central_local.c app_info = OBJ_NEW(orte_sstore_central_local_app_snapshot_info_t); app_info 589 orte/mca/sstore/central/sstore_central_local.c app_info->name.jobid = name->jobid; app_info 590 orte/mca/sstore/central/sstore_central_local.c app_info->name.vpid = name->vpid; app_info 592 orte/mca/sstore/central/sstore_central_local.c opal_list_append(handle_info->app_info_handle, &(app_info->super)); app_info 600 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_app_snapshot_info_t *app_info = NULL; app_info 607 orte/mca/sstore/central/sstore_central_local.c app_info = (orte_sstore_central_local_app_snapshot_info_t*)item; app_info 611 orte/mca/sstore/central/sstore_central_local.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &app_info->name, name)) { app_info 612 orte/mca/sstore/central/sstore_central_local.c return app_info; app_info 651 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_app_snapshot_info_t *app_info = NULL; app_info 681 orte/mca/sstore/central/sstore_central_local.c app_info = (orte_sstore_central_local_app_snapshot_info_t*)item; app_info 683 orte/mca/sstore/central/sstore_central_local.c if( NULL != app_info->local_location ) { app_info 684 orte/mca/sstore/central/sstore_central_local.c free(app_info->local_location); app_info 685 orte/mca/sstore/central/sstore_central_local.c app_info->local_location = NULL; app_info 687 orte/mca/sstore/central/sstore_central_local.c opal_asprintf(&(app_info->local_location), handle_info->location_fmt, app_info->name.vpid); app_info 689 orte/mca/sstore/central/sstore_central_local.c if( NULL != app_info->metadata_filename ) { app_info 690 orte/mca/sstore/central/sstore_central_local.c free(app_info->metadata_filename); app_info 691 orte/mca/sstore/central/sstore_central_local.c app_info->metadata_filename = NULL; app_info 693 orte/mca/sstore/central/sstore_central_local.c opal_asprintf(&(app_info->metadata_filename), "%s/%s", app_info 694 orte/mca/sstore/central/sstore_central_local.c app_info->local_location, app_info 713 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_app_snapshot_info_t *app_info = NULL; app_info 718 orte/mca/sstore/central/sstore_central_local.c app_info = find_app_handle_info(handle_info, peer); app_info 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))) { app_info 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))) { app_info 784 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_app_snapshot_info_t *app_info = NULL; app_info 789 orte/mca/sstore/central/sstore_central_local.c app_info = find_app_handle_info(handle_info, peer); app_info 795 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(app_info->ckpt_skipped), &count, OPAL_BOOL))) { app_info 801 orte/mca/sstore/central/sstore_central_local.c if( !app_info->ckpt_skipped ) { app_info 803 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(app_info->crs_comp), &count, OPAL_STRING))) { app_info 812 orte/mca/sstore/central/sstore_central_local.c ORTE_NAME_PRINT(&(app_info->name)), app_info 813 orte/mca/sstore/central/sstore_central_local.c (app_info->ckpt_skipped ? "T" : "F"), app_info 814 orte/mca/sstore/central/sstore_central_local.c app_info->crs_comp)); app_info 822 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_app_snapshot_info_t *app_info = NULL; app_info 831 orte/mca/sstore/central/sstore_central_local.c app_info = (orte_sstore_central_local_app_snapshot_info_t*)item; app_info 833 orte/mca/sstore/central/sstore_central_local.c if( NULL == app_info->crs_comp && !app_info->ckpt_skipped ) { app_info 842 orte/mca/sstore/central/sstore_central_local.c ORTE_NAME_PRINT(&(app_info->name)) )); app_info 910 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_app_snapshot_info_t *app_info = NULL; app_info 942 orte/mca/sstore/central/sstore_central_local.c app_info = (orte_sstore_central_local_app_snapshot_info_t*)item; app_info 944 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(app_info->name), 1, ORTE_NAME))) { app_info 950 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(app_info->ckpt_skipped), 1, OPAL_BOOL))) { app_info 956 orte/mca/sstore/central/sstore_central_local.c if( !app_info->ckpt_skipped ) { app_info 957 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(app_info->crs_comp), 1, OPAL_STRING))) { app_info 196 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info); app_info 684 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 761 orte/mca/sstore/stage/sstore_stage_local.c app_info = find_app_handle_info(handle_info, &child->name); app_info 766 orte/mca/sstore/stage/sstore_stage_local.c if( NULL == app_info ) { app_info 776 orte/mca/sstore/stage/sstore_stage_local.c if( NULL != app_info->local_cache_location && app_info 777 orte/mca/sstore/stage/sstore_stage_local.c 0 == (ret = access(app_info->local_cache_location, F_OK)) ) { app_info 781 orte/mca/sstore/stage/sstore_stage_local.c app_info->local_cache_location)); app_info 784 orte/mca/sstore/stage/sstore_stage_local.c opal_argv_append(&loc_argc, &(app->argv), app_info->local_cache_location); app_info 790 orte/mca/sstore/stage/sstore_stage_local.c ORTE_NAME_PRINT(&app_info->name), app_info 791 orte/mca/sstore/stage/sstore_stage_local.c app_info->local_cache_location)); app_info 1012 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1014 orte/mca/sstore/stage/sstore_stage_local.c app_info = OBJ_NEW(orte_sstore_stage_local_app_snapshot_info_t); app_info 1016 orte/mca/sstore/stage/sstore_stage_local.c app_info->name.jobid = name->jobid; app_info 1017 orte/mca/sstore/stage/sstore_stage_local.c app_info->name.vpid = name->vpid; app_info 1019 orte/mca/sstore/stage/sstore_stage_local.c opal_list_append(handle_info->app_info_handle, &(app_info->super)); app_info 1027 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1034 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)item; app_info 1038 orte/mca/sstore/stage/sstore_stage_local.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &app_info->name, name)) { app_info 1039 orte/mca/sstore/stage/sstore_stage_local.c return app_info; app_info 1162 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1208 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)item; app_info 1210 orte/mca/sstore/stage/sstore_stage_local.c if( NULL != app_info->local_location ) { app_info 1211 orte/mca/sstore/stage/sstore_stage_local.c free(app_info->local_location); app_info 1212 orte/mca/sstore/stage/sstore_stage_local.c app_info->local_location = NULL; app_info 1214 orte/mca/sstore/stage/sstore_stage_local.c opal_asprintf(&(app_info->local_location), handle_info->location_fmt, app_info->name.vpid); app_info 1217 orte/mca/sstore/stage/sstore_stage_local.c if( NULL != app_info->local_cache_location ) { app_info 1218 orte/mca/sstore/stage/sstore_stage_local.c free(app_info->local_cache_location); app_info 1219 orte/mca/sstore/stage/sstore_stage_local.c app_info->local_cache_location = NULL; app_info 1221 orte/mca/sstore/stage/sstore_stage_local.c opal_asprintf(&(app_info->local_cache_location), handle_info->cache_location_fmt, app_info->name.vpid); app_info 1224 orte/mca/sstore/stage/sstore_stage_local.c if( NULL != app_info->metadata_filename ) { app_info 1225 orte/mca/sstore/stage/sstore_stage_local.c free(app_info->metadata_filename); app_info 1226 orte/mca/sstore/stage/sstore_stage_local.c app_info->metadata_filename = NULL; app_info 1228 orte/mca/sstore/stage/sstore_stage_local.c opal_asprintf(&(app_info->metadata_filename), "%s/%s", app_info 1229 orte/mca/sstore/stage/sstore_stage_local.c app_info->local_location, app_info 1246 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1262 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)item; app_info 1264 orte/mca/sstore/stage/sstore_stage_local.c opal_asprintf(&cmd, "rm -rf %s", app_info->local_location); app_info 1270 orte/mca/sstore/stage/sstore_stage_local.c if( orte_sstore_stage_enabled_compression && NULL != app_info->compressed_local_location) { app_info 1274 orte/mca/sstore/stage/sstore_stage_local.c opal_asprintf(&cmd, "rm -rf %s", app_info->compressed_local_location); app_info 1350 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1355 orte/mca/sstore/stage/sstore_stage_local.c app_info = find_app_handle_info(handle_info, peer); app_info 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))) { app_info 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))) { app_info 1422 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1427 orte/mca/sstore/stage/sstore_stage_local.c app_info = find_app_handle_info(handle_info, peer); app_info 1433 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(app_info->ckpt_skipped), &count, OPAL_BOOL))) { app_info 1439 orte/mca/sstore/stage/sstore_stage_local.c if( !app_info->ckpt_skipped ) { app_info 1441 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(app_info->crs_comp), &count, OPAL_STRING))) { app_info 1450 orte/mca/sstore/stage/sstore_stage_local.c ORTE_NAME_PRINT(&(app_info->name)), app_info 1451 orte/mca/sstore/stage/sstore_stage_local.c (app_info->ckpt_skipped ? "T" : "F"), app_info 1452 orte/mca/sstore/stage/sstore_stage_local.c app_info->crs_comp)); app_info 1462 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1471 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)item; app_info 1473 orte/mca/sstore/stage/sstore_stage_local.c if( NULL == app_info->crs_comp && !app_info->ckpt_skipped ) { app_info 1482 orte/mca/sstore/stage/sstore_stage_local.c ORTE_NAME_PRINT(&(app_info->name)) )); app_info 1491 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info) app_info 1504 orte/mca/sstore/stage/sstore_stage_local.c ORTE_NAME_PRINT(&(app_info->name)), app_info 1505 orte/mca/sstore/stage/sstore_stage_local.c app_info->local_location )); app_info 1510 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = opal_compress.compress_nb(app_info->local_location, app_info 1511 orte/mca/sstore/stage/sstore_stage_local.c &(app_info->compressed_local_location), app_info 1513 orte/mca/sstore/stage/sstore_stage_local.c &(app_info->compress_pid))) ) { app_info 1518 orte/mca/sstore/stage/sstore_stage_local.c if( app_info->compress_pid <= 0 ) { app_info 1534 orte/mca/sstore/stage/sstore_stage_local.c app_info->compress_pid, app_info 1535 orte/mca/sstore/stage/sstore_stage_local.c ORTE_NAME_PRINT(&(app_info->name)) )); app_info 1538 orte/mca/sstore/stage/sstore_stage_local.c proc->pid = app_info->compress_pid; app_info 1542 orte/mca/sstore/stage/sstore_stage_local.c orte_wait_cb(proc, sstore_stage_local_compress_waitpid_cb, app_info); app_info 1555 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1558 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)t2->cbdata; app_info 1563 orte/mca/sstore/stage/sstore_stage_local.c ORTE_NAME_PRINT(&(app_info->name)) )); app_info 1565 orte/mca/sstore/stage/sstore_stage_local.c app_info->compress_pid = 0; app_info 1573 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1601 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)item; app_info 1603 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = start_compression(handle_info, app_info)) ) { app_info 1620 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)item; app_info 1622 orte/mca/sstore/stage/sstore_stage_local.c if( 0 < app_info->compress_pid ) { app_info 1631 orte/mca/sstore/stage/sstore_stage_local.c ORTE_NAME_PRINT(&(app_info->name)) )); app_info 1702 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1734 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)item; app_info 1736 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(app_info->name), 1, ORTE_NAME))) { app_info 1742 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(app_info->ckpt_skipped), 1, OPAL_BOOL))) { app_info 1748 orte/mca/sstore/stage/sstore_stage_local.c if( !app_info->ckpt_skipped ) { app_info 1749 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(app_info->crs_comp), 1, OPAL_STRING))) { app_info 1873 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_app_snapshot_info_t *app_info = NULL; app_info 1889 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)opal_list_get_first(handle_info->app_info_handle); app_info 1890 orte/mca/sstore/stage/sstore_stage_local.c if( NULL == app_info ) { app_info 1899 orte/mca/sstore/stage/sstore_stage_local.c cache_dirname = opal_dirname(app_info->local_cache_location); app_info 1913 orte/mca/sstore/stage/sstore_stage_local.c app_info = (orte_sstore_stage_local_app_snapshot_info_t*)item; app_info 1915 orte/mca/sstore/stage/sstore_stage_local.c opal_asprintf(&cmd, "mv %s %s", app_info->local_location, cache_dirname); app_info 1918 orte/mca/sstore/stage/sstore_stage_local.c ORTE_NAME_PRINT(&app_info->name), app_info 1923 orte/mca/sstore/stage/sstore_stage_local.c if( orte_sstore_stage_enabled_compression && NULL != app_info->compressed_local_location) { app_info 1927 orte/mca/sstore/stage/sstore_stage_local.c opal_asprintf(&cmd, "rm -rf %s", app_info->compressed_local_location);