handle_info 106 orte/mca/sstore/central/sstore_central_app.c static int init_local_snapshot_directory(orte_sstore_central_app_snapshot_info_t *handle_info); handle_info 107 orte/mca/sstore/central/sstore_central_app.c static int pull_handle_info(orte_sstore_central_app_snapshot_info_t *handle_info ); handle_info 108 orte/mca/sstore/central/sstore_central_app.c static int push_handle_info(orte_sstore_central_app_snapshot_info_t *handle_info ); handle_info 110 orte/mca/sstore/central/sstore_central_app.c static int metadata_open(orte_sstore_central_app_snapshot_info_t * handle_info); handle_info 111 orte/mca/sstore/central/sstore_central_app.c static int metadata_close(orte_sstore_central_app_snapshot_info_t * handle_info); handle_info 112 orte/mca/sstore/central/sstore_central_app.c static int metadata_write_str(orte_sstore_central_app_snapshot_info_t * handle_info, char * key, char *value); handle_info 113 orte/mca/sstore/central/sstore_central_app.c static int metadata_write_int(orte_sstore_central_app_snapshot_info_t * handle_info, char *key, int value); handle_info 114 orte/mca/sstore/central/sstore_central_app.c static int metadata_write_timestamp(orte_sstore_central_app_snapshot_info_t * handle_info); handle_info 201 orte/mca/sstore/central/sstore_central_app.c orte_sstore_central_app_snapshot_info_t *handle_info = NULL; handle_info 210 orte/mca/sstore/central/sstore_central_app.c handle_info = find_handle_info(handle); handle_info 211 orte/mca/sstore/central/sstore_central_app.c if( NULL != handle_info ) { handle_info 213 orte/mca/sstore/central/sstore_central_app.c opal_list_remove_item(active_handles, &(handle_info->super)); handle_info 215 orte/mca/sstore/central/sstore_central_app.c handle_info = create_new_handle_info(handle); handle_info 220 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = pull_handle_info(handle_info)) ) { handle_info 229 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = init_local_snapshot_directory(handle_info)) ) { handle_info 242 orte/mca/sstore/central/sstore_central_app.c orte_sstore_central_app_snapshot_info_t *handle_info = NULL; handle_info 250 orte/mca/sstore/central/sstore_central_app.c handle_info = find_handle_info(handle); handle_info 256 orte/mca/sstore/central/sstore_central_app.c opal_asprintf(value, "%d", handle_info->seq_num); handle_info 258 orte/mca/sstore/central/sstore_central_app.c "sstore:central:(app): get_attr(%d, %d) Seq = <%s>", key, handle_info->id, *value)); handle_info 261 orte/mca/sstore/central/sstore_central_app.c *value = strdup(handle_info->local_location); handle_info 264 orte/mca/sstore/central/sstore_central_app.c *value = strdup(handle_info->metadata_filename); handle_info 267 orte/mca/sstore/central/sstore_central_app.c *value = strdup(handle_info->global_ref_name); handle_info 269 orte/mca/sstore/central/sstore_central_app.c "sstore:central:(app): get_attr(%d, %d) Ref = <%s>", key, handle_info->id, *value)); handle_info 277 orte/mca/sstore/central/sstore_central_app.c "sstore:central:(app): get_attr(%d, %d) <%s>", key, handle_info->id, *value)); handle_info 285 orte/mca/sstore/central/sstore_central_app.c orte_sstore_central_app_snapshot_info_t *handle_info = NULL; handle_info 306 orte/mca/sstore/central/sstore_central_app.c handle_info = find_handle_info(handle); handle_info 312 orte/mca/sstore/central/sstore_central_app.c if( NULL != handle_info->crs_comp ) { handle_info 313 orte/mca/sstore/central/sstore_central_app.c free(handle_info->crs_comp); handle_info 315 orte/mca/sstore/central/sstore_central_app.c handle_info->crs_comp = strdup(value); handle_info 318 orte/mca/sstore/central/sstore_central_app.c handle_info->ckpt_skipped = true; handle_info 323 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_write_str(handle_info, key_str, value))) { handle_info 346 orte/mca/sstore/central/sstore_central_app.c orte_sstore_central_app_snapshot_info_t *handle_info = NULL; handle_info 354 orte/mca/sstore/central/sstore_central_app.c handle_info = find_handle_info(handle); handle_info 359 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_write_timestamp(handle_info)) ) { handle_info 365 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_close(handle_info)) ) { handle_info 374 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = push_handle_info(handle_info)) ) { handle_info 409 orte/mca/sstore/central/sstore_central_app.c orte_sstore_central_app_snapshot_info_t *handle_info = NULL; handle_info 411 orte/mca/sstore/central/sstore_central_app.c handle_info = OBJ_NEW(orte_sstore_central_app_snapshot_info_t); handle_info 413 orte/mca/sstore/central/sstore_central_app.c handle_info->id = handle; handle_info 415 orte/mca/sstore/central/sstore_central_app.c opal_list_append(active_handles, &(handle_info->super)); handle_info 417 orte/mca/sstore/central/sstore_central_app.c return handle_info; handle_info 422 orte/mca/sstore/central/sstore_central_app.c orte_sstore_central_app_snapshot_info_t *handle_info = NULL; handle_info 428 orte/mca/sstore/central/sstore_central_app.c handle_info = (orte_sstore_central_app_snapshot_info_t*)item; handle_info 430 orte/mca/sstore/central/sstore_central_app.c if( handle_info->id == handle ) { handle_info 431 orte/mca/sstore/central/sstore_central_app.c return handle_info; handle_info 438 orte/mca/sstore/central/sstore_central_app.c static int pull_handle_info(orte_sstore_central_app_snapshot_info_t *handle_info ) handle_info 459 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { handle_info 503 orte/mca/sstore/central/sstore_central_app.c if( loc_id != handle_info->id ) { handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 539 orte/mca/sstore/central/sstore_central_app.c handle_info->id, handle_info 540 orte/mca/sstore/central/sstore_central_app.c handle_info->seq_num, handle_info 541 orte/mca/sstore/central/sstore_central_app.c handle_info->global_ref_name handle_info 556 orte/mca/sstore/central/sstore_central_app.c static int push_handle_info(orte_sstore_central_app_snapshot_info_t *handle_info ) handle_info 571 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { handle_info 577 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->ckpt_skipped), 1, OPAL_BOOL))) { handle_info 583 orte/mca/sstore/central/sstore_central_app.c if( !handle_info->ckpt_skipped ) { handle_info 584 orte/mca/sstore/central/sstore_central_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->crs_comp), 1, OPAL_STRING))) { handle_info 611 orte/mca/sstore/central/sstore_central_app.c static int init_local_snapshot_directory(orte_sstore_central_app_snapshot_info_t *handle_info) handle_info 619 orte/mca/sstore/central/sstore_central_app.c if(OPAL_SUCCESS != (ret = opal_os_dirpath_create(handle_info->local_location, my_mode)) ) { handle_info 623 orte/mca/sstore/central/sstore_central_app.c handle_info->local_location); handle_info 632 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 641 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_write_timestamp(handle_info)) ) { handle_info 647 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, SSTORE_METADATA_LOCAL_PID_STR, (int)getpid())) ) { handle_info 653 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_close(handle_info)) ) { handle_info 667 orte/mca/sstore/central/sstore_central_app.c static int metadata_open(orte_sstore_central_app_snapshot_info_t * handle_info) handle_info 670 orte/mca/sstore/central/sstore_central_app.c if( NULL != handle_info->metadata ) { handle_info 674 orte/mca/sstore/central/sstore_central_app.c if (NULL == (handle_info->metadata = fopen(handle_info->metadata_filename, "a")) ) { handle_info 677 orte/mca/sstore/central/sstore_central_app.c handle_info->metadata_filename); handle_info 685 orte/mca/sstore/central/sstore_central_app.c static int metadata_close(orte_sstore_central_app_snapshot_info_t * handle_info) handle_info 688 orte/mca/sstore/central/sstore_central_app.c if( NULL == handle_info->metadata ) { handle_info 692 orte/mca/sstore/central/sstore_central_app.c fclose(handle_info->metadata); handle_info 693 orte/mca/sstore/central/sstore_central_app.c handle_info->metadata = NULL; handle_info 698 orte/mca/sstore/central/sstore_central_app.c static int metadata_write_str(orte_sstore_central_app_snapshot_info_t * handle_info, char *key, char *value) handle_info 703 orte/mca/sstore/central/sstore_central_app.c if( NULL == handle_info->metadata ) { handle_info 704 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 711 orte/mca/sstore/central/sstore_central_app.c fprintf(handle_info->metadata, "%s%s\n", key, value); handle_info 717 orte/mca/sstore/central/sstore_central_app.c if( NULL != handle_info->metadata ) { handle_info 718 orte/mca/sstore/central/sstore_central_app.c fclose(handle_info->metadata); handle_info 719 orte/mca/sstore/central/sstore_central_app.c handle_info->metadata = NULL; handle_info 725 orte/mca/sstore/central/sstore_central_app.c static int metadata_write_int(orte_sstore_central_app_snapshot_info_t * handle_info, char *key, int value) handle_info 730 orte/mca/sstore/central/sstore_central_app.c if( NULL == handle_info->metadata ) { handle_info 731 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 738 orte/mca/sstore/central/sstore_central_app.c fprintf(handle_info->metadata, "%s%d\n", key, value); handle_info 744 orte/mca/sstore/central/sstore_central_app.c static int metadata_write_timestamp(orte_sstore_central_app_snapshot_info_t * handle_info) handle_info 750 orte/mca/sstore/central/sstore_central_app.c if( NULL == handle_info->metadata ) { handle_info 751 orte/mca/sstore/central/sstore_central_app.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 759 orte/mca/sstore/central/sstore_central_app.c fprintf(handle_info->metadata, "%s%s", SSTORE_METADATA_INTERNAL_TIME_STR, ctime(×tamp)); handle_info 145 orte/mca/sstore/central/sstore_central_global.c static int process_local_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_global_snapshot_info_t *handle_info); handle_info 146 orte/mca/sstore/central/sstore_central_global.c static int process_local_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_global_snapshot_info_t *handle_info); handle_info 152 orte/mca/sstore/central/sstore_central_global.c static int metadata_open(orte_sstore_central_global_snapshot_info_t * handle_info); handle_info 153 orte/mca/sstore/central/sstore_central_global.c static int metadata_close(orte_sstore_central_global_snapshot_info_t * handle_info); handle_info 154 orte/mca/sstore/central/sstore_central_global.c static int metadata_write_int(orte_sstore_central_global_snapshot_info_t * handle_info, char * key, int value); handle_info 155 orte/mca/sstore/central/sstore_central_global.c static int metadata_write_str(orte_sstore_central_global_snapshot_info_t * handle_info, char * key, char *value); handle_info 156 orte/mca/sstore/central/sstore_central_global.c static int metadata_write_timestamp(orte_sstore_central_global_snapshot_info_t * handle_info); handle_info 158 orte/mca/sstore/central/sstore_central_global.c static int init_global_snapshot_directory(orte_sstore_central_global_snapshot_info_t *handle_info); handle_info 161 orte/mca/sstore/central/sstore_central_global.c static int orte_sstore_central_extract_global_metadata(orte_sstore_central_global_snapshot_info_t * handle_info, handle_info 304 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 313 orte/mca/sstore/central/sstore_central_global.c handle_info = create_new_handle_info(seq, SSTORE_HANDLE_TYPE_CKPT, jobid); handle_info 318 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = init_global_snapshot_directory(handle_info)) ) { handle_info 327 orte/mca/sstore/central/sstore_central_global.c *handle = handle_info->id; handle_info 338 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 340 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info_from_ref(ref, seq); handle_info 341 orte/mca/sstore/central/sstore_central_global.c if( NULL == handle_info ) { handle_info 348 orte/mca/sstore/central/sstore_central_global.c *handle = handle_info->id; handle_info 358 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 367 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info(*handle); handle_info 370 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info(orte_sstore_handle_last_stable); handle_info 377 orte/mca/sstore/central/sstore_central_global.c snapshot->seq_num = handle_info->seq_num; handle_info 378 orte/mca/sstore/central/sstore_central_global.c snapshot->reference = strdup(handle_info->ref_name); handle_info 379 orte/mca/sstore/central/sstore_central_global.c snapshot->basedir = strdup(handle_info->base_location); handle_info 380 orte/mca/sstore/central/sstore_central_global.c snapshot->metadata_filename = strdup(handle_info->metadata_filename); handle_info 384 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = orte_sstore_central_extract_global_metadata(handle_info, snapshot)) ) { handle_info 408 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 416 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info(handle); handle_info 417 orte/mca/sstore/central/sstore_central_global.c if( SSTORE_GLOBAL_REG != handle_info->state ) { handle_info 418 orte/mca/sstore/central/sstore_central_global.c handle_info->state = SSTORE_GLOBAL_REG; handle_info 428 orte/mca/sstore/central/sstore_central_global.c if( handle_info->migrating ) { handle_info 429 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, handle_info 431 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num)) ) { handle_info 437 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, handle_info 439 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num)) ) { handle_info 446 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_write_str(handle_info, handle_info 454 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_write_timestamp(handle_info)) ) { handle_info 467 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 475 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info(handle); handle_info 481 orte/mca/sstore/central/sstore_central_global.c *value = strdup(handle_info->ref_name); handle_info 484 orte/mca/sstore/central/sstore_central_global.c opal_asprintf(value, "%d", handle_info->seq_num); handle_info 492 orte/mca/sstore/central/sstore_central_global.c handle_info->base_location, handle_info 493 orte/mca/sstore/central/sstore_central_global.c handle_info->ref_name, handle_info 494 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num); handle_info 498 orte/mca/sstore/central/sstore_central_global.c handle_info->base_location, handle_info 499 orte/mca/sstore/central/sstore_central_global.c handle_info->ref_name, handle_info 500 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num, handle_info 513 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 522 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info(handle); handle_info 528 orte/mca/sstore/central/sstore_central_global.c handle_info->migrating = true; handle_info 538 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_write_str(handle_info, key_str, value))) { handle_info 557 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 565 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info(handle); handle_info 566 orte/mca/sstore/central/sstore_central_global.c if( SSTORE_GLOBAL_SYNCING != handle_info->state ) { handle_info 567 orte/mca/sstore/central/sstore_central_global.c handle_info->state = SSTORE_GLOBAL_SYNCING; handle_info 576 orte/mca/sstore/central/sstore_central_global.c while(handle_info->num_procs_synced < handle_info->num_procs_total) { handle_info 583 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_write_timestamp(handle_info)) ) { handle_info 589 orte/mca/sstore/central/sstore_central_global.c if( handle_info->migrating ) { handle_info 590 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, handle_info 592 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num)) ) { handle_info 598 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, handle_info 600 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num)) ) { handle_info 607 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_close(handle_info)) ) { handle_info 614 orte/mca/sstore/central/sstore_central_global.c if( !handle_info->migrating ) { handle_info 638 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 646 orte/mca/sstore/central/sstore_central_global.c handle_info = find_handle_info(handle); handle_info 659 orte/mca/sstore/central/sstore_central_global.c handle_info->id, handle_info 660 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num, handle_info 661 orte/mca/sstore/central/sstore_central_global.c handle_info->ref_name)); handle_info 666 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->seq_num), 1, OPAL_INT )) ) { handle_info 672 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->ref_name), 1, OPAL_STRING )) ) { handle_info 678 orte/mca/sstore/central/sstore_central_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->app_location_fmt), 1, OPAL_STRING )) ) { handle_info 720 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 723 orte/mca/sstore/central/sstore_central_global.c handle_info = OBJ_NEW(orte_sstore_central_global_snapshot_info_t); handle_info 725 orte/mca/sstore/central/sstore_central_global.c handle_info->jobid = jobid; handle_info 727 orte/mca/sstore/central/sstore_central_global.c handle_info->state = SSTORE_GLOBAL_INIT; handle_info 729 orte/mca/sstore/central/sstore_central_global.c handle_info->handle_type = type; handle_info 731 orte/mca/sstore/central/sstore_central_global.c handle_info->seq_num = seq; handle_info 733 orte/mca/sstore/central/sstore_central_global.c orte_sstore_base_get_global_snapshot_ref(&(handle_info->ref_name), getpid()); handle_info 735 orte/mca/sstore/central/sstore_central_global.c opal_asprintf(&(handle_info->local_location), "%s/%d", handle_info 736 orte/mca/sstore/central/sstore_central_global.c handle_info->ref_name, handle_info->seq_num); handle_info 738 orte/mca/sstore/central/sstore_central_global.c opal_asprintf(&(handle_info->app_location_fmt), "%s/%s/%s", handle_info 739 orte/mca/sstore/central/sstore_central_global.c handle_info->base_location, handle_info 740 orte/mca/sstore/central/sstore_central_global.c handle_info->local_location, handle_info 743 orte/mca/sstore/central/sstore_central_global.c opal_asprintf(&(handle_info->metadata_filename), "%s/%s/%s", handle_info 744 orte/mca/sstore/central/sstore_central_global.c handle_info->base_location, handle_info 745 orte/mca/sstore/central/sstore_central_global.c handle_info->ref_name, handle_info 748 orte/mca/sstore/central/sstore_central_global.c jdata = orte_get_job_data_object(handle_info->jobid); handle_info 749 orte/mca/sstore/central/sstore_central_global.c handle_info->num_procs_total = (int)jdata->num_procs; handle_info 751 orte/mca/sstore/central/sstore_central_global.c opal_list_append(active_handles, &(handle_info->super)); handle_info 753 orte/mca/sstore/central/sstore_central_global.c return handle_info; handle_info 758 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 764 orte/mca/sstore/central/sstore_central_global.c handle_info = (orte_sstore_central_global_snapshot_info_t*)item; handle_info 766 orte/mca/sstore/central/sstore_central_global.c if( handle_info->id == handle ) { handle_info 767 orte/mca/sstore/central/sstore_central_global.c return handle_info; handle_info 776 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 782 orte/mca/sstore/central/sstore_central_global.c handle_info = (orte_sstore_central_global_snapshot_info_t*)item; handle_info 784 orte/mca/sstore/central/sstore_central_global.c if( handle_info->seq_num == seq ) { handle_info 786 orte/mca/sstore/central/sstore_central_global.c strncmp(handle_info->ref_name, ref, strlen(ref)) ) { handle_info 787 orte/mca/sstore/central/sstore_central_global.c return handle_info; handle_info 789 orte/mca/sstore/central/sstore_central_global.c return handle_info; handle_info 828 orte/mca/sstore/central/sstore_central_global.c orte_sstore_central_global_snapshot_info_t *handle_info = NULL; handle_info 865 orte/mca/sstore/central/sstore_central_global.c if(NULL == (handle_info = find_handle_info(loc_id)) ) { handle_info 873 orte/mca/sstore/central/sstore_central_global.c process_local_pull(sender, buffer, handle_info); handle_info 876 orte/mca/sstore/central/sstore_central_global.c process_local_push(sender, buffer, handle_info); handle_info 883 orte/mca/sstore/central/sstore_central_global.c static int process_local_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_global_snapshot_info_t *handle_info) handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 943 orte/mca/sstore/central/sstore_central_global.c static int process_local_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_global_snapshot_info_t *handle_info) handle_info 991 orte/mca/sstore/central/sstore_central_global.c metadata_write_str(handle_info, handle_info 994 orte/mca/sstore/central/sstore_central_global.c metadata_write_str(handle_info, handle_info 1008 orte/mca/sstore/central/sstore_central_global.c (handle_info->num_procs_synced)++; handle_info 1024 orte/mca/sstore/central/sstore_central_global.c static int init_global_snapshot_directory(orte_sstore_central_global_snapshot_info_t *handle_info) handle_info 1034 orte/mca/sstore/central/sstore_central_global.c handle_info->base_location, handle_info 1035 orte/mca/sstore/central/sstore_central_global.c handle_info->local_location); handle_info 1045 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 1063 orte/mca/sstore/central/sstore_central_global.c static int metadata_open(orte_sstore_central_global_snapshot_info_t * handle_info) handle_info 1066 orte/mca/sstore/central/sstore_central_global.c if( NULL != handle_info->metadata ) { handle_info 1070 orte/mca/sstore/central/sstore_central_global.c if (NULL == (handle_info->metadata = fopen(handle_info->metadata_filename, "a")) ) { handle_info 1073 orte/mca/sstore/central/sstore_central_global.c handle_info->metadata_filename); handle_info 1081 orte/mca/sstore/central/sstore_central_global.c static int metadata_close(orte_sstore_central_global_snapshot_info_t * handle_info) handle_info 1084 orte/mca/sstore/central/sstore_central_global.c if( NULL == handle_info->metadata ) { handle_info 1088 orte/mca/sstore/central/sstore_central_global.c fclose(handle_info->metadata); handle_info 1089 orte/mca/sstore/central/sstore_central_global.c handle_info->metadata = NULL; handle_info 1094 orte/mca/sstore/central/sstore_central_global.c static int metadata_write_int(orte_sstore_central_global_snapshot_info_t * handle_info, char *key, int value) handle_info 1099 orte/mca/sstore/central/sstore_central_global.c if( NULL == handle_info->metadata ) { handle_info 1100 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 1107 orte/mca/sstore/central/sstore_central_global.c fprintf(handle_info->metadata, "%s%d\n", key, value); handle_info 1113 orte/mca/sstore/central/sstore_central_global.c static int metadata_write_str(orte_sstore_central_global_snapshot_info_t * handle_info, char *key, char *value) handle_info 1118 orte/mca/sstore/central/sstore_central_global.c if( NULL == handle_info->metadata ) { handle_info 1119 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 1126 orte/mca/sstore/central/sstore_central_global.c fprintf(handle_info->metadata, "%s%s\n", key, value); handle_info 1132 orte/mca/sstore/central/sstore_central_global.c static int metadata_write_timestamp(orte_sstore_central_global_snapshot_info_t * handle_info) handle_info 1138 orte/mca/sstore/central/sstore_central_global.c if( NULL == handle_info->metadata ) { handle_info 1139 orte/mca/sstore/central/sstore_central_global.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 1147 orte/mca/sstore/central/sstore_central_global.c fprintf(handle_info->metadata, "%s%s", handle_info 1155 orte/mca/sstore/central/sstore_central_global.c static int orte_sstore_central_extract_global_metadata(orte_sstore_central_global_snapshot_info_t * handle_info, handle_info 1183 orte/mca/sstore/central/sstore_central_global.c for(i = 0; i < handle_info->num_procs_total; ++i) { handle_info 1185 orte/mca/sstore/central/sstore_central_global.c vpid_snapshot->ss_handle = handle_info->id; handle_info 1187 orte/mca/sstore/central/sstore_central_global.c vpid_snapshot->process_name.jobid = handle_info->jobid; handle_info 140 orte/mca/sstore/central/sstore_central_local.c static int process_global_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_local_snapshot_info_t *handle_info); handle_info 141 orte/mca/sstore/central/sstore_central_local.c static int process_global_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_local_snapshot_info_t *handle_info); handle_info 142 orte/mca/sstore/central/sstore_central_local.c static int process_app_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_local_snapshot_info_t *handle_info); handle_info 143 orte/mca/sstore/central/sstore_central_local.c static int process_app_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_local_snapshot_info_t *handle_info); handle_info 148 orte/mca/sstore/central/sstore_central_local.c static int append_new_app_handle_info(orte_sstore_central_local_snapshot_info_t *handle_info, handle_info 150 orte/mca/sstore/central/sstore_central_local.c static orte_sstore_central_local_app_snapshot_info_t *find_app_handle_info(orte_sstore_central_local_snapshot_info_t *handle_info, handle_info 153 orte/mca/sstore/central/sstore_central_local.c static int pull_handle_info(orte_sstore_central_local_snapshot_info_t *handle_info ); handle_info 154 orte/mca/sstore/central/sstore_central_local.c static int push_handle_info(orte_sstore_central_local_snapshot_info_t *handle_info ); handle_info 156 orte/mca/sstore/central/sstore_central_local.c static int wait_all_apps_updated(orte_sstore_central_local_snapshot_info_t *handle_info); handle_info 303 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_snapshot_info_t *handle_info = NULL; handle_info 311 orte/mca/sstore/central/sstore_central_local.c if( NULL == (handle_info = find_handle_info(handle)) ) { handle_info 312 orte/mca/sstore/central/sstore_central_local.c handle_info = create_new_handle_info(handle); handle_info 318 orte/mca/sstore/central/sstore_central_local.c if( ORTE_SUCCESS != (ret = pull_handle_info(handle_info)) ) { handle_info 327 orte/mca/sstore/central/sstore_central_local.c while(SSTORE_LOCAL_READY != handle_info->status && handle_info 328 orte/mca/sstore/central/sstore_central_local.c SSTORE_LOCAL_ERROR != handle_info->status ) { handle_info 351 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_snapshot_info_t *handle_info = NULL; handle_info 359 orte/mca/sstore/central/sstore_central_local.c handle_info = find_handle_info(handle); handle_info 364 orte/mca/sstore/central/sstore_central_local.c if( ORTE_SUCCESS != (ret = wait_all_apps_updated(handle_info))) { handle_info 373 orte/mca/sstore/central/sstore_central_local.c if( ORTE_SUCCESS != (ret = push_handle_info(handle_info)) ) { handle_info 379 orte/mca/sstore/central/sstore_central_local.c handle_info->status = SSTORE_LOCAL_SYNCED; handle_info 423 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_snapshot_info_t *handle_info = NULL; handle_info 442 orte/mca/sstore/central/sstore_central_local.c if( NULL == (handle_info = find_handle_info(*handle)) ) { handle_info 443 orte/mca/sstore/central/sstore_central_local.c handle_info = create_new_handle_info(*handle); handle_info 449 orte/mca/sstore/central/sstore_central_local.c if( ORTE_SUCCESS != (ret = process_global_push(peer, buffer, handle_info))) { handle_info 457 orte/mca/sstore/central/sstore_central_local.c handle_info->id, handle_info 458 orte/mca/sstore/central/sstore_central_local.c handle_info->seq_num, handle_info 459 orte/mca/sstore/central/sstore_central_local.c handle_info->global_ref_name)); handle_info 475 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_snapshot_info_t *handle_info = NULL; handle_info 500 orte/mca/sstore/central/sstore_central_local.c if(NULL == (handle_info = find_handle_info(loc_id)) ) { handle_info 501 orte/mca/sstore/central/sstore_central_local.c handle_info = create_new_handle_info(loc_id); handle_info 509 orte/mca/sstore/central/sstore_central_local.c process_global_pull(sender, buffer, handle_info); handle_info 511 orte/mca/sstore/central/sstore_central_local.c process_app_pull(sender, buffer, handle_info); handle_info 516 orte/mca/sstore/central/sstore_central_local.c process_global_push(sender, buffer, handle_info); handle_info 518 orte/mca/sstore/central/sstore_central_local.c process_app_push(sender, buffer, handle_info); handle_info 531 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_snapshot_info_t *handle_info = NULL; handle_info 539 orte/mca/sstore/central/sstore_central_local.c handle_info = OBJ_NEW(orte_sstore_central_local_snapshot_info_t); handle_info 541 orte/mca/sstore/central/sstore_central_local.c handle_info->id = handle; handle_info 543 orte/mca/sstore/central/sstore_central_local.c opal_list_append(active_handles, &(handle_info->super)); handle_info 552 orte/mca/sstore/central/sstore_central_local.c append_new_app_handle_info(handle_info, &child->name); handle_info 555 orte/mca/sstore/central/sstore_central_local.c handle_info->status = SSTORE_LOCAL_INIT; handle_info 557 orte/mca/sstore/central/sstore_central_local.c return handle_info; handle_info 562 orte/mca/sstore/central/sstore_central_local.c orte_sstore_central_local_snapshot_info_t *handle_info = NULL; handle_info 572 orte/mca/sstore/central/sstore_central_local.c handle_info = (orte_sstore_central_local_snapshot_info_t*)item; handle_info 574 orte/mca/sstore/central/sstore_central_local.c if( handle_info->id == handle ) { handle_info 575 orte/mca/sstore/central/sstore_central_local.c return handle_info; handle_info 582 orte/mca/sstore/central/sstore_central_local.c static int append_new_app_handle_info(orte_sstore_central_local_snapshot_info_t *handle_info, handle_info 592 orte/mca/sstore/central/sstore_central_local.c opal_list_append(handle_info->app_info_handle, &(app_info->super)); handle_info 597 orte/mca/sstore/central/sstore_central_local.c static orte_sstore_central_local_app_snapshot_info_t *find_app_handle_info(orte_sstore_central_local_snapshot_info_t *handle_info, handle_info 604 orte/mca/sstore/central/sstore_central_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 605 orte/mca/sstore/central/sstore_central_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 640 orte/mca/sstore/central/sstore_central_local.c static int process_global_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_local_snapshot_info_t *handle_info) handle_info 647 orte/mca/sstore/central/sstore_central_local.c static int process_global_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_local_snapshot_info_t *handle_info) handle_info 655 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(handle_info->seq_num), &count, OPAL_INT))) { handle_info 662 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(handle_info->global_ref_name), &count, OPAL_STRING))) { handle_info 669 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(handle_info->location_fmt), &count, OPAL_STRING))) { handle_info 678 orte/mca/sstore/central/sstore_central_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 679 orte/mca/sstore/central/sstore_central_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 687 orte/mca/sstore/central/sstore_central_local.c opal_asprintf(&(app_info->local_location), handle_info->location_fmt, app_info->name.vpid); handle_info 700 orte/mca/sstore/central/sstore_central_local.c handle_info->status = SSTORE_LOCAL_READY; handle_info 702 orte/mca/sstore/central/sstore_central_local.c handle_info->status = SSTORE_LOCAL_ERROR; handle_info 708 orte/mca/sstore/central/sstore_central_local.c static int process_app_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_local_snapshot_info_t *handle_info) handle_info 718 orte/mca/sstore/central/sstore_central_local.c app_info = find_app_handle_info(handle_info, peer); handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 780 orte/mca/sstore/central/sstore_central_local.c static int process_app_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_central_local_snapshot_info_t *handle_info) handle_info 789 orte/mca/sstore/central/sstore_central_local.c app_info = find_app_handle_info(handle_info, peer); handle_info 820 orte/mca/sstore/central/sstore_central_local.c static int wait_all_apps_updated(orte_sstore_central_local_snapshot_info_t *handle_info) handle_info 828 orte/mca/sstore/central/sstore_central_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 829 orte/mca/sstore/central/sstore_central_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 850 orte/mca/sstore/central/sstore_central_local.c static int pull_handle_info(orte_sstore_central_local_snapshot_info_t *handle_info ) handle_info 860 orte/mca/sstore/central/sstore_central_local.c if( 0 <= handle_info->seq_num && handle_info 861 orte/mca/sstore/central/sstore_central_local.c NULL != handle_info->global_ref_name && handle_info 862 orte/mca/sstore/central/sstore_central_local.c NULL != handle_info->location_fmt ) { handle_info 863 orte/mca/sstore/central/sstore_central_local.c handle_info->status = SSTORE_LOCAL_READY; handle_info 879 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { handle_info 905 orte/mca/sstore/central/sstore_central_local.c static int push_handle_info(orte_sstore_central_local_snapshot_info_t *handle_info ) handle_info 923 orte/mca/sstore/central/sstore_central_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { handle_info 929 orte/mca/sstore/central/sstore_central_local.c list_size = opal_list_get_size(handle_info->app_info_handle); handle_info 939 orte/mca/sstore/central/sstore_central_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 940 orte/mca/sstore/central/sstore_central_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 106 orte/mca/sstore/stage/sstore_stage_app.c static int init_local_snapshot_directory(orte_sstore_stage_app_snapshot_info_t *handle_info); handle_info 107 orte/mca/sstore/stage/sstore_stage_app.c static int pull_handle_info(orte_sstore_stage_app_snapshot_info_t *handle_info ); handle_info 108 orte/mca/sstore/stage/sstore_stage_app.c static int push_handle_info(orte_sstore_stage_app_snapshot_info_t *handle_info ); handle_info 110 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_open(orte_sstore_stage_app_snapshot_info_t * handle_info); handle_info 111 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_close(orte_sstore_stage_app_snapshot_info_t * handle_info); handle_info 112 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_write_str(orte_sstore_stage_app_snapshot_info_t * handle_info, char * key, char *value); handle_info 113 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_write_int(orte_sstore_stage_app_snapshot_info_t * handle_info, char *key, int value); handle_info 114 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_write_timestamp(orte_sstore_stage_app_snapshot_info_t * handle_info); handle_info 201 orte/mca/sstore/stage/sstore_stage_app.c orte_sstore_stage_app_snapshot_info_t *handle_info = NULL; handle_info 210 orte/mca/sstore/stage/sstore_stage_app.c handle_info = find_handle_info(handle); handle_info 211 orte/mca/sstore/stage/sstore_stage_app.c if( NULL != handle_info ) { handle_info 213 orte/mca/sstore/stage/sstore_stage_app.c opal_list_remove_item(active_handles, &(handle_info->super)); handle_info 215 orte/mca/sstore/stage/sstore_stage_app.c handle_info = create_new_handle_info(handle); handle_info 220 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = pull_handle_info(handle_info)) ) { handle_info 229 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = init_local_snapshot_directory(handle_info)) ) { handle_info 242 orte/mca/sstore/stage/sstore_stage_app.c orte_sstore_stage_app_snapshot_info_t *handle_info = NULL; handle_info 250 orte/mca/sstore/stage/sstore_stage_app.c handle_info = find_handle_info(handle); handle_info 256 orte/mca/sstore/stage/sstore_stage_app.c opal_asprintf(value, "%d", handle_info->seq_num); handle_info 259 orte/mca/sstore/stage/sstore_stage_app.c *value = strdup(handle_info->local_location); handle_info 262 orte/mca/sstore/stage/sstore_stage_app.c *value = strdup(handle_info->metadata_filename); handle_info 265 orte/mca/sstore/stage/sstore_stage_app.c *value = strdup(handle_info->global_ref_name); handle_info 279 orte/mca/sstore/stage/sstore_stage_app.c orte_sstore_stage_app_snapshot_info_t *handle_info = NULL; handle_info 300 orte/mca/sstore/stage/sstore_stage_app.c handle_info = find_handle_info(handle); handle_info 306 orte/mca/sstore/stage/sstore_stage_app.c if( NULL != handle_info->crs_comp ) { handle_info 307 orte/mca/sstore/stage/sstore_stage_app.c free(handle_info->crs_comp); handle_info 309 orte/mca/sstore/stage/sstore_stage_app.c handle_info->crs_comp = strdup(value); handle_info 312 orte/mca/sstore/stage/sstore_stage_app.c handle_info->ckpt_skipped = true; handle_info 317 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_write_str(handle_info, key_str, value))) { handle_info 335 orte/mca/sstore/stage/sstore_stage_app.c orte_sstore_stage_app_snapshot_info_t *handle_info = NULL; handle_info 343 orte/mca/sstore/stage/sstore_stage_app.c handle_info = find_handle_info(handle); handle_info 348 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_write_timestamp(handle_info)) ) { handle_info 354 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_close(handle_info)) ) { handle_info 363 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = push_handle_info(handle_info)) ) { handle_info 398 orte/mca/sstore/stage/sstore_stage_app.c orte_sstore_stage_app_snapshot_info_t *handle_info = NULL; handle_info 400 orte/mca/sstore/stage/sstore_stage_app.c handle_info = OBJ_NEW(orte_sstore_stage_app_snapshot_info_t); handle_info 402 orte/mca/sstore/stage/sstore_stage_app.c handle_info->id = handle; handle_info 404 orte/mca/sstore/stage/sstore_stage_app.c opal_list_append(active_handles, &(handle_info->super)); handle_info 406 orte/mca/sstore/stage/sstore_stage_app.c return handle_info; handle_info 411 orte/mca/sstore/stage/sstore_stage_app.c orte_sstore_stage_app_snapshot_info_t *handle_info = NULL; handle_info 417 orte/mca/sstore/stage/sstore_stage_app.c handle_info = (orte_sstore_stage_app_snapshot_info_t*)item; handle_info 419 orte/mca/sstore/stage/sstore_stage_app.c if( handle_info->id == handle ) { handle_info 420 orte/mca/sstore/stage/sstore_stage_app.c return handle_info; handle_info 427 orte/mca/sstore/stage/sstore_stage_app.c static int pull_handle_info(orte_sstore_stage_app_snapshot_info_t *handle_info ) handle_info 448 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { handle_info 492 orte/mca/sstore/stage/sstore_stage_app.c if( loc_id != handle_info->id ) { handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 537 orte/mca/sstore/stage/sstore_stage_app.c static int push_handle_info(orte_sstore_stage_app_snapshot_info_t *handle_info ) handle_info 552 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { handle_info 558 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->ckpt_skipped), 1, OPAL_BOOL))) { handle_info 564 orte/mca/sstore/stage/sstore_stage_app.c if( !handle_info->ckpt_skipped ) { handle_info 565 orte/mca/sstore/stage/sstore_stage_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->crs_comp), 1, OPAL_STRING))) { handle_info 591 orte/mca/sstore/stage/sstore_stage_app.c static int init_local_snapshot_directory(orte_sstore_stage_app_snapshot_info_t *handle_info) handle_info 599 orte/mca/sstore/stage/sstore_stage_app.c if(OPAL_SUCCESS != (ret = opal_os_dirpath_create(handle_info->local_location, my_mode)) ) { handle_info 603 orte/mca/sstore/stage/sstore_stage_app.c handle_info->local_location); handle_info 612 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 621 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_write_timestamp(handle_info)) ) { handle_info 627 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, SSTORE_METADATA_LOCAL_PID_STR, (int)getpid())) ) { handle_info 633 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_close(handle_info)) ) { handle_info 647 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_open(orte_sstore_stage_app_snapshot_info_t * handle_info) handle_info 650 orte/mca/sstore/stage/sstore_stage_app.c if( NULL != handle_info->metadata ) { handle_info 654 orte/mca/sstore/stage/sstore_stage_app.c if (NULL == (handle_info->metadata = fopen(handle_info->metadata_filename, "a")) ) { handle_info 657 orte/mca/sstore/stage/sstore_stage_app.c handle_info->metadata_filename); handle_info 665 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_close(orte_sstore_stage_app_snapshot_info_t * handle_info) handle_info 668 orte/mca/sstore/stage/sstore_stage_app.c if( NULL == handle_info->metadata ) { handle_info 672 orte/mca/sstore/stage/sstore_stage_app.c fclose(handle_info->metadata); handle_info 673 orte/mca/sstore/stage/sstore_stage_app.c handle_info->metadata = NULL; handle_info 678 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_write_str(orte_sstore_stage_app_snapshot_info_t * handle_info, char *key, char *value) handle_info 683 orte/mca/sstore/stage/sstore_stage_app.c if( NULL == handle_info->metadata ) { handle_info 684 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 691 orte/mca/sstore/stage/sstore_stage_app.c fprintf(handle_info->metadata, "%s%s\n", key, value); handle_info 697 orte/mca/sstore/stage/sstore_stage_app.c if( NULL != handle_info->metadata ) { handle_info 698 orte/mca/sstore/stage/sstore_stage_app.c fclose(handle_info->metadata); handle_info 699 orte/mca/sstore/stage/sstore_stage_app.c handle_info->metadata = NULL; handle_info 705 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_write_int(orte_sstore_stage_app_snapshot_info_t * handle_info, char *key, int value) handle_info 710 orte/mca/sstore/stage/sstore_stage_app.c if( NULL == handle_info->metadata ) { handle_info 711 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 718 orte/mca/sstore/stage/sstore_stage_app.c fprintf(handle_info->metadata, "%s%d\n", key, value); handle_info 724 orte/mca/sstore/stage/sstore_stage_app.c static int metadata_write_timestamp(orte_sstore_stage_app_snapshot_info_t * handle_info) handle_info 730 orte/mca/sstore/stage/sstore_stage_app.c if( NULL == handle_info->metadata ) { handle_info 731 orte/mca/sstore/stage/sstore_stage_app.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 739 orte/mca/sstore/stage/sstore_stage_app.c fprintf(handle_info->metadata, "%s%s", SSTORE_METADATA_INTERNAL_TIME_STR, ctime(×tamp)); handle_info 172 orte/mca/sstore/stage/sstore_stage_global.c static int process_local_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_global_snapshot_info_t *handle_info); handle_info 173 orte/mca/sstore/stage/sstore_stage_global.c static int process_local_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_global_snapshot_info_t *handle_info); handle_info 174 orte/mca/sstore/stage/sstore_stage_global.c static int process_local_done(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_global_snapshot_info_t *handle_info); handle_info 175 orte/mca/sstore/stage/sstore_stage_global.c static int xcast_remove_all(orte_sstore_stage_global_snapshot_info_t *handle_info); handle_info 180 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_open(orte_sstore_stage_global_snapshot_info_t * handle_info); handle_info 181 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_close(orte_sstore_stage_global_snapshot_info_t * handle_info); handle_info 182 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_write_int(orte_sstore_stage_global_snapshot_info_t * handle_info, char * key, int value); handle_info 183 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_write_str(orte_sstore_stage_global_snapshot_info_t * handle_info, char * key, char *value); handle_info 184 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_write_timestamp(orte_sstore_stage_global_snapshot_info_t * handle_info); handle_info 186 orte/mca/sstore/stage/sstore_stage_global.c static int init_global_snapshot_directory(orte_sstore_stage_global_snapshot_info_t *handle_info); handle_info 189 orte/mca/sstore/stage/sstore_stage_global.c static int orte_sstore_stage_extract_global_metadata(orte_sstore_stage_global_snapshot_info_t * handle_info, handle_info 192 orte/mca/sstore/stage/sstore_stage_global.c static int wait_all_filem(orte_sstore_stage_global_snapshot_info_t *handle_info); handle_info 193 orte/mca/sstore/stage/sstore_stage_global.c static void sync_global_dir(orte_sstore_stage_global_snapshot_info_t *handle_info); handle_info 201 orte/mca/sstore/stage/sstore_stage_global.c static void sstore_stage_report_progress(orte_sstore_stage_global_snapshot_info_t *handle_info); handle_info 203 orte/mca/sstore/stage/sstore_stage_global.c #define SSTORE_STAGE_REPORT_PROGRESS(handle_info) \ handle_info 206 orte/mca/sstore/stage/sstore_stage_global.c sstore_stage_report_progress(handle_info); \ handle_info 363 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 377 orte/mca/sstore/stage/sstore_stage_global.c handle_info = (orte_sstore_stage_global_snapshot_info_t*)item; handle_info 378 orte/mca/sstore/stage/sstore_stage_global.c if( SSTORE_GLOBAL_SYNCED != handle_info->state && handle_info 379 orte/mca/sstore/stage/sstore_stage_global.c SSTORE_GLOBAL_NONE != handle_info->state ) { handle_info 425 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 434 orte/mca/sstore/stage/sstore_stage_global.c handle_info = create_new_handle_info(seq, SSTORE_HANDLE_TYPE_CKPT, jobid); handle_info 439 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = init_global_snapshot_directory(handle_info)) ) { handle_info 448 orte/mca/sstore/stage/sstore_stage_global.c *handle = handle_info->id; handle_info 458 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 467 orte/mca/sstore/stage/sstore_stage_global.c handle_info = find_handle_info(*handle); handle_info 470 orte/mca/sstore/stage/sstore_stage_global.c handle_info = find_handle_info(orte_sstore_handle_last_stable); handle_info 477 orte/mca/sstore/stage/sstore_stage_global.c snapshot->seq_num = handle_info->seq_num; handle_info 478 orte/mca/sstore/stage/sstore_stage_global.c snapshot->reference = strdup(handle_info->ref_name); handle_info 479 orte/mca/sstore/stage/sstore_stage_global.c snapshot->basedir = strdup(handle_info->base_location); handle_info 480 orte/mca/sstore/stage/sstore_stage_global.c snapshot->metadata_filename = strdup(handle_info->metadata_filename); handle_info 484 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = orte_sstore_stage_extract_global_metadata(handle_info, snapshot)) ) { handle_info 508 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 516 orte/mca/sstore/stage/sstore_stage_global.c handle_info = find_handle_info(handle); handle_info 517 orte/mca/sstore/stage/sstore_stage_global.c if( SSTORE_GLOBAL_REG != handle_info->state ) { handle_info 518 orte/mca/sstore/stage/sstore_stage_global.c handle_info->state = SSTORE_GLOBAL_REG; handle_info 528 orte/mca/sstore/stage/sstore_stage_global.c if( handle_info->migrating ) { handle_info 529 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, handle_info 531 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num)) ) { handle_info 537 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, handle_info 539 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num)) ) { handle_info 546 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_write_str(handle_info, handle_info 554 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_write_timestamp(handle_info)) ) { handle_info 567 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 575 orte/mca/sstore/stage/sstore_stage_global.c handle_info = find_handle_info(handle); handle_info 582 orte/mca/sstore/stage/sstore_stage_global.c *value = strdup(handle_info->ref_name); handle_info 586 orte/mca/sstore/stage/sstore_stage_global.c opal_asprintf(value, "%d", handle_info->seq_num); handle_info 591 orte/mca/sstore/stage/sstore_stage_global.c handle_info->base_location, handle_info 592 orte/mca/sstore/stage/sstore_stage_global.c handle_info->ref_name, handle_info 593 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num); handle_info 602 orte/mca/sstore/stage/sstore_stage_global.c handle_info->base_location, handle_info 603 orte/mca/sstore/stage/sstore_stage_global.c handle_info->ref_name, handle_info 604 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num, handle_info 617 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 626 orte/mca/sstore/stage/sstore_stage_global.c handle_info = find_handle_info(handle); handle_info 632 orte/mca/sstore/stage/sstore_stage_global.c handle_info->migrating = true; handle_info 642 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_write_str(handle_info, key_str, value))) { handle_info 661 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 669 orte/mca/sstore/stage/sstore_stage_global.c handle_info = find_handle_info(handle); handle_info 670 orte/mca/sstore/stage/sstore_stage_global.c if( SSTORE_GLOBAL_SYNCING != handle_info->state ) { handle_info 671 orte/mca/sstore/stage/sstore_stage_global.c handle_info->state = SSTORE_GLOBAL_SYNCING; handle_info 680 orte/mca/sstore/stage/sstore_stage_global.c while(handle_info->num_procs_synced < handle_info->num_procs_total) { handle_info 689 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = wait_all_filem(handle_info))) { handle_info 699 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_write_timestamp(handle_info)) ) { handle_info 705 orte/mca/sstore/stage/sstore_stage_global.c if( handle_info->migrating ) { handle_info 706 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, handle_info 708 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num)) ) { handle_info 714 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_write_int(handle_info, handle_info 716 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num)) ) { handle_info 723 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_close(handle_info)) ) { handle_info 730 orte/mca/sstore/stage/sstore_stage_global.c if( !handle_info->migrating ) { handle_info 735 orte/mca/sstore/stage/sstore_stage_global.c handle_info->state = SSTORE_GLOBAL_SYNCED; handle_info 741 orte/mca/sstore/stage/sstore_stage_global.c static void sync_global_dir(orte_sstore_stage_global_snapshot_info_t *handle_info) handle_info 755 orte/mca/sstore/stage/sstore_stage_global.c handle_info->base_location, handle_info 756 orte/mca/sstore/stage/sstore_stage_global.c handle_info->ref_name, handle_info 757 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num); handle_info 776 orte/mca/sstore/stage/sstore_stage_global.c for(f_item = opal_list_get_first(handle_info->filem_requests); handle_info 777 orte/mca/sstore/stage/sstore_stage_global.c f_item != opal_list_get_end(handle_info->filem_requests); handle_info 831 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 839 orte/mca/sstore/stage/sstore_stage_global.c handle_info = find_handle_info(handle); handle_info 853 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->seq_num), 1, OPAL_INT )) ) { handle_info 859 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->ref_name), 1, OPAL_STRING )) ) { handle_info 865 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->app_local_location_fmt), 1, OPAL_STRING )) ) { handle_info 872 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->app_local_cache_location_fmt), 1, OPAL_STRING )) ) { handle_info 879 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->migrating), 1, OPAL_BOOL )) ) { handle_info 921 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 924 orte/mca/sstore/stage/sstore_stage_global.c handle_info = OBJ_NEW(orte_sstore_stage_global_snapshot_info_t); handle_info 926 orte/mca/sstore/stage/sstore_stage_global.c handle_info->jobid = jobid; handle_info 928 orte/mca/sstore/stage/sstore_stage_global.c handle_info->state = SSTORE_GLOBAL_INIT; handle_info 930 orte/mca/sstore/stage/sstore_stage_global.c handle_info->handle_type = type; handle_info 932 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num = seq; handle_info 934 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_base_get_global_snapshot_ref(&(handle_info->ref_name), getpid()); handle_info 936 orte/mca/sstore/stage/sstore_stage_global.c opal_asprintf(&(handle_info->local_location), "%s/%d", handle_info 937 orte/mca/sstore/stage/sstore_stage_global.c handle_info->ref_name, handle_info->seq_num); handle_info 940 orte/mca/sstore/stage/sstore_stage_global.c opal_asprintf(&(handle_info->app_local_location_fmt), "%s/%s/%s/%s", handle_info 947 orte/mca/sstore/stage/sstore_stage_global.c opal_asprintf(&(handle_info->app_local_cache_location_fmt), "%s/%s/%s/%d/%s", handle_info 951 orte/mca/sstore/stage/sstore_stage_global.c handle_info->seq_num, handle_info 956 orte/mca/sstore/stage/sstore_stage_global.c opal_asprintf(&(handle_info->app_global_location_fmt), "%s/%s/%s", handle_info 957 orte/mca/sstore/stage/sstore_stage_global.c handle_info->base_location, handle_info 958 orte/mca/sstore/stage/sstore_stage_global.c handle_info->local_location, handle_info 961 orte/mca/sstore/stage/sstore_stage_global.c opal_asprintf(&(handle_info->metadata_filename), "%s/%s/%s", handle_info 962 orte/mca/sstore/stage/sstore_stage_global.c handle_info->base_location, handle_info 963 orte/mca/sstore/stage/sstore_stage_global.c handle_info->ref_name, handle_info 966 orte/mca/sstore/stage/sstore_stage_global.c jdata = orte_get_job_data_object(handle_info->jobid); handle_info 967 orte/mca/sstore/stage/sstore_stage_global.c handle_info->num_procs_total = (int)jdata->num_procs; handle_info 969 orte/mca/sstore/stage/sstore_stage_global.c opal_list_append(active_handles, &(handle_info->super)); handle_info 971 orte/mca/sstore/stage/sstore_stage_global.c return handle_info; handle_info 976 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 982 orte/mca/sstore/stage/sstore_stage_global.c handle_info = (orte_sstore_stage_global_snapshot_info_t*)item; handle_info 984 orte/mca/sstore/stage/sstore_stage_global.c if( handle_info->id == handle ) { handle_info 985 orte/mca/sstore/stage/sstore_stage_global.c return handle_info; handle_info 1023 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_stage_global_snapshot_info_t *handle_info = NULL; handle_info 1064 orte/mca/sstore/stage/sstore_stage_global.c if(NULL == (handle_info = find_handle_info(loc_id)) ) { handle_info 1080 orte/mca/sstore/stage/sstore_stage_global.c process_local_pull(sender, buffer, handle_info); handle_info 1083 orte/mca/sstore/stage/sstore_stage_global.c process_local_push(sender, buffer, handle_info); handle_info 1090 orte/mca/sstore/stage/sstore_stage_global.c process_local_done(sender, buffer, handle_info); handle_info 1097 orte/mca/sstore/stage/sstore_stage_global.c static int process_local_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_global_snapshot_info_t *handle_info) handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 1147 orte/mca/sstore/stage/sstore_stage_global.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->migrating), 1, OPAL_BOOL))) { handle_info 1171 orte/mca/sstore/stage/sstore_stage_global.c static int process_local_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_global_snapshot_info_t *handle_info) handle_info 1241 orte/mca/sstore/stage/sstore_stage_global.c if( NULL == handle_info->compress_comp ) { handle_info 1242 orte/mca/sstore/stage/sstore_stage_global.c handle_info->compress_comp = strdup(compress_comp); handle_info 1251 orte/mca/sstore/stage/sstore_stage_global.c if( NULL == handle_info->compress_postfix ) { handle_info 1252 orte/mca/sstore/stage/sstore_stage_global.c handle_info->compress_postfix = strdup(compress_postfix); handle_info 1269 orte/mca/sstore/stage/sstore_stage_global.c handle_info->app_global_location_fmt, handle_info 1276 orte/mca/sstore/stage/sstore_stage_global.c handle_info->app_global_location_fmt, handle_info 1286 orte/mca/sstore/stage/sstore_stage_global.c handle_info->app_local_location_fmt, handle_info 1293 orte/mca/sstore/stage/sstore_stage_global.c handle_info->app_local_location_fmt, handle_info 1310 orte/mca/sstore/stage/sstore_stage_global.c metadata_write_str(handle_info, handle_info 1313 orte/mca/sstore/stage/sstore_stage_global.c metadata_write_str(handle_info, handle_info 1317 orte/mca/sstore/stage/sstore_stage_global.c metadata_write_str(handle_info, handle_info 1320 orte/mca/sstore/stage/sstore_stage_global.c metadata_write_str(handle_info, handle_info 1347 orte/mca/sstore/stage/sstore_stage_global.c (handle_info->num_procs_synced)++; handle_info 1357 orte/mca/sstore/stage/sstore_stage_global.c handle_info->num_procs_synced, handle_info 1358 orte/mca/sstore/stage/sstore_stage_global.c handle_info->num_procs_total)); handle_info 1359 orte/mca/sstore/stage/sstore_stage_global.c opal_list_append(handle_info->filem_requests, &(filem_request->super)); handle_info 1392 orte/mca/sstore/stage/sstore_stage_global.c static int process_local_done(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_global_snapshot_info_t *handle_info) handle_info 1408 orte/mca/sstore/stage/sstore_stage_global.c (handle_info->num_procs_done) += (int)num_entries; handle_info 1410 orte/mca/sstore/stage/sstore_stage_global.c SSTORE_STAGE_REPORT_PROGRESS(handle_info); handle_info 1416 orte/mca/sstore/stage/sstore_stage_global.c handle_info->num_procs_done, handle_info 1417 orte/mca/sstore/stage/sstore_stage_global.c handle_info->num_procs_total)); handle_info 1423 orte/mca/sstore/stage/sstore_stage_global.c static int init_global_snapshot_directory(orte_sstore_stage_global_snapshot_info_t *handle_info) handle_info 1433 orte/mca/sstore/stage/sstore_stage_global.c handle_info->base_location, handle_info 1434 orte/mca/sstore/stage/sstore_stage_global.c handle_info->local_location); handle_info 1444 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 1459 orte/mca/sstore/stage/sstore_stage_global.c static int wait_all_filem(orte_sstore_stage_global_snapshot_info_t *handle_info) handle_info 1473 orte/mca/sstore/stage/sstore_stage_global.c (int)opal_list_get_size(handle_info->filem_requests) )); handle_info 1475 orte/mca/sstore/stage/sstore_stage_global.c if(ORTE_SUCCESS != (ret = orte_filem.wait_all(handle_info->filem_requests)) ) { handle_info 1486 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = xcast_remove_all(handle_info))) { handle_info 1495 orte/mca/sstore/stage/sstore_stage_global.c sync_global_dir(handle_info); handle_info 1502 orte/mca/sstore/stage/sstore_stage_global.c while(handle_info->num_procs_done < handle_info->num_procs_total) { handle_info 1510 orte/mca/sstore/stage/sstore_stage_global.c while (NULL != (item = opal_list_remove_first(handle_info->filem_requests) ) ) { handle_info 1513 orte/mca/sstore/stage/sstore_stage_global.c OBJ_DESTRUCT(handle_info->filem_requests); handle_info 1518 orte/mca/sstore/stage/sstore_stage_global.c static int xcast_remove_all(orte_sstore_stage_global_snapshot_info_t *handle_info) handle_info 1525 orte/mca/sstore/stage/sstore_stage_global.c handle_info->num_procs_done = 0; handle_info 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))) { handle_info 1570 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_open(orte_sstore_stage_global_snapshot_info_t * handle_info) handle_info 1573 orte/mca/sstore/stage/sstore_stage_global.c if( NULL != handle_info->metadata ) { handle_info 1577 orte/mca/sstore/stage/sstore_stage_global.c if (NULL == (handle_info->metadata = fopen(handle_info->metadata_filename, "a")) ) { handle_info 1580 orte/mca/sstore/stage/sstore_stage_global.c handle_info->metadata_filename); handle_info 1588 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_close(orte_sstore_stage_global_snapshot_info_t * handle_info) handle_info 1591 orte/mca/sstore/stage/sstore_stage_global.c if( NULL == handle_info->metadata ) { handle_info 1595 orte/mca/sstore/stage/sstore_stage_global.c fclose(handle_info->metadata); handle_info 1596 orte/mca/sstore/stage/sstore_stage_global.c handle_info->metadata = NULL; handle_info 1601 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_write_int(orte_sstore_stage_global_snapshot_info_t * handle_info, char *key, int value) handle_info 1606 orte/mca/sstore/stage/sstore_stage_global.c if( NULL == handle_info->metadata ) { handle_info 1607 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 1614 orte/mca/sstore/stage/sstore_stage_global.c fprintf(handle_info->metadata, "%s%d\n", key, value); handle_info 1620 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_write_str(orte_sstore_stage_global_snapshot_info_t * handle_info, char *key, char *value) handle_info 1625 orte/mca/sstore/stage/sstore_stage_global.c if( NULL == handle_info->metadata ) { handle_info 1626 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 1633 orte/mca/sstore/stage/sstore_stage_global.c fprintf(handle_info->metadata, "%s%s\n", key, value); handle_info 1639 orte/mca/sstore/stage/sstore_stage_global.c static int metadata_write_timestamp(orte_sstore_stage_global_snapshot_info_t * handle_info) handle_info 1645 orte/mca/sstore/stage/sstore_stage_global.c if( NULL == handle_info->metadata ) { handle_info 1646 orte/mca/sstore/stage/sstore_stage_global.c if( ORTE_SUCCESS != (ret = metadata_open(handle_info)) ) { handle_info 1654 orte/mca/sstore/stage/sstore_stage_global.c fprintf(handle_info->metadata, "%s%s", handle_info 1662 orte/mca/sstore/stage/sstore_stage_global.c static int orte_sstore_stage_extract_global_metadata(orte_sstore_stage_global_snapshot_info_t * handle_info, handle_info 1690 orte/mca/sstore/stage/sstore_stage_global.c for(i = 0; i < handle_info->num_procs_total; ++i) { handle_info 1692 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->ss_handle = handle_info->id; handle_info 1694 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->process_name.jobid = handle_info->jobid; handle_info 1702 orte/mca/sstore/stage/sstore_stage_global.c if( NULL != handle_info->compress_comp ) { handle_info 1703 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->compress_comp = strdup(handle_info->compress_comp); handle_info 1707 orte/mca/sstore/stage/sstore_stage_global.c if( NULL != handle_info->compress_postfix ) { handle_info 1708 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->compress_postfix = strdup(handle_info->compress_postfix); handle_info 1740 orte/mca/sstore/stage/sstore_stage_global.c static void sstore_stage_report_progress(orte_sstore_stage_global_snapshot_info_t *handle_info) handle_info 1744 orte/mca/sstore/stage/sstore_stage_global.c perc_done = (handle_info->num_procs_total - handle_info->num_procs_done); handle_info 1745 orte/mca/sstore/stage/sstore_stage_global.c perc_done = perc_done / (1.0 * handle_info->num_procs_total); handle_info 1748 orte/mca/sstore/stage/sstore_stage_global.c if( perc_done >= (handle_info->last_progress_report + orte_sstore_stage_progress_meter ) || handle_info 1749 orte/mca/sstore/stage/sstore_stage_global.c handle_info->last_progress_report == 0.0 ) { handle_info 1750 orte/mca/sstore/stage/sstore_stage_global.c handle_info->last_progress_report = perc_done; handle_info 175 orte/mca/sstore/stage/sstore_stage_local.c static int process_global_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info); handle_info 176 orte/mca/sstore/stage/sstore_stage_local.c static int process_global_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info); handle_info 177 orte/mca/sstore/stage/sstore_stage_local.c static int process_global_remove(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info); handle_info 178 orte/mca/sstore/stage/sstore_stage_local.c static int process_app_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info); handle_info 179 orte/mca/sstore/stage/sstore_stage_local.c static int process_app_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info); handle_info 185 orte/mca/sstore/stage/sstore_stage_local.c static int append_new_app_handle_info(orte_sstore_stage_local_snapshot_info_t *handle_info, handle_info 187 orte/mca/sstore/stage/sstore_stage_local.c static orte_sstore_stage_local_app_snapshot_info_t *find_app_handle_info(orte_sstore_stage_local_snapshot_info_t *handle_info, handle_info 190 orte/mca/sstore/stage/sstore_stage_local.c static int pull_handle_info(orte_sstore_stage_local_snapshot_info_t *handle_info ); handle_info 191 orte/mca/sstore/stage/sstore_stage_local.c static int push_handle_info(orte_sstore_stage_local_snapshot_info_t *handle_info ); handle_info 193 orte/mca/sstore/stage/sstore_stage_local.c static int wait_all_apps_updated(orte_sstore_stage_local_snapshot_info_t *handle_info); handle_info 195 orte/mca/sstore/stage/sstore_stage_local.c static int start_compression(orte_sstore_stage_local_snapshot_info_t *handle_info, handle_info 198 orte/mca/sstore/stage/sstore_stage_local.c static int wait_all_compressed(orte_sstore_stage_local_snapshot_info_t *handle_info); handle_info 207 orte/mca/sstore/stage/sstore_stage_local.c static int sstore_stage_update_cache(orte_sstore_stage_local_snapshot_info_t *handle_info); handle_info 402 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 420 orte/mca/sstore/stage/sstore_stage_local.c handle_info = (orte_sstore_stage_local_snapshot_info_t*)item; handle_info 421 orte/mca/sstore/stage/sstore_stage_local.c if( SSTORE_LOCAL_DONE != handle_info->status && handle_info 422 orte/mca/sstore/stage/sstore_stage_local.c SSTORE_LOCAL_NONE != handle_info->status && handle_info 423 orte/mca/sstore/stage/sstore_stage_local.c SSTORE_LOCAL_ERROR != handle_info->status ) { handle_info 513 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 521 orte/mca/sstore/stage/sstore_stage_local.c if( NULL == (handle_info = find_handle_info(handle)) ) { handle_info 522 orte/mca/sstore/stage/sstore_stage_local.c handle_info = create_new_handle_info(handle); handle_info 528 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = pull_handle_info(handle_info)) ) { handle_info 537 orte/mca/sstore/stage/sstore_stage_local.c while(SSTORE_LOCAL_READY != handle_info->status && handle_info 538 orte/mca/sstore/stage/sstore_stage_local.c SSTORE_LOCAL_ERROR != handle_info->status ) { handle_info 561 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 569 orte/mca/sstore/stage/sstore_stage_local.c handle_info = find_handle_info(handle); handle_info 574 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = wait_all_apps_updated(handle_info))) { handle_info 584 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = wait_all_compressed(handle_info))) { handle_info 594 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = push_handle_info(handle_info)) ) { handle_info 600 orte/mca/sstore/stage/sstore_stage_local.c handle_info->status = SSTORE_LOCAL_SYNCED; handle_info 644 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 663 orte/mca/sstore/stage/sstore_stage_local.c if( NULL == (handle_info = find_handle_info(*handle)) ) { handle_info 664 orte/mca/sstore/stage/sstore_stage_local.c handle_info = create_new_handle_info(*handle); handle_info 670 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = process_global_push(peer, buffer, handle_info))) { handle_info 683 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 732 orte/mca/sstore/stage/sstore_stage_local.c handle_info = find_handle_info_ref(req_snap_global_ref, req_snap_seq); handle_info 733 orte/mca/sstore/stage/sstore_stage_local.c if( NULL == handle_info ) { handle_info 748 orte/mca/sstore/stage/sstore_stage_local.c if( orte_sstore_stage_enabled_caching && !handle_info->migrating ) { handle_info 761 orte/mca/sstore/stage/sstore_stage_local.c app_info = find_app_handle_info(handle_info, &child->name); handle_info 935 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 943 orte/mca/sstore/stage/sstore_stage_local.c handle_info = OBJ_NEW(orte_sstore_stage_local_snapshot_info_t); handle_info 945 orte/mca/sstore/stage/sstore_stage_local.c handle_info->id = handle; handle_info 947 orte/mca/sstore/stage/sstore_stage_local.c opal_list_append(active_handles, &(handle_info->super)); handle_info 956 orte/mca/sstore/stage/sstore_stage_local.c append_new_app_handle_info(handle_info, &child->name); handle_info 959 orte/mca/sstore/stage/sstore_stage_local.c handle_info->status = SSTORE_LOCAL_INIT; handle_info 961 orte/mca/sstore/stage/sstore_stage_local.c return handle_info; handle_info 966 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 976 orte/mca/sstore/stage/sstore_stage_local.c handle_info = (orte_sstore_stage_local_snapshot_info_t*)item; handle_info 978 orte/mca/sstore/stage/sstore_stage_local.c if( handle_info->id == handle ) { handle_info 979 orte/mca/sstore/stage/sstore_stage_local.c return handle_info; handle_info 988 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 998 orte/mca/sstore/stage/sstore_stage_local.c handle_info = (orte_sstore_stage_local_snapshot_info_t*)item; handle_info 1000 orte/mca/sstore/stage/sstore_stage_local.c if( 0 == strncmp(handle_info->global_ref_name, ref, strlen(ref)) && handle_info 1001 orte/mca/sstore/stage/sstore_stage_local.c handle_info->seq_num == seq ) { handle_info 1002 orte/mca/sstore/stage/sstore_stage_local.c return handle_info; handle_info 1009 orte/mca/sstore/stage/sstore_stage_local.c static int append_new_app_handle_info(orte_sstore_stage_local_snapshot_info_t *handle_info, handle_info 1019 orte/mca/sstore/stage/sstore_stage_local.c opal_list_append(handle_info->app_info_handle, &(app_info->super)); handle_info 1024 orte/mca/sstore/stage/sstore_stage_local.c static orte_sstore_stage_local_app_snapshot_info_t *find_app_handle_info(orte_sstore_stage_local_snapshot_info_t *handle_info, handle_info 1031 orte/mca/sstore/stage/sstore_stage_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 1032 orte/mca/sstore/stage/sstore_stage_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 1108 orte/mca/sstore/stage/sstore_stage_local.c orte_sstore_stage_local_snapshot_info_t *handle_info = NULL; handle_info 1113 orte/mca/sstore/stage/sstore_stage_local.c if(NULL == (handle_info = find_handle_info(loc_id)) ) { handle_info 1114 orte/mca/sstore/stage/sstore_stage_local.c handle_info = create_new_handle_info(loc_id); handle_info 1130 orte/mca/sstore/stage/sstore_stage_local.c process_global_pull(sender, buffer, handle_info); handle_info 1132 orte/mca/sstore/stage/sstore_stage_local.c process_app_pull(sender, buffer, handle_info); handle_info 1137 orte/mca/sstore/stage/sstore_stage_local.c process_global_push(sender, buffer, handle_info); handle_info 1139 orte/mca/sstore/stage/sstore_stage_local.c process_app_push(sender, buffer, handle_info); handle_info 1145 orte/mca/sstore/stage/sstore_stage_local.c process_global_remove(ORTE_PROC_MY_HNP, buffer, handle_info); handle_info 1151 orte/mca/sstore/stage/sstore_stage_local.c static int process_global_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info) handle_info 1158 orte/mca/sstore/stage/sstore_stage_local.c static int process_global_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info) handle_info 1166 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(handle_info->seq_num), &count, OPAL_INT))) { handle_info 1173 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(handle_info->global_ref_name), &count, OPAL_STRING))) { handle_info 1180 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(handle_info->location_fmt), &count, OPAL_STRING))) { handle_info 1188 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(handle_info->cache_location_fmt), &count, OPAL_STRING))) { handle_info 1196 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &(handle_info->migrating), &count, OPAL_BOOL))) { handle_info 1205 orte/mca/sstore/stage/sstore_stage_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 1206 orte/mca/sstore/stage/sstore_stage_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 1214 orte/mca/sstore/stage/sstore_stage_local.c opal_asprintf(&(app_info->local_location), handle_info->location_fmt, app_info->name.vpid); handle_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); handle_info 1235 orte/mca/sstore/stage/sstore_stage_local.c handle_info->status = SSTORE_LOCAL_READY; handle_info 1237 orte/mca/sstore/stage/sstore_stage_local.c handle_info->status = SSTORE_LOCAL_ERROR; handle_info 1243 orte/mca/sstore/stage/sstore_stage_local.c static int process_global_remove(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info) handle_info 1258 orte/mca/sstore/stage/sstore_stage_local.c if( !orte_sstore_stage_enabled_caching || handle_info->migrating ) { handle_info 1259 orte/mca/sstore/stage/sstore_stage_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 1260 orte/mca/sstore/stage/sstore_stage_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 1286 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = sstore_stage_update_cache(handle_info)) ) { handle_info 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))) { handle_info 1308 orte/mca/sstore/stage/sstore_stage_local.c list_size = opal_list_get_size(handle_info->app_info_handle); handle_info 1327 orte/mca/sstore/stage/sstore_stage_local.c handle_info->status = SSTORE_LOCAL_DONE; handle_info 1345 orte/mca/sstore/stage/sstore_stage_local.c static int process_app_pull(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info) handle_info 1355 orte/mca/sstore/stage/sstore_stage_local.c app_info = find_app_handle_info(handle_info, peer); handle_info 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))) { handle_info 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))) { handle_info 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))) { handle_info 1418 orte/mca/sstore/stage/sstore_stage_local.c static int process_app_push(orte_process_name_t* peer, opal_buffer_t* buffer, orte_sstore_stage_local_snapshot_info_t *handle_info) handle_info 1427 orte/mca/sstore/stage/sstore_stage_local.c app_info = find_app_handle_info(handle_info, peer); handle_info 1460 orte/mca/sstore/stage/sstore_stage_local.c static int wait_all_apps_updated(orte_sstore_stage_local_snapshot_info_t *handle_info) handle_info 1468 orte/mca/sstore/stage/sstore_stage_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 1469 orte/mca/sstore/stage/sstore_stage_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 1490 orte/mca/sstore/stage/sstore_stage_local.c static int start_compression(orte_sstore_stage_local_snapshot_info_t *handle_info, handle_info 1524 orte/mca/sstore/stage/sstore_stage_local.c if( NULL == handle_info->compress_comp ) { handle_info 1525 orte/mca/sstore/stage/sstore_stage_local.c handle_info->compress_comp = strdup(opal_compress_base_selected_component.base_version.mca_component_name); handle_info 1526 orte/mca/sstore/stage/sstore_stage_local.c handle_info->compress_postfix = strdup(postfix); handle_info 1570 orte/mca/sstore/stage/sstore_stage_local.c static int wait_all_compressed(orte_sstore_stage_local_snapshot_info_t *handle_info) handle_info 1598 orte/mca/sstore/stage/sstore_stage_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 1599 orte/mca/sstore/stage/sstore_stage_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 1603 orte/mca/sstore/stage/sstore_stage_local.c if( ORTE_SUCCESS != (ret = start_compression(handle_info, app_info)) ) { handle_info 1617 orte/mca/sstore/stage/sstore_stage_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 1618 orte/mca/sstore/stage/sstore_stage_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 1642 orte/mca/sstore/stage/sstore_stage_local.c static int pull_handle_info(orte_sstore_stage_local_snapshot_info_t *handle_info ) handle_info 1652 orte/mca/sstore/stage/sstore_stage_local.c if( 0 <= handle_info->seq_num && handle_info 1653 orte/mca/sstore/stage/sstore_stage_local.c NULL != handle_info->global_ref_name && handle_info 1654 orte/mca/sstore/stage/sstore_stage_local.c NULL != handle_info->location_fmt ) { handle_info 1655 orte/mca/sstore/stage/sstore_stage_local.c handle_info->status = SSTORE_LOCAL_READY; handle_info 1671 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { handle_info 1697 orte/mca/sstore/stage/sstore_stage_local.c static int push_handle_info(orte_sstore_stage_local_snapshot_info_t *handle_info ) handle_info 1715 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->id), 1, ORTE_SSTORE_HANDLE))) { handle_info 1721 orte/mca/sstore/stage/sstore_stage_local.c list_size = opal_list_get_size(handle_info->app_info_handle); handle_info 1731 orte/mca/sstore/stage/sstore_stage_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 1732 orte/mca/sstore/stage/sstore_stage_local.c item != opal_list_get_end(handle_info->app_info_handle); handle_info 1756 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->compress_comp), 1, OPAL_STRING))) { handle_info 1761 orte/mca/sstore/stage/sstore_stage_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(handle_info->compress_postfix), 1, OPAL_STRING))) { handle_info 1867 orte/mca/sstore/stage/sstore_stage_local.c static int sstore_stage_update_cache(orte_sstore_stage_local_snapshot_info_t *handle_info) handle_info 1878 orte/mca/sstore/stage/sstore_stage_local.c if( !orte_sstore_stage_enabled_caching || handle_info->migrating) { handle_info 1882 orte/mca/sstore/stage/sstore_stage_local.c list_size = opal_list_get_size(handle_info->app_info_handle); handle_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); handle_info 1910 orte/mca/sstore/stage/sstore_stage_local.c for(item = opal_list_get_first(handle_info->app_info_handle); handle_info 1911 orte/mca/sstore/stage/sstore_stage_local.c item != opal_list_get_end(handle_info->app_info_handle);