vpid_snapshot 161 orte/mca/errmgr/base/errmgr_base_fns.c orte_sstore_base_local_snapshot_info_t *vpid_snapshot = NULL; vpid_snapshot 178 orte/mca/errmgr/base/errmgr_base_fns.c vpid_snapshot = (orte_sstore_base_local_snapshot_info_t*)item; vpid_snapshot 180 orte/mca/errmgr/base/errmgr_base_fns.c &vpid_snapshot->process_name, vpid_snapshot 185 orte/mca/errmgr/base/errmgr_base_fns.c vpid_snapshot = NULL; vpid_snapshot 189 orte/mca/errmgr/base/errmgr_base_fns.c if( NULL == vpid_snapshot ) { vpid_snapshot 195 orte/mca/errmgr/base/errmgr_base_fns.c orte_sstore.get_attr(vpid_snapshot->ss_handle, vpid_snapshot 198 orte/mca/errmgr/base/errmgr_base_fns.c orte_sstore.get_attr(vpid_snapshot->ss_handle, vpid_snapshot 201 orte/mca/errmgr/base/errmgr_base_fns.c orte_sstore.get_attr(vpid_snapshot->ss_handle, vpid_snapshot 204 orte/mca/errmgr/base/errmgr_base_fns.c orte_sstore.get_attr(vpid_snapshot->ss_handle, vpid_snapshot 207 orte/mca/errmgr/base/errmgr_base_fns.c orte_sstore.get_attr(vpid_snapshot->ss_handle, vpid_snapshot 256 orte/mca/errmgr/base/errmgr_base_fns.c opal_asprintf(&tmp_str, reference_fmt_str, vpid_snapshot->process_name.vpid); vpid_snapshot 262 orte/mca/errmgr/base/errmgr_base_fns.c (vpid_snapshot->compress_comp == NULL ? "" : vpid_snapshot->compress_comp), vpid_snapshot 263 orte/mca/errmgr/base/errmgr_base_fns.c (vpid_snapshot->compress_postfix == NULL ? "" : vpid_snapshot->compress_postfix), vpid_snapshot 289 orte/mca/errmgr/base/errmgr_base_fns.c opal_asprintf(&tmp_str, reference_fmt_str, vpid_snapshot->process_name.vpid); vpid_snapshot 295 orte/mca/errmgr/base/errmgr_base_fns.c (vpid_snapshot->compress_comp == NULL ? "" : vpid_snapshot->compress_comp), vpid_snapshot 296 orte/mca/errmgr/base/errmgr_base_fns.c (vpid_snapshot->compress_postfix == NULL ? "" : vpid_snapshot->compress_postfix), vpid_snapshot 316 orte/mca/errmgr/base/errmgr_base_fns.c opal_asprintf(&tmp_str, reference_fmt_str, vpid_snapshot->process_name.vpid); vpid_snapshot 82 orte/mca/snapc/full/snapc_full_local.c static int local_define_pipe_names(orte_snapc_full_app_snapshot_t *vpid_snapshot); vpid_snapshot 115 orte/mca/snapc/full/snapc_full_local.c static int local_coord_job_state_update_finished_local_vpid(orte_snapc_full_app_snapshot_t *vpid_snapshot); vpid_snapshot 126 orte/mca/snapc/full/snapc_full_local.c static int snapc_full_local_start_ckpt_open_comm(orte_snapc_full_app_snapshot_t *vpid_snapshot); vpid_snapshot 127 orte/mca/snapc/full/snapc_full_local.c static int snapc_full_local_start_ckpt_handshake_opts(orte_snapc_full_app_snapshot_t *vpid_snapshot, vpid_snapshot 129 orte/mca/snapc/full/snapc_full_local.c static int snapc_full_local_start_ckpt_handshake(orte_snapc_full_app_snapshot_t *vpid_snapshot); vpid_snapshot 130 orte/mca/snapc/full/snapc_full_local.c static int snapc_full_local_end_ckpt_handshake(orte_snapc_full_app_snapshot_t *vpid_snapshot); vpid_snapshot 160 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 188 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 201 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 206 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name))); vpid_snapshot 281 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot; vpid_snapshot 295 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 297 orte/mca/snapc/full/snapc_full_local.c if(ORTE_SNAPC_CKPT_STATE_NONE != vpid_snapshot->super.state && vpid_snapshot 298 orte/mca/snapc/full/snapc_full_local.c ORTE_SNAPC_CKPT_STATE_ERROR != vpid_snapshot->super.state && vpid_snapshot 299 orte/mca/snapc/full/snapc_full_local.c ORTE_SNAPC_CKPT_STATE_ESTABLISHED != vpid_snapshot->super.state && vpid_snapshot 300 orte/mca/snapc/full/snapc_full_local.c ORTE_SNAPC_CKPT_STATE_RECOVERED != vpid_snapshot->super.state ) { vpid_snapshot 433 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 501 orte/mca/snapc/full/snapc_full_local.c if( NULL == (vpid_snapshot = find_vpid_snapshot(&proc)) ) { vpid_snapshot 508 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), vpid_snapshot->process_pid, proc_pid)); vpid_snapshot 511 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid = proc_pid; vpid_snapshot 512 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->finished = true; vpid_snapshot 523 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 524 orte/mca/snapc/full/snapc_full_local.c if( !vpid_snapshot->finished ) { vpid_snapshot 555 orte/mca/snapc/full/snapc_full_local.c if( NULL == (vpid_snapshot = find_vpid_snapshot(sender)) ) { vpid_snapshot 564 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), vpid_snapshot 567 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.state = ORTE_SNAPC_CKPT_STATE_RECOVERED; vpid_snapshot 576 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 578 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SNAPC_CKPT_STATE_RECOVERED != vpid_snapshot->super.state ) { vpid_snapshot 623 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 636 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 637 orte/mca/snapc/full/snapc_full_local.c global_coord_restart_proc_info(vpid_snapshot->process_pid, orte_process_info.nodename); vpid_snapshot 677 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 679 orte/mca/snapc/full/snapc_full_local.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(vpid_snapshot->process_pid), 1, OPAL_PID))) { vpid_snapshot 775 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 845 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 848 orte/mca/snapc/full/snapc_full_local.c &(vpid_snapshot->super.process_name), vpid_snapshot 850 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->migrating = true; vpid_snapshot 882 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 928 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 930 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.state = job_ckpt_state; vpid_snapshot 931 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->finished = false; vpid_snapshot 950 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 954 orte/mca/snapc/full/snapc_full_local.c if( vpid_snapshot->migrating ) { vpid_snapshot 957 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name) )); vpid_snapshot 1000 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 1009 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1011 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SUCCESS != (ret = local_coord_job_state_update_finished_local_vpid(vpid_snapshot) ) ) { vpid_snapshot 1017 orte/mca/snapc/full/snapc_full_local.c if( vpid_snapshot->migrating ) { vpid_snapshot 1020 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name) )); vpid_snapshot 1028 orte/mca/snapc/full/snapc_full_local.c static int local_coord_job_state_update_finished_local_vpid(orte_snapc_full_app_snapshot_t *vpid_snapshot) vpid_snapshot 1034 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), vpid_snapshot 1035 orte/mca/snapc/full/snapc_full_local.c (vpid_snapshot->migrating ? "- Migrating, Skip" : "") )); vpid_snapshot 1040 orte/mca/snapc/full/snapc_full_local.c if( vpid_snapshot->migrating ) { vpid_snapshot 1044 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SUCCESS != (ret = snapc_full_local_end_ckpt_handshake(vpid_snapshot) ) ) { vpid_snapshot 1047 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), ret); vpid_snapshot 1063 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot; vpid_snapshot 1078 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1081 orte/mca/snapc/full/snapc_full_local.c if( vpid_snapshot->process_pid == 0 ) { vpid_snapshot 1083 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SUCCESS != ret || vpid_snapshot->process_pid == 0 ) { vpid_snapshot 1086 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid); vpid_snapshot 1103 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1108 orte/mca/snapc/full/snapc_full_local.c local_define_pipe_names(vpid_snapshot); vpid_snapshot 1112 orte/mca/snapc/full/snapc_full_local.c (int) vpid_snapshot->process_pid, vpid_snapshot 1118 orte/mca/snapc/full/snapc_full_local.c if( 0 != (ret = kill(vpid_snapshot->process_pid, opal_cr_entry_point_signal) ) ) { vpid_snapshot 1121 orte/mca/snapc/full/snapc_full_local.c (int) vpid_snapshot->process_pid, vpid_snapshot 1137 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1139 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SUCCESS != (ret = snapc_full_local_start_ckpt_open_comm(vpid_snapshot) ) ) { vpid_snapshot 1142 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), ret); vpid_snapshot 1148 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.state = ORTE_SNAPC_CKPT_STATE_RUNNING; vpid_snapshot 1159 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1161 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SUCCESS != (ret = snapc_full_local_start_ckpt_handshake_opts(vpid_snapshot, options) ) ) { vpid_snapshot 1164 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), ret); vpid_snapshot 1179 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1181 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SUCCESS != (ret = snapc_full_local_start_ckpt_handshake(vpid_snapshot) ) ) { vpid_snapshot 1184 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), ret); vpid_snapshot 1213 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1215 orte/mca/snapc/full/snapc_full_local.c ret = waitpid(vpid_snapshot->process_pid, &waitpid_status, WNOHANG|WUNTRACED); vpid_snapshot 1221 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid, (int)num_stopped )); vpid_snapshot 1226 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid, ret, vpid_snapshot 1227 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name)); vpid_snapshot 1238 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1240 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.state = ORTE_SNAPC_CKPT_STATE_STOPPED; vpid_snapshot 1270 orte/mca/snapc/full/snapc_full_local.c static int local_define_pipe_names(orte_snapc_full_app_snapshot_t *vpid_snapshot) vpid_snapshot 1272 orte/mca/snapc/full/snapc_full_local.c if( NULL != vpid_snapshot->comm_pipe_r ) { vpid_snapshot 1273 orte/mca/snapc/full/snapc_full_local.c free(vpid_snapshot->comm_pipe_r); vpid_snapshot 1274 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r = NULL; vpid_snapshot 1277 orte/mca/snapc/full/snapc_full_local.c if( NULL != vpid_snapshot->comm_pipe_w ) { vpid_snapshot 1278 orte/mca/snapc/full/snapc_full_local.c free(vpid_snapshot->comm_pipe_w); vpid_snapshot 1279 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w = NULL; vpid_snapshot 1282 orte/mca/snapc/full/snapc_full_local.c opal_asprintf(&(vpid_snapshot->comm_pipe_w), vpid_snapshot 1285 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid, vpid_snapshot 1286 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->unique_pipe_id); vpid_snapshot 1288 orte/mca/snapc/full/snapc_full_local.c opal_asprintf(&(vpid_snapshot->comm_pipe_r), vpid_snapshot 1291 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid, vpid_snapshot 1292 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->unique_pipe_id); vpid_snapshot 1294 orte/mca/snapc/full/snapc_full_local.c (vpid_snapshot->unique_pipe_id)++; vpid_snapshot 1354 orte/mca/snapc/full/snapc_full_local.c static int snapc_full_local_start_ckpt_open_comm(orte_snapc_full_app_snapshot_t *vpid_snapshot) vpid_snapshot 1368 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), vpid_snapshot 1369 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w, vpid_snapshot 1370 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r)); vpid_snapshot 1375 orte/mca/snapc/full/snapc_full_local.c if( 0 > (ret = access(vpid_snapshot->comm_pipe_r, F_OK) )) { vpid_snapshot 1380 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r, ret, vpid_snapshot 1386 orte/mca/snapc/full/snapc_full_local.c else if( 0 > (ret = access(vpid_snapshot->comm_pipe_w, F_OK) )) { vpid_snapshot 1391 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w, ret, vpid_snapshot 1407 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid, s_time, max_wait_time)); vpid_snapshot 1421 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid, vpid_snapshot 1422 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r, vpid_snapshot 1423 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w); vpid_snapshot 1438 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w_fd = open(vpid_snapshot->comm_pipe_w, O_WRONLY); vpid_snapshot 1439 orte/mca/snapc/full/snapc_full_local.c if(vpid_snapshot->comm_pipe_w_fd < 0) { vpid_snapshot 1442 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w, vpid_snapshot->comm_pipe_w_fd); vpid_snapshot 1447 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r_fd = open(vpid_snapshot->comm_pipe_r, O_RDONLY); vpid_snapshot 1448 orte/mca/snapc/full/snapc_full_local.c if(vpid_snapshot->comm_pipe_r_fd < 0) { vpid_snapshot 1451 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r, vpid_snapshot->comm_pipe_r_fd); vpid_snapshot 1460 orte/mca/snapc/full/snapc_full_local.c static int snapc_full_local_start_ckpt_handshake_opts(orte_snapc_full_app_snapshot_t *vpid_snapshot, vpid_snapshot 1472 orte/mca/snapc/full/snapc_full_local.c if( vpid_snapshot->migrating ) { vpid_snapshot 1475 orte/mca/snapc/full/snapc_full_local.c (vpid_snapshot->migrating ? "True" : "False"), vpid_snapshot 1491 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &opt_rep, sizeof(int))) ) { vpid_snapshot 1494 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->migrating, vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1499 orte/mca/snapc/full/snapc_full_local.c opt_rep = (int)(vpid_snapshot->migrating); vpid_snapshot 1500 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &opt_rep, sizeof(int))) ) { vpid_snapshot 1503 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->migrating, vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1509 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &opt_rep, sizeof(int))) ) { vpid_snapshot 1512 orte/mca/snapc/full/snapc_full_local.c options->term, vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1518 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &opt_rep, sizeof(int))) ) { vpid_snapshot 1521 orte/mca/snapc/full/snapc_full_local.c options->stop, vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1527 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &opt_rep, sizeof(int))) ) { vpid_snapshot 1530 orte/mca/snapc/full/snapc_full_local.c options->stop, vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1536 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &opt_rep, sizeof(int))) ) { vpid_snapshot 1539 orte/mca/snapc/full/snapc_full_local.c options->stop, vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1546 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &opt_rep, sizeof(int))) ) { vpid_snapshot 1549 orte/mca/snapc/full/snapc_full_local.c options->attach_debugger, vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1555 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &opt_rep, sizeof(int))) ) { vpid_snapshot 1558 orte/mca/snapc/full/snapc_full_local.c options->detach_debugger, vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1567 orte/mca/snapc/full/snapc_full_local.c if( sizeof(orte_sstore_base_handle_t) != (ret = write(vpid_snapshot->comm_pipe_w_fd, vpid_snapshot 1571 orte/mca/snapc/full/snapc_full_local.c (int)(local_global_snapshot.ss_handle), vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1581 orte/mca/snapc/full/snapc_full_local.c static int snapc_full_local_start_ckpt_handshake(orte_snapc_full_app_snapshot_t *vpid_snapshot) vpid_snapshot 1589 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = read(vpid_snapshot->comm_pipe_r_fd, &value, sizeof(int))) ) { vpid_snapshot 1592 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r, ret); vpid_snapshot 1602 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid); vpid_snapshot 1610 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid); vpid_snapshot 1618 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid); vpid_snapshot 1623 orte/mca/snapc/full/snapc_full_local.c opal_event_set(orte_event_base, &(vpid_snapshot->comm_pipe_r_eh), vpid_snapshot 1624 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r_fd, vpid_snapshot 1627 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot); vpid_snapshot 1628 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->is_eh_active = true; vpid_snapshot 1629 orte/mca/snapc/full/snapc_full_local.c opal_event_add(&(vpid_snapshot->comm_pipe_r_eh), NULL); vpid_snapshot 1634 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &value, sizeof(int))) ) { vpid_snapshot 1637 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w, ret); vpid_snapshot 1647 orte/mca/snapc/full/snapc_full_local.c static int snapc_full_local_end_ckpt_handshake(orte_snapc_full_app_snapshot_t *vpid_snapshot) vpid_snapshot 1655 orte/mca/snapc/full/snapc_full_local.c if( 0 > vpid_snapshot->comm_pipe_w_fd ) { vpid_snapshot 1658 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), vpid_snapshot 1659 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w_fd)); vpid_snapshot 1666 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = write(vpid_snapshot->comm_pipe_w_fd, &last_cmd, sizeof(int))) ) { vpid_snapshot 1669 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), ret); vpid_snapshot 1678 orte/mca/snapc/full/snapc_full_local.c close(vpid_snapshot->comm_pipe_w_fd); vpid_snapshot 1679 orte/mca/snapc/full/snapc_full_local.c close(vpid_snapshot->comm_pipe_r_fd); vpid_snapshot 1680 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_w_fd = -1; vpid_snapshot 1681 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r_fd = -1; vpid_snapshot 1689 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 1694 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t *)arg; vpid_snapshot 1698 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name))); vpid_snapshot 1703 orte/mca/snapc/full/snapc_full_local.c if( !vpid_snapshot->migrating ) { vpid_snapshot 1704 orte/mca/snapc/full/snapc_full_local.c if( sizeof(int) != (ret = read(vpid_snapshot->comm_pipe_r_fd, &ckpt_state, sizeof(int))) ) { vpid_snapshot 1707 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->comm_pipe_r, ret); vpid_snapshot 1720 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.state = ORTE_SNAPC_CKPT_STATE_INC_PREPED; vpid_snapshot 1740 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.state = ORTE_SNAPC_CKPT_STATE_ERROR; vpid_snapshot 1742 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.state = ORTE_SNAPC_CKPT_STATE_FINISHED_LOCAL; vpid_snapshot 1769 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SNAPC_CKPT_STATE_ERROR == vpid_snapshot->super.state ) { vpid_snapshot 1834 orte/mca/snapc/full/snapc_full_local.c opal_event_del(&(vpid_snapshot->comm_pipe_r_eh)); vpid_snapshot 1835 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->is_eh_active = false; vpid_snapshot 1848 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 1856 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 1865 orte/mca/snapc/full/snapc_full_local.c orte_snapc_ckpt_state_str(&state_str_a, vpid_snapshot->super.state); vpid_snapshot 1870 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), vpid_snapshot 1871 orte/mca/snapc/full/snapc_full_local.c (int)vpid_snapshot->super.state, state_str_a, vpid_snapshot 1873 orte/mca/snapc/full/snapc_full_local.c if( min_state > vpid_snapshot->super.state ) { vpid_snapshot 1874 orte/mca/snapc/full/snapc_full_local.c min_state = vpid_snapshot->super.state; vpid_snapshot 1901 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 1912 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)opal_list_get_first(&(local_global_snapshot.local_snapshots)); vpid_snapshot 1913 orte/mca/snapc/full/snapc_full_local.c if( 0 < vpid_snapshot->process_pid ) { vpid_snapshot 1928 orte/mca/snapc/full/snapc_full_local.c NULL == (vpid_snapshot = find_vpid_snapshot(&child->name)) ) { vpid_snapshot 1929 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = OBJ_NEW(orte_snapc_full_app_snapshot_t); vpid_snapshot 1930 orte/mca/snapc/full/snapc_full_local.c opal_list_append(&(local_global_snapshot.local_snapshots), &(vpid_snapshot->super.super)); vpid_snapshot 1934 orte/mca/snapc/full/snapc_full_local.c if( 0 >= vpid_snapshot->process_pid ) { vpid_snapshot 1935 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid = child->pid; vpid_snapshot 1936 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.process_name.jobid = child->name.jobid; vpid_snapshot 1937 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.process_name.vpid = child->name.vpid; vpid_snapshot 1947 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 1959 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)v_item; vpid_snapshot 1969 orte/mca/snapc/full/snapc_full_local.c &(vpid_snapshot->super.process_name) )) { vpid_snapshot 1977 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), vpid_snapshot 1978 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid, vpid_snapshot 1994 orte/mca/snapc/full/snapc_full_local.c if( NULL == (vpid_snapshot = find_vpid_snapshot(&child->name)) ) { vpid_snapshot 1995 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = OBJ_NEW(orte_snapc_full_app_snapshot_t); vpid_snapshot 1997 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid = child->pid; vpid_snapshot 1998 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.process_name.jobid = child->name.jobid; vpid_snapshot 1999 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.process_name.vpid = child->name.vpid; vpid_snapshot 2002 orte/mca/snapc/full/snapc_full_local.c opal_list_append(&(local_global_snapshot.local_snapshots), &(vpid_snapshot->super.super)); vpid_snapshot 2006 orte/mca/snapc/full/snapc_full_local.c ORTE_NAME_PRINT(&vpid_snapshot->super.process_name), vpid_snapshot 2007 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid, vpid_snapshot 2011 orte/mca/snapc/full/snapc_full_local.c else if( 0 >= vpid_snapshot->process_pid ) { vpid_snapshot 2012 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->process_pid = child->pid; vpid_snapshot 2013 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.process_name.jobid = child->name.jobid; vpid_snapshot 2014 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.process_name.vpid = child->name.vpid; vpid_snapshot 2024 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 2030 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 2035 orte/mca/snapc/full/snapc_full_local.c orte_util_compare_name_fields(mask, name, &vpid_snapshot->super.process_name)) { vpid_snapshot 2036 orte/mca/snapc/full/snapc_full_local.c return vpid_snapshot; vpid_snapshot 2046 orte/mca/snapc/full/snapc_full_local.c orte_snapc_full_app_snapshot_t *vpid_snapshot = NULL; vpid_snapshot 2055 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot = (orte_snapc_full_app_snapshot_t*)item; vpid_snapshot 2061 orte/mca/snapc/full/snapc_full_local.c if( vpid_snapshot->comm_pipe_w_fd > 0 ) { vpid_snapshot 2062 orte/mca/snapc/full/snapc_full_local.c if( ORTE_SUCCESS != (ret = local_coord_job_state_update_finished_local_vpid(vpid_snapshot) ) ) { vpid_snapshot 2068 orte/mca/snapc/full/snapc_full_local.c vpid_snapshot->super.state = ORTE_SNAPC_CKPT_STATE_NONE; vpid_snapshot 584 orte/mca/sstore/base/sstore_base_fns.c orte_sstore_base_local_snapshot_info_t *vpid_snapshot = NULL; vpid_snapshot 641 orte/mca/sstore/base/sstore_base_fns.c if( NULL != vpid_snapshot) { vpid_snapshot 642 orte/mca/sstore/base/sstore_base_fns.c opal_list_append(&global_snapshot->local_snapshots, &(vpid_snapshot->super)); vpid_snapshot 645 orte/mca/sstore/base/sstore_base_fns.c vpid_snapshot = OBJ_NEW(orte_sstore_base_local_snapshot_info_t); vpid_snapshot 646 orte/mca/sstore/base/sstore_base_fns.c vpid_snapshot->ss_handle = global_snapshot->ss_handle; vpid_snapshot 648 orte/mca/sstore/base/sstore_base_fns.c vpid_snapshot->process_name.jobid = proc.jobid; vpid_snapshot 649 orte/mca/sstore/base/sstore_base_fns.c vpid_snapshot->process_name.vpid = proc.vpid; vpid_snapshot 652 orte/mca/sstore/base/sstore_base_fns.c vpid_snapshot->crs_comp = strdup(value); vpid_snapshot 655 orte/mca/sstore/base/sstore_base_fns.c vpid_snapshot->compress_comp = strdup(value); vpid_snapshot 658 orte/mca/sstore/base/sstore_base_fns.c vpid_snapshot->compress_postfix = strdup(value); vpid_snapshot 677 orte/mca/sstore/base/sstore_base_fns.c if( NULL != vpid_snapshot) { vpid_snapshot 678 orte/mca/sstore/base/sstore_base_fns.c opal_list_append(&global_snapshot->local_snapshots, &(vpid_snapshot->super)); vpid_snapshot 1159 orte/mca/sstore/central/sstore_central_global.c orte_sstore_base_local_snapshot_info_t *vpid_snapshot = NULL; vpid_snapshot 1184 orte/mca/sstore/central/sstore_central_global.c vpid_snapshot = OBJ_NEW(orte_sstore_base_local_snapshot_info_t); vpid_snapshot 1185 orte/mca/sstore/central/sstore_central_global.c vpid_snapshot->ss_handle = handle_info->id; vpid_snapshot 1187 orte/mca/sstore/central/sstore_central_global.c vpid_snapshot->process_name.jobid = handle_info->jobid; vpid_snapshot 1188 orte/mca/sstore/central/sstore_central_global.c vpid_snapshot->process_name.vpid = i; vpid_snapshot 1190 orte/mca/sstore/central/sstore_central_global.c vpid_snapshot->crs_comp = NULL; vpid_snapshot 1194 orte/mca/sstore/central/sstore_central_global.c opal_list_append(&global_snapshot->local_snapshots, &(vpid_snapshot->super)); vpid_snapshot 1666 orte/mca/sstore/stage/sstore_stage_global.c orte_sstore_base_local_snapshot_info_t *vpid_snapshot = NULL; vpid_snapshot 1691 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot = OBJ_NEW(orte_sstore_base_local_snapshot_info_t); vpid_snapshot 1692 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->ss_handle = handle_info->id; vpid_snapshot 1694 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->process_name.jobid = handle_info->jobid; vpid_snapshot 1695 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->process_name.vpid = i; vpid_snapshot 1701 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->crs_comp = NULL; vpid_snapshot 1703 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->compress_comp = strdup(handle_info->compress_comp); vpid_snapshot 1705 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->compress_comp = NULL; vpid_snapshot 1708 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->compress_postfix = strdup(handle_info->compress_postfix); vpid_snapshot 1710 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->compress_postfix = NULL; vpid_snapshot 1712 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->start_time = NULL; vpid_snapshot 1713 orte/mca/sstore/stage/sstore_stage_global.c vpid_snapshot->end_time = NULL; vpid_snapshot 1715 orte/mca/sstore/stage/sstore_stage_global.c opal_list_append(&global_snapshot->local_snapshots, &(vpid_snapshot->super));