datum 30 ompi/mpiext/cr/c/checkpoint.c orte_snapc_base_request_op_t *datum = NULL; datum 42 ompi/mpiext/cr/c/checkpoint.c datum = OBJ_NEW(orte_snapc_base_request_op_t); datum 43 ompi/mpiext/cr/c/checkpoint.c datum->event = ORTE_SNAPC_OP_CHECKPOINT; datum 44 ompi/mpiext/cr/c/checkpoint.c datum->is_active = true; datum 48 ompi/mpiext/cr/c/checkpoint.c datum->leader = OMPI_PROC_MY_NAME->vpid; datum 50 ompi/mpiext/cr/c/checkpoint.c datum->leader = -1; /* Unknown from non-root ranks */ datum 62 ompi/mpiext/cr/c/checkpoint.c ret = orte_snapc.request_op(datum); datum 64 ompi/mpiext/cr/c/checkpoint.c OBJ_RELEASE(datum); datum 73 ompi/mpiext/cr/c/checkpoint.c if( datum->leader == (int)OMPI_PROC_MY_NAME->vpid ) { datum 74 ompi/mpiext/cr/c/checkpoint.c *handle = strdup(datum->global_handle); datum 75 ompi/mpiext/cr/c/checkpoint.c *seq = datum->seq_num; datum 85 ompi/mpiext/cr/c/checkpoint.c datum->is_active = false; datum 86 ompi/mpiext/cr/c/checkpoint.c OBJ_RELEASE(datum); datum 30 ompi/mpiext/cr/c/migrate.c orte_snapc_base_request_op_t *datum = NULL; datum 46 ompi/mpiext/cr/c/migrate.c datum = OBJ_NEW(orte_snapc_base_request_op_t); datum 47 ompi/mpiext/cr/c/migrate.c datum->event = ORTE_SNAPC_OP_MIGRATE; datum 48 ompi/mpiext/cr/c/migrate.c datum->is_active = true; datum 53 ompi/mpiext/cr/c/migrate.c datum->leader = OMPI_PROC_MY_NAME->vpid; datum 55 ompi/mpiext/cr/c/migrate.c datum->leader = -1; /* Unknown from non-root ranks */ datum 69 ompi/mpiext/cr/c/migrate.c datum->mig_num = my_size; datum 70 ompi/mpiext/cr/c/migrate.c datum->mig_vpids = (int *) malloc(sizeof(int) * my_size); datum 71 ompi/mpiext/cr/c/migrate.c datum->mig_host_pref = (char (*)[OPAL_MAX_PROCESSOR_NAME]) malloc(sizeof(char) * my_size * MPI_MAX_PROCESSOR_NAME); datum 72 ompi/mpiext/cr/c/migrate.c datum->mig_vpid_pref = (int *) malloc(sizeof(int) * my_size); datum 73 ompi/mpiext/cr/c/migrate.c datum->mig_off_node = (int *) malloc(sizeof(int) * my_size); datum 76 ompi/mpiext/cr/c/migrate.c (datum->mig_vpids)[i] = 0; datum 77 ompi/mpiext/cr/c/migrate.c (datum->mig_host_pref)[i][0] = '\0'; datum 78 ompi/mpiext/cr/c/migrate.c (datum->mig_vpid_pref)[i] = 0; datum 79 ompi/mpiext/cr/c/migrate.c (datum->mig_off_node)[i] = (int)false; datum 94 ompi/mpiext/cr/c/migrate.c (datum->mig_vpids), 1, MPI_INT, 0, comm); datum 96 ompi/mpiext/cr/c/migrate.c (datum->mig_host_pref), MPI_MAX_PROCESSOR_NAME, MPI_CHAR, 0, comm); datum 98 ompi/mpiext/cr/c/migrate.c (datum->mig_vpid_pref), 1, MPI_INT, 0, comm); datum 100 ompi/mpiext/cr/c/migrate.c (datum->mig_off_node), 1, MPI_INT, 0, comm); datum 106 ompi/mpiext/cr/c/migrate.c ret = orte_snapc.request_op(datum); datum 113 ompi/mpiext/cr/c/migrate.c datum->is_active = false; datum 114 ompi/mpiext/cr/c/migrate.c OBJ_RELEASE(datum); datum 29 ompi/mpiext/cr/c/quiesce_checkpoint.c orte_snapc_base_request_op_t *datum = NULL; datum 40 ompi/mpiext/cr/c/quiesce_checkpoint.c datum = OBJ_NEW(orte_snapc_base_request_op_t); datum 41 ompi/mpiext/cr/c/quiesce_checkpoint.c datum->event = ORTE_SNAPC_OP_QUIESCE_CHECKPOINT; datum 42 ompi/mpiext/cr/c/quiesce_checkpoint.c datum->is_active = true; datum 46 ompi/mpiext/cr/c/quiesce_checkpoint.c datum->leader = OMPI_PROC_MY_NAME->vpid; datum 48 ompi/mpiext/cr/c/quiesce_checkpoint.c datum->leader = -1; /* Unknown from non-root ranks */ datum 55 ompi/mpiext/cr/c/quiesce_checkpoint.c ret = orte_snapc.request_op(datum); datum 63 ompi/mpiext/cr/c/quiesce_checkpoint.c *handle = strdup(datum->global_handle); datum 64 ompi/mpiext/cr/c/quiesce_checkpoint.c *seq = datum->seq_num; datum 66 ompi/mpiext/cr/c/quiesce_checkpoint.c datum->is_active = false; datum 67 ompi/mpiext/cr/c/quiesce_checkpoint.c OBJ_RELEASE(datum); datum 29 ompi/mpiext/cr/c/quiesce_end.c orte_snapc_base_request_op_t *datum = NULL; datum 40 ompi/mpiext/cr/c/quiesce_end.c datum = OBJ_NEW(orte_snapc_base_request_op_t); datum 41 ompi/mpiext/cr/c/quiesce_end.c datum->event = ORTE_SNAPC_OP_QUIESCE_END; datum 42 ompi/mpiext/cr/c/quiesce_end.c datum->is_active = true; datum 46 ompi/mpiext/cr/c/quiesce_end.c datum->leader = OMPI_PROC_MY_NAME->vpid; datum 48 ompi/mpiext/cr/c/quiesce_end.c datum->leader = -1; /* Unknown from non-root ranks */ datum 55 ompi/mpiext/cr/c/quiesce_end.c ret = orte_snapc.request_op(datum); datum 33 ompi/mpiext/cr/c/quiesce_start.c orte_snapc_base_request_op_t *datum = NULL; datum 44 ompi/mpiext/cr/c/quiesce_start.c datum = OBJ_NEW(orte_snapc_base_request_op_t); datum 45 ompi/mpiext/cr/c/quiesce_start.c datum->event = ORTE_SNAPC_OP_QUIESCE_START; datum 46 ompi/mpiext/cr/c/quiesce_start.c datum->is_active = true; datum 50 ompi/mpiext/cr/c/quiesce_start.c datum->leader = OMPI_PROC_MY_NAME->vpid; datum 52 ompi/mpiext/cr/c/quiesce_start.c datum->leader = -1; /* Unknown from non-root ranks */ datum 64 ompi/mpiext/cr/c/quiesce_start.c ret = orte_snapc.request_op(datum); datum 67 ompi/mpiext/cr/c/quiesce_start.c OBJ_RELEASE(datum); datum 74 ompi/mpiext/cr/c/quiesce_start.c datum->is_active = false; datum 75 ompi/mpiext/cr/c/quiesce_start.c OBJ_RELEASE(datum); datum 127 ompi/mpiext/cr/c/quiesce_start.c static int extract_info_into_datum(opal_info_t *info, orte_snapc_base_quiesce_t *datum) datum 141 ompi/mpiext/cr/c/quiesce_start.c datum->crs_name = strdup(info_char); datum 149 ompi/mpiext/cr/c/quiesce_start.c datum->cmdline = strdup(info_char); datum 157 ompi/mpiext/cr/c/quiesce_start.c datum->handle = strdup(info_char); datum 165 ompi/mpiext/cr/c/quiesce_start.c datum->target_dir = strdup(info_char); datum 173 ompi/mpiext/cr/c/quiesce_start.c datum->restarting = info_bool; datum 175 ompi/mpiext/cr/c/quiesce_start.c datum->restarting = false; datum 183 ompi/mpiext/cr/c/quiesce_start.c datum->checkpointing = info_bool; datum 185 ompi/mpiext/cr/c/quiesce_start.c datum->checkpointing = false; datum 194 ompi/mpiext/cr/c/quiesce_start.c (NULL == datum->crs_name ? "Default (none)" : datum->crs_name))); datum 198 ompi/mpiext/cr/c/quiesce_start.c (NULL == datum->cmdline ? "Default ()" : datum->cmdline))); datum 202 ompi/mpiext/cr/c/quiesce_start.c (datum->checkpointing ? 'T' : 'F'))); datum 206 ompi/mpiext/cr/c/quiesce_start.c (datum->restarting ? 'T' : 'F'))); datum 29 ompi/mpiext/cr/c/restart.c orte_snapc_base_request_op_t *datum = NULL; datum 39 ompi/mpiext/cr/c/restart.c datum = OBJ_NEW(orte_snapc_base_request_op_t); datum 40 ompi/mpiext/cr/c/restart.c datum->event = ORTE_SNAPC_OP_RESTART; datum 41 ompi/mpiext/cr/c/restart.c datum->is_active = true; datum 46 ompi/mpiext/cr/c/restart.c datum->leader = OMPI_PROC_MY_NAME->vpid; datum 47 ompi/mpiext/cr/c/restart.c datum->seq_num = seq; datum 48 ompi/mpiext/cr/c/restart.c datum->global_handle = strdup(handle); datum 54 ompi/mpiext/cr/c/restart.c ret = orte_snapc.request_op(datum); datum 61 ompi/mpiext/cr/c/restart.c datum->is_active = false; datum 62 ompi/mpiext/cr/c/restart.c OBJ_RELEASE(datum); datum 89 orte/mca/errmgr/base/base.h ORTE_DECLSPEC int orte_errmgr_base_migrate_job(orte_jobid_t jobid, orte_snapc_base_request_op_t *datum); datum 392 orte/mca/errmgr/base/errmgr_base_fns.c int orte_errmgr_base_migrate_job(orte_jobid_t jobid, orte_snapc_base_request_op_t *datum) datum 409 orte/mca/errmgr/base/errmgr_base_fns.c for( i = 0; i < datum->mig_num; ++i ) { datum 416 orte/mca/errmgr/base/errmgr_base_fns.c if( (datum->mig_off_node)[i] ) { datum 424 orte/mca/errmgr/base/errmgr_base_fns.c onto_map->proc_name.vpid = (datum->mig_vpids)[i]; datum 428 orte/mca/errmgr/base/errmgr_base_fns.c onto_map->map_proc_name.vpid = (datum->mig_vpid_pref)[i]; datum 430 orte/mca/errmgr/base/errmgr_base_fns.c if( ((datum->mig_host_pref)[i])[0] == '\0') { datum 433 orte/mca/errmgr/base/errmgr_base_fns.c onto_map->map_node_name = strdup((datum->mig_host_pref)[i]); datum 103 orte/mca/snapc/base/base.h ORTE_DECLSPEC int orte_snapc_base_none_start_ckpt(orte_snapc_base_quiesce_t *datum); datum 104 orte/mca/snapc/base/base.h ORTE_DECLSPEC int orte_snapc_base_none_end_ckpt(orte_snapc_base_quiesce_t *datum); datum 332 orte/mca/snapc/base/snapc_base_fns.c int orte_snapc_base_none_start_ckpt(orte_snapc_base_quiesce_t *datum) datum 337 orte/mca/snapc/base/snapc_base_fns.c int orte_snapc_base_none_end_ckpt(orte_snapc_base_quiesce_t *datum) datum 126 orte/mca/snapc/full/snapc_full.h int orte_snapc_full_start_ckpt(orte_snapc_base_quiesce_t *datum); datum 127 orte/mca/snapc/full/snapc_full.h int orte_snapc_full_end_ckpt(orte_snapc_base_quiesce_t *datum); datum 128 orte/mca/snapc/full/snapc_full.h int orte_snapc_full_request_op(orte_snapc_base_request_op_t *datum); datum 142 orte/mca/snapc/full/snapc_full.h int global_coord_start_ckpt(orte_snapc_base_quiesce_t *datum); datum 143 orte/mca/snapc/full/snapc_full.h int global_coord_end_ckpt(orte_snapc_base_quiesce_t *datum); datum 165 orte/mca/snapc/full/snapc_full.h int app_coord_request_op(orte_snapc_base_request_op_t *datum); datum 1259 orte/mca/snapc/full/snapc_full_app.c int app_coord_request_op(orte_snapc_base_request_op_t *datum) datum 1274 orte/mca/snapc/full/snapc_full_app.c if( ORTE_SNAPC_OP_QUIESCE_END == datum->event) { datum 1308 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_QUIESCE_CHECKPOINT == datum->event) { datum 1324 orte/mca/snapc/full/snapc_full_app.c datum->seq_num = atoi(seq_str); datum 1326 orte/mca/snapc/full/snapc_full_app.c datum->seq_num = -1; datum 1331 orte/mca/snapc/full/snapc_full_app.c &(datum->global_handle)); datum 1332 orte/mca/snapc/full/snapc_full_app.c if( NULL == datum->global_handle ) { datum 1333 orte/mca/snapc/full/snapc_full_app.c datum->global_handle = strdup("Unknown"); datum 1342 orte/mca/snapc/full/snapc_full_app.c if( datum->leader == (int)ORTE_PROC_MY_NAME->vpid ) { datum 1345 orte/mca/snapc/full/snapc_full_app.c datum->event)); datum 1362 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(datum->event), 1, OPAL_INT))) { datum 1368 orte/mca/snapc/full/snapc_full_app.c if( ORTE_SNAPC_OP_RESTART == datum->event) { datum 1369 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(datum->seq_num), 1, OPAL_INT))) { datum 1374 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(datum->global_handle), 1, OPAL_STRING))) { datum 1380 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_MIGRATE == datum->event) { datum 1406 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &(datum->mig_num), 1, OPAL_INT))) { datum 1412 orte/mca/snapc/full/snapc_full_app.c for( i = 0; i < datum->mig_num; ++i ) { datum 1415 orte/mca/snapc/full/snapc_full_app.c datum->mig_num, i, datum 1416 orte/mca/snapc/full/snapc_full_app.c (datum->mig_vpids)[i], datum 1417 orte/mca/snapc/full/snapc_full_app.c (datum->mig_host_pref)[i], datum 1418 orte/mca/snapc/full/snapc_full_app.c (datum->mig_vpid_pref)[i], datum 1419 orte/mca/snapc/full/snapc_full_app.c (OPAL_INT_TO_BOOL((datum->mig_off_node)[i]) ? 'T' : 'F') datum 1422 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &((datum->mig_vpids)[i]), 1, OPAL_INT))) { datum 1427 orte/mca/snapc/full/snapc_full_app.c tmp_str = strdup((datum->mig_host_pref)[i]); datum 1438 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &((datum->mig_vpid_pref)[i]), 1, OPAL_INT))) { datum 1443 orte/mca/snapc/full/snapc_full_app.c if (ORTE_SUCCESS != (ret = opal_dss.pack(buffer, &((datum->mig_off_node)[i]), 1, OPAL_INT))) { datum 1464 orte/mca/snapc/full/snapc_full_app.c if( ORTE_SNAPC_OP_CHECKPOINT == datum->event) { datum 1465 orte/mca/snapc/full/snapc_full_app.c if( datum->leader == (int)ORTE_PROC_MY_NAME->vpid ) { datum 1482 orte/mca/snapc/full/snapc_full_app.c datum->seq_num = atoi(seq_str); datum 1484 orte/mca/snapc/full/snapc_full_app.c datum->seq_num = -1; datum 1489 orte/mca/snapc/full/snapc_full_app.c &(datum->global_handle)); datum 1490 orte/mca/snapc/full/snapc_full_app.c if( NULL == datum->global_handle ) { datum 1491 orte/mca/snapc/full/snapc_full_app.c datum->global_handle = strdup("Unknown"); datum 1532 orte/mca/snapc/full/snapc_full_app.c datum->seq_num = atoi(seq_str); datum 1536 orte/mca/snapc/full/snapc_full_app.c &(datum->global_handle)); datum 1542 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_RESTART == datum->event) { datum 1552 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_MIGRATE == datum->event) { datum 1553 orte/mca/snapc/full/snapc_full_app.c if( datum->leader == (int)ORTE_PROC_MY_NAME->vpid ) { datum 1562 orte/mca/snapc/full/snapc_full_app.c datum->event)); datum 1596 orte/mca/snapc/full/snapc_full_app.c datum->event)); datum 1602 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_QUIESCE_START == datum->event) { datum 1617 orte/mca/snapc/full/snapc_full_app.c else if( ORTE_SNAPC_OP_QUIESCE_END == datum->event) { datum 388 orte/mca/snapc/full/snapc_full_global.c int global_coord_start_ckpt(orte_snapc_base_quiesce_t *datum) datum 406 orte/mca/snapc/full/snapc_full_global.c if( datum->migrating ) { datum 420 orte/mca/snapc/full/snapc_full_global.c for(i_proc = 0; i_proc < opal_pointer_array_get_size(&(datum->migrating_procs)); ++i_proc) { datum 421 orte/mca/snapc/full/snapc_full_global.c proc = (orte_proc_t*)opal_pointer_array_get_item(&(datum->migrating_procs), i_proc); datum 473 orte/mca/snapc/full/snapc_full_global.c datum->snapshot = OBJ_NEW(orte_snapc_base_global_snapshot_t); datum 475 orte/mca/snapc/full/snapc_full_global.c datum->ss_handle = global_snapshot.ss_handle; datum 476 orte/mca/snapc/full/snapc_full_global.c datum->ss_snapshot = OBJ_NEW(orte_sstore_base_global_snapshot_info_t); datum 477 orte/mca/snapc/full/snapc_full_global.c if( ORTE_SUCCESS != (ret = orte_sstore.request_global_snapshot_data(&(datum->ss_handle), datum->ss_snapshot)) ) { datum 487 orte/mca/snapc/full/snapc_full_global.c datum->epoch = atoi(tmp_str); datum 503 orte/mca/snapc/full/snapc_full_global.c int global_coord_end_ckpt(orte_snapc_base_quiesce_t *datum) datum 1176 orte/mca/snapc/full/snapc_full_global.c orte_snapc_base_request_op_t *datum = NULL; datum 1347 orte/mca/snapc/full/snapc_full_global.c datum = OBJ_NEW(orte_snapc_base_request_op_t); datum 1353 orte/mca/snapc/full/snapc_full_global.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(sbuffer, &(datum->mig_num), &count, OPAL_INT))) { datum 1358 orte/mca/snapc/full/snapc_full_global.c datum->mig_vpids = malloc(sizeof(int) * datum->mig_num); datum 1359 orte/mca/snapc/full/snapc_full_global.c datum->mig_host_pref = malloc(sizeof(char) * datum->mig_num * OPAL_MAX_PROCESSOR_NAME); datum 1360 orte/mca/snapc/full/snapc_full_global.c datum->mig_vpid_pref = malloc(sizeof(int) * datum->mig_num); datum 1361 orte/mca/snapc/full/snapc_full_global.c datum->mig_off_node = malloc(sizeof(int) * datum->mig_num); datum 1363 orte/mca/snapc/full/snapc_full_global.c for( i = 0; i < datum->mig_num; ++i ) { datum 1364 orte/mca/snapc/full/snapc_full_global.c (datum->mig_vpids)[i] = 0; datum 1365 orte/mca/snapc/full/snapc_full_global.c (datum->mig_host_pref)[i][0] = '\0'; datum 1366 orte/mca/snapc/full/snapc_full_global.c (datum->mig_vpid_pref)[i] = 0; datum 1367 orte/mca/snapc/full/snapc_full_global.c (datum->mig_off_node)[i] = (int)false; datum 1370 orte/mca/snapc/full/snapc_full_global.c for( i = 0; i < datum->mig_num; ++i ) { datum 1372 orte/mca/snapc/full/snapc_full_global.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(sbuffer, &((datum->mig_vpids)[i]), &count, OPAL_INT))) { datum 1386 orte/mca/snapc/full/snapc_full_global.c opal_string_copy( ((datum->mig_host_pref)[i]), tmp_str, OPAL_MAX_PROCESSOR_NAME); datum 1389 orte/mca/snapc/full/snapc_full_global.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(sbuffer, &((datum->mig_vpid_pref)[i]), &count, OPAL_INT))) { datum 1395 orte/mca/snapc/full/snapc_full_global.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(sbuffer, &((datum->mig_off_node)[i]), &count, OPAL_INT))) { datum 1402 orte/mca/snapc/full/snapc_full_global.c datum->mig_num, i, datum 1403 orte/mca/snapc/full/snapc_full_global.c (datum->mig_vpids)[i], datum 1404 orte/mca/snapc/full/snapc_full_global.c (datum->mig_host_pref)[i], datum 1405 orte/mca/snapc/full/snapc_full_global.c (datum->mig_vpid_pref)[i], datum 1406 orte/mca/snapc/full/snapc_full_global.c (OPAL_INT_TO_BOOL((datum->mig_off_node)[i]) ? 'T' : 'F') datum 1415 orte/mca/snapc/full/snapc_full_global.c if( ORTE_SUCCESS != (ret = orte_errmgr_base_migrate_job(current_global_jobid, datum) ) ) { datum 305 orte/mca/snapc/full/snapc_full_module.c int orte_snapc_full_start_ckpt(orte_snapc_base_quiesce_t *datum) datum 310 orte/mca/snapc/full/snapc_full_module.c return global_coord_start_ckpt(datum); datum 325 orte/mca/snapc/full/snapc_full_module.c int orte_snapc_full_end_ckpt(orte_snapc_base_quiesce_t *datum) datum 330 orte/mca/snapc/full/snapc_full_module.c return global_coord_end_ckpt(datum); datum 345 orte/mca/snapc/full/snapc_full_module.c int orte_snapc_full_request_op(orte_snapc_base_request_op_t *datum) datum 356 orte/mca/snapc/full/snapc_full_module.c return app_coord_request_op(datum); datum 334 orte/mca/snapc/snapc.h (orte_snapc_base_quiesce_t *datum); datum 343 orte/mca/snapc/snapc.h (orte_snapc_base_quiesce_t *datum); datum 349 orte/mca/snapc/snapc.h (orte_snapc_base_request_op_t *datum);