jdata 350 orte/mca/errmgr/base/errmgr_base_fns.c orte_job_t *jdata; jdata 369 orte/mca/errmgr/base/errmgr_base_fns.c if (NULL == (jdata = orte_get_job_data_object(jobid))) { jdata 382 orte/mca/errmgr/base/errmgr_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FT_RESTART); jdata 86 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c static void default_hnp_abort(orte_job_t *jdata); jdata 192 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_job_t *jdata; jdata 215 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (NULL == caddy->jdata) { jdata 222 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata = caddy->jdata; jdata 224 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = jobstate; jdata 229 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_JOBID_PRINT(jdata->jobid), jdata 236 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (1 == ORTE_LOCAL_JOBID(jdata->jobid)) { jdata 246 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->num_terminated = jdata->num_procs; jdata 248 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_TERMINATED); jdata 250 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (ORTE_JOBID_INVALID != jdata->originator.jobid) { jdata 259 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (ORTE_SUCCESS != (ret = opal_dss.pack(answer, &jdata->jobid, 1, ORTE_JOBID))) { jdata 267 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_ROOM_NUM, (void**)&rmptr, OPAL_INT)) { jdata 278 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_JOBID_PRINT(jdata->jobid), jdata 279 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_NAME_PRINT(&jdata->originator))); jdata 280 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (0 > (ret = orte_rml.send_buffer_nb(&jdata->originator, answer, jdata 299 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, (void**)&aborted_proc, OPAL_PTR)) { jdata 301 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (ORTE_PROC_MY_NAME->jobid == jdata->jobid) { jdata 328 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (jdata->jobid == ORTE_PROC_MY_NAME->jobid) { jdata 339 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->jobid == ORTE_PROC_MY_NAME->jobid && jdata 340 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->num_procs != jdata->num_reported) { jdata 345 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_FORCED_EXIT); jdata 354 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_job_t *jdata; jdata 377 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (NULL == (jdata = orte_get_job_data_object(proc->jobid))) { jdata 381 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); jdata 443 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 445 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_COMM_FAILED; jdata 447 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, ORTE_ATTR_LOCAL, pptr, OPAL_PTR); jdata 450 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_ABORTED); jdata 468 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 504 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_CONTINUOUS_OP, NULL, OPAL_BOOL) || jdata 505 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RECOVERABLE)) { jdata 530 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (jdata->num_terminated >= jdata->num_procs) { jdata 532 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_TERMINATED); jdata 542 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 543 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_ABORTED; jdata 545 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, ORTE_ATTR_LOCAL, pptr, OPAL_PTR); jdata 548 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_ABORTED); jdata 552 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 566 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_get_attribute(&jdata->attributes, ORTE_JOB_NUM_NONZERO_EXIT, (void**)&i32ptr, OPAL_INT32); jdata 568 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_NUM_NONZERO_EXIT, ORTE_ATTR_LOCAL, i32ptr, OPAL_INT32); jdata 571 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 572 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_ABORTED_BY_SIG; jdata 574 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, ORTE_ATTR_LOCAL, pptr, OPAL_PTR); jdata 577 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_ABORTED); jdata 581 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 585 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (jdata->num_terminated >= jdata->num_procs) { jdata 587 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_TERMINATED); jdata 597 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 598 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_ABORTED_WO_SYNC; jdata 600 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, ORTE_ATTR_LOCAL, pptr, OPAL_PTR); jdata 603 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_ABORTED); jdata 613 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 624 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 626 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_FAILED_TO_START; jdata 628 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_FAILED_TO_LAUNCH; jdata 631 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, ORTE_ATTR_LOCAL, pptr, OPAL_PTR); jdata 634 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_ABORTED); jdata 638 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 641 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (jdata->jobid == ORTE_PROC_MY_NAME->jobid) { jdata 652 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 653 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_CALLED_ABORT; jdata 655 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, ORTE_ATTR_LOCAL, pptr, OPAL_PTR); jdata 658 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_ABORTED); jdata 662 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 676 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_get_attribute(&jdata->attributes, ORTE_JOB_NUM_NONZERO_EXIT, (void**)&i32ptr, OPAL_INT32); jdata 678 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_NUM_NONZERO_EXIT, ORTE_ATTR_LOCAL, i32ptr, OPAL_INT32); jdata 680 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 681 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_NON_ZERO_TERM; jdata 683 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, ORTE_ATTR_LOCAL, pptr, OPAL_PTR); jdata 686 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_ABORTED); jdata 689 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 693 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (jdata->num_terminated >= jdata->num_procs) { jdata 695 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_TERMINATED); jdata 705 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 706 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata->state = ORTE_JOB_STATE_HEARTBEAT_FAILED; jdata 708 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ABORTED_PROC, ORTE_ATTR_LOCAL, pptr, OPAL_PTR); jdata 711 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_ABORTED); jdata 715 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 733 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 736 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 754 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 757 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 775 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) { jdata 778 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c default_hnp_abort(jdata); jdata 789 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (jdata->num_terminated == jdata->num_procs) { jdata 790 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_TERMINATED); jdata 806 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c static void default_hnp_abort(orte_job_t *jdata) jdata 816 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 823 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 833 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (ORTE_PROC_MY_NAME->jobid == jdata->jobid) { jdata 839 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_NUM_NONZERO_EXIT, (void**)&i32ptr, OPAL_INT32)) { jdata 842 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c (1 == ORTE_LOCAL_JOBID(jdata->jobid)) ? "Primary" : "Child", jdata 843 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c (1 == ORTE_LOCAL_JOBID(jdata->jobid)) ? "" : ORTE_LOCAL_JOBID_PRINT(jdata->jobid), jdata 236 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_job_t *jdata; jdata 254 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (NULL == caddy->jdata) { jdata 261 orte/mca/errmgr/default_orted/errmgr_default_orted.c jdata = caddy->jdata; jdata 263 orte/mca/errmgr/default_orted/errmgr_default_orted.c jdata->state = jobstate; jdata 268 orte/mca/errmgr/default_orted/errmgr_default_orted.c ORTE_JOBID_PRINT(jdata->jobid), jdata 273 orte/mca/errmgr/default_orted/errmgr_default_orted.c failed_start(jdata); jdata 299 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (ORTE_SUCCESS != (rc = pack_state_update(alert, jdata))) { jdata 319 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_job_t *jdata; jdata 378 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (NULL == (jdata = orte_get_job_data_object(proc->jobid))) { jdata 404 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (NULL == (child = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid))) { jdata 457 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (NULL == (child = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid))) { jdata 483 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_FAIL_NOTIFIED, NULL, OPAL_BOOL)) { jdata 509 orte/mca/errmgr/default_orted/errmgr_default_orted.c jdata->num_local_procs)); jdata 517 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_set_attribute(&jdata->attributes, ORTE_JOB_FAIL_NOTIFIED, ORTE_ATTR_LOCAL, NULL, OPAL_BOOL); jdata 533 orte/mca/errmgr/default_orted/errmgr_default_orted.c jdata->num_terminated++; jdata 540 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (jdata->num_local_procs == jdata->num_terminated) { jdata 543 orte/mca/errmgr/default_orted/errmgr_default_orted.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_START); jdata 545 orte/mca/errmgr/default_orted/errmgr_default_orted.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_LAUNCH); jdata 564 orte/mca/errmgr/default_orted/errmgr_default_orted.c jdata->num_terminated++; jdata 590 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_FAIL_NOTIFIED, NULL, OPAL_BOOL)) { jdata 615 orte/mca/errmgr/default_orted/errmgr_default_orted.c jdata->num_local_procs)); jdata 623 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_set_attribute(&jdata->attributes, ORTE_JOB_FAIL_NOTIFIED, ORTE_ATTR_LOCAL, NULL, OPAL_BOOL); jdata 644 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (ORTE_SUCCESS != (rc = pack_state_update(alert, jdata))) { jdata 652 orte/mca/errmgr/default_orted/errmgr_default_orted.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 659 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (jdata->jobid == ptr->name.jobid) { jdata 666 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_session_dir_cleanup(jdata->jobid); jdata 669 orte/mca/errmgr/default_orted/errmgr_default_orted.c OBJ_RELEASE(jdata); jdata 105 orte/mca/ess/base/ess_base_std_orted.c orte_job_t *jdata; jdata 330 orte/mca/ess/base/ess_base_std_orted.c jdata = OBJ_NEW(orte_job_t); jdata 331 orte/mca/ess/base/ess_base_std_orted.c jdata->jobid = ORTE_PROC_MY_NAME->jobid; jdata 332 orte/mca/ess/base/ess_base_std_orted.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata); jdata 335 orte/mca/ess/base/ess_base_std_orted.c opal_pointer_array_set_item(jdata->apps, 0, app); jdata 336 orte/mca/ess/base/ess_base_std_orted.c jdata->num_apps++; jdata 344 orte/mca/ess/base/ess_base_std_orted.c opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc); jdata 346 orte/mca/ess/base/ess_base_std_orted.c jdata->num_procs = 1; jdata 347 orte/mca/ess/base/ess_base_std_orted.c jdata->state = ORTE_JOB_STATE_RUNNING; jdata 349 orte/mca/ess/base/ess_base_std_orted.c jdata->num_reported = 1; jdata 135 orte/mca/ess/hnp/ess_hnp_module.c orte_job_t *jdata; jdata 422 orte/mca/ess/hnp/ess_hnp_module.c jdata = OBJ_NEW(orte_job_t); jdata 423 orte/mca/ess/hnp/ess_hnp_module.c jdata->jobid = ORTE_PROC_MY_NAME->jobid; jdata 424 orte/mca/ess/hnp/ess_hnp_module.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata); jdata 429 orte/mca/ess/hnp/ess_hnp_module.c jdata->state = ORTE_JOB_STATE_DAEMONS_REPORTED; jdata 433 orte/mca/ess/hnp/ess_hnp_module.c opal_pointer_array_set_item(jdata->apps, 0, app); jdata 434 orte/mca/ess/hnp/ess_hnp_module.c jdata->num_apps++; jdata 469 orte/mca/ess/hnp/ess_hnp_module.c opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc); jdata 494 orte/mca/ess/hnp/ess_hnp_module.c jdata->num_procs = 1; jdata 495 orte/mca/ess/hnp/ess_hnp_module.c jdata->state = ORTE_JOB_STATE_RUNNING; jdata 497 orte/mca/ess/hnp/ess_hnp_module.c jdata->num_reported = 1; jdata 728 orte/mca/ess/hnp/ess_hnp_module.c orte_job_t *jdata; jdata 801 orte/mca/ess/hnp/ess_hnp_module.c OPAL_HASH_TABLE_FOREACH(key, uint32, jdata, orte_job_data) { jdata 802 orte/mca/ess/hnp/ess_hnp_module.c if (NULL != jdata) { jdata 803 orte/mca/ess/hnp/ess_hnp_module.c OBJ_RELEASE(jdata); jdata 72 orte/mca/filem/base/base.h int orte_filem_base_none_preposition_files(orte_job_t *jdata, jdata 75 orte/mca/filem/base/base.h int orte_filem_base_none_link_local_files(orte_job_t *jdata, jdata 201 orte/mca/filem/base/filem_base_fns.c int orte_filem_base_none_preposition_files(orte_job_t *jdata, jdata 211 orte/mca/filem/base/filem_base_fns.c int orte_filem_base_none_link_local_files(orte_job_t *jdata, jdata 168 orte/mca/filem/base/filem_base_receive.c orte_job_t *jdata = NULL; jdata 187 orte/mca/filem/base/filem_base_receive.c if (NULL == (jdata = orte_get_job_data_object(name.jobid))) { jdata 193 orte/mca/filem/base/filem_base_receive.c proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, name.vpid); jdata 338 orte/mca/filem/filem.h typedef int (*orte_filem_base_preposition_files_fn_t)(orte_job_t *jdata, jdata 343 orte/mca/filem/filem.h typedef int (*orte_filem_base_link_local_files_fn_t)(orte_job_t *jdata, jdata 65 orte/mca/filem/raw/filem_raw_module.c static int raw_preposition_files(orte_job_t *jdata, jdata 68 orte/mca/filem/raw/filem_raw_module.c static int raw_link_local_files(orte_job_t *jdata, jdata 246 orte/mca/filem/raw/filem_raw_module.c static int raw_preposition_files(orte_job_t *jdata, jdata 265 orte/mca/filem/raw/filem_raw_module.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 271 orte/mca/filem/raw/filem_raw_module.c for (i=0; i < jdata->apps->size; i++) { jdata 272 orte/mca/filem/raw/filem_raw_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 620 orte/mca/filem/raw/filem_raw_module.c static int raw_link_local_files(orte_job_t *jdata, jdata 670 orte/mca/filem/raw/filem_raw_module.c if (proc->name.jobid != jdata->jobid) { jdata 675 orte/mca/filem/raw/filem_raw_module.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 314 orte/mca/grpcomm/base/grpcomm_base_stubs.c orte_job_t *jdata; jdata 344 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (NULL == (jdata = orte_get_job_data_object(sig->signature[0].jobid))) { jdata 351 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (NULL == jdata->map || 0 == jdata->map->num_nodes) { jdata 368 orte/mca/grpcomm/base/grpcomm_base_stubs.c dns = (orte_vpid_t*)malloc(jdata->map->num_nodes * sizeof(vpid)); jdata 370 orte/mca/grpcomm/base/grpcomm_base_stubs.c for (i=0; i < jdata->map->nodes->size && (int)nds < jdata->map->num_nodes; i++) { jdata 371 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (NULL == (node = opal_pointer_array_get_item(jdata->map->nodes, i))) { jdata 395 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (NULL == (jdata = orte_get_job_data_object(sig->signature[n].jobid))) { jdata 407 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, sig->signature[n].vpid))) { jdata 266 orte/mca/grpcomm/direct/grpcomm_direct.c orte_job_t *jdata; jdata 541 orte/mca/grpcomm/direct/grpcomm_direct.c jdata = orte_get_job_data_object(nm->name.jobid); jdata 542 orte/mca/grpcomm/direct/grpcomm_direct.c if (NULL == (rec = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, nm->name.vpid))) { jdata 76 orte/mca/iof/base/base.h orte_job_t *jdata; jdata 162 orte/mca/iof/base/iof_base_frame.c ptr->jdata = NULL; jdata 167 orte/mca/iof/base/iof_base_frame.c if (NULL != ptr->jdata) { jdata 168 orte/mca/iof/base/iof_base_frame.c OBJ_RELEASE(ptr->jdata); jdata 77 orte/mca/iof/hnp/iof_hnp.c static void hnp_complete(const orte_job_t *jdata); jdata 136 orte/mca/iof/hnp/iof_hnp.c orte_job_t *jdata; jdata 178 orte/mca/iof/hnp/iof_hnp.c if (NULL == (jdata = orte_get_job_data_object(proct->name.jobid))) { jdata 196 orte/mca/iof/hnp/iof_hnp.c if (ORTE_SUCCESS != (rc = orte_iof_base_setup_output_files(dst_name, jdata, proct))) { jdata 248 orte/mca/iof/hnp/iof_hnp.c if (NULL == (jdata = orte_get_job_data_object(dst_name->jobid))) { jdata 252 orte/mca/iof/hnp/iof_hnp.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, dst_name->vpid))) { jdata 441 orte/mca/iof/hnp/iof_hnp.c static void hnp_complete(const orte_job_t *jdata) jdata 447 orte/mca/iof/hnp/iof_hnp.c if (jdata->jobid == proct->name.jobid) { jdata 198 orte/mca/iof/iof.h typedef void (*orte_iof_base_complete_fn_t)(const orte_job_t *jdata); jdata 80 orte/mca/iof/orted/iof_orted.c static void orted_complete(const orte_job_t *jdata); jdata 335 orte/mca/iof/orted/iof_orted.c static void orted_complete(const orte_job_t *jdata) jdata 341 orte/mca/iof/orted/iof_orted.c if (jdata->jobid == proct->name.jobid) { jdata 355 orte/mca/odls/alps/odls_alps_module.c if (ORTE_FLAG_TEST(cd->jdata, ORTE_JOB_FLAG_FORWARD_OUTPUT)) { jdata 368 orte/mca/odls/alps/odls_alps_module.c orte_rtc.set(cd->jdata, cd->child, &cd->env, write_fd); jdata 370 orte/mca/odls/alps/odls_alps_module.c } else if (!ORTE_FLAG_TEST(cd->jdata, ORTE_JOB_FLAG_FORWARD_OUTPUT)) { jdata 48 orte/mca/odls/base/base.h ORTE_DECLSPEC void orte_odls_base_start_threads(orte_job_t *jdata); jdata 108 orte/mca/odls/base/odls_base_default_fns.c orte_job_t *jdata = (orte_job_t*)provided_cbdata; jdata 124 orte/mca/odls/base/odls_base_default_fns.c opal_dss.pack(&jdata->launch_msg, &bptr, 1, OPAL_BUFFER); jdata 133 orte/mca/odls/base/odls_base_default_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_SEND_LAUNCH_MSG); jdata 143 orte/mca/odls/base/odls_base_default_fns.c orte_job_t *jdata=NULL, *jptr; jdata 157 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (jdata = orte_get_job_data_object(job))) { jdata 163 orte/mca/odls/base/odls_base_default_fns.c map = jdata->map; jdata 174 orte/mca/odls/base/odls_base_default_fns.c orte_get_attribute(&jdata->attributes, ORTE_JOB_LAUNCHED_DAEMONS, NULL, OPAL_BOOL))) { jdata 333 orte/mca/odls/base/odls_base_default_fns.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_LAUNCHED_DAEMONS, NULL, OPAL_BOOL)) { jdata 340 orte/mca/odls/base/odls_base_default_fns.c if (NULL != jptr && jptr != jdata && jdata 397 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = opal_dss.pack(buffer, &jdata, 1, ORTE_JOB))) { jdata 402 orte/mca/odls/base/odls_base_default_fns.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_FULLY_DESCRIBED, NULL, OPAL_BOOL)) { jdata 404 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = orte_util_generate_ppn(jdata, buffer))) { jdata 417 orte/mca/odls/base/odls_base_default_fns.c opal_asprintf(&kv->data.string, "%s.net", ORTE_JOBID_PRINT(jdata->jobid)); jdata 433 orte/mca/odls/base/odls_base_default_fns.c if (OPAL_SUCCESS != (rc = opal_pmix.server_setup_application(jdata->jobid, &ilist, setup_cbfunc, jdata))) { jdata 441 orte/mca/odls/base/odls_base_default_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_SEND_LAUNCH_MSG); jdata 457 orte/mca/odls/base/odls_base_default_fns.c orte_job_t *jdata=NULL, *daemons; jdata 500 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = opal_dss.unpack(jptr, &jdata, &cnt, ORTE_JOB))) { jdata 508 orte/mca/odls/base/odls_base_default_fns.c if (NULL == orte_get_job_data_object(jdata->jobid)) { jdata 510 orte/mca/odls/base/odls_base_default_fns.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata); jdata 513 orte/mca/odls/base/odls_base_default_fns.c jdata->jobid = ORTE_JOBID_INVALID; jdata 514 orte/mca/odls/base/odls_base_default_fns.c OBJ_RELEASE(jdata); jdata 520 orte/mca/odls/base/odls_base_default_fns.c for (v=0; v < jdata->num_procs; v++) { jdata 521 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, v))) { jdata 523 orte/mca/odls/base/odls_base_default_fns.c pptr->name.jobid = jdata->jobid; jdata 525 orte/mca/odls/base/odls_base_default_fns.c opal_pointer_array_set_item(jdata->procs, v, pptr); jdata 555 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = opal_dss.unpack(buffer, &jdata, &cnt, ORTE_JOB))) { jdata 560 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_JOBID_INVALID == jdata->jobid) { jdata 565 orte/mca/odls/base/odls_base_default_fns.c *job = jdata->jobid; jdata 581 orte/mca/odls/base/odls_base_default_fns.c jdata->jobid = ORTE_JOBID_INVALID; jdata 582 orte/mca/odls/base/odls_base_default_fns.c OBJ_RELEASE(jdata); jdata 584 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (jdata = orte_get_job_data_object(*job))) { jdata 590 orte/mca/odls/base/odls_base_default_fns.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata); jdata 593 orte/mca/odls/base/odls_base_default_fns.c if (NULL == jdata->map) { jdata 594 orte/mca/odls/base/odls_base_default_fns.c jdata->map = OBJ_NEW(orte_job_map_t); jdata 601 orte/mca/odls/base/odls_base_default_fns.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_FULLY_DESCRIBED, NULL, OPAL_BOOL)) { jdata 605 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = orte_util_decode_ppn(jdata, buffer))) { jdata 612 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_assign_locations(jdata))) { jdata 620 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_compute_vpids(jdata))) { jdata 625 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_compute_local_ranks(jdata))) { jdata 659 orte/mca/odls/base/odls_base_default_fns.c orte_prepend_attribute(&jdata->attributes, ORTE_JOB_SET_ENVAR, jdata 662 orte/mca/odls/base/odls_base_default_fns.c orte_prepend_attribute(&jdata->attributes, ORTE_JOB_ADD_ENVAR, jdata 665 orte/mca/odls/base/odls_base_default_fns.c orte_prepend_attribute(&jdata->attributes, ORTE_JOB_UNSET_ENVAR, jdata 668 orte/mca/odls/base/odls_base_default_fns.c orte_prepend_attribute(&jdata->attributes, ORTE_JOB_PREPEND_ENVAR, jdata 671 orte/mca/odls/base/odls_base_default_fns.c orte_prepend_attribute(&jdata->attributes, ORTE_JOB_APPEND_ENVAR, jdata 682 orte/mca/odls/base/odls_base_default_fns.c for (n=0; n < jdata->procs->size; n++) { jdata 683 orte/mca/odls/base/odls_base_default_fns.c if (NULL == (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, n))) { jdata 691 orte/mca/odls/base/odls_base_default_fns.c orte_get_attribute(&jdata->attributes, ORTE_JOB_FULLY_DESCRIBED, NULL, OPAL_BOOL)) { jdata 715 orte/mca/odls/base/odls_base_default_fns.c opal_pointer_array_add(jdata->map->nodes, pptr->node); jdata 716 orte/mca/odls/base/odls_base_default_fns.c jdata->map->num_nodes++; jdata 735 orte/mca/odls/base/odls_base_default_fns.c jdata->num_local_procs++; jdata 743 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 747 orte/mca/odls/base/odls_base_default_fns.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, pptr->app_idx); jdata 751 orte/mca/odls/base/odls_base_default_fns.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_FULLY_DESCRIBED, NULL, OPAL_BOOL)) { jdata 753 orte/mca/odls/base/odls_base_default_fns.c for (n=0; n < jdata->map->nodes->size; n++) { jdata 754 orte/mca/odls/base/odls_base_default_fns.c if (NULL != (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, n))) { jdata 760 orte/mca/odls/base/odls_base_default_fns.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_FULLY_DESCRIBED, NULL, OPAL_BOOL)) { jdata 762 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_compute_bindings(jdata))) { jdata 769 orte/mca/odls/base/odls_base_default_fns.c if (jdata->map->display_map) { jdata 770 orte/mca/odls/base/odls_base_default_fns.c orte_rmaps_base_display_map(jdata); jdata 775 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = orte_pmix_server_register_nspace(jdata, false))) { jdata 785 orte/mca/odls/base/odls_base_default_fns.c if (OPAL_SUCCESS != (rc = opal_pmix.server_setup_local_support(jdata->jobid, &local_support, jdata 795 orte/mca/odls/base/odls_base_default_fns.c orte_rtc.assign(jdata); jdata 798 orte/mca/odls/base/odls_base_default_fns.c orte_odls_base_start_threads(jdata); jdata 915 orte/mca/odls/base/odls_base_default_fns.c orte_job_t *jobdat = cd->jdata; jdata 1412 orte/mca/odls/base/odls_base_default_fns.c cd->jdata = jobdat; jdata 2090 orte/mca/odls/base/odls_base_default_fns.c cd->jdata = jobdat; jdata 145 orte/mca/odls/base/odls_base_frame.c void orte_odls_base_start_threads(orte_job_t *jdata) jdata 161 orte/mca/odls/base/odls_base_frame.c if ((int)jdata->num_local_procs < orte_odls_globals.cutoff) { jdata 168 orte/mca/odls/base/odls_base_frame.c orte_odls_globals.num_threads = jdata->num_local_procs / 8; jdata 102 orte/mca/odls/base/odls_private.h orte_job_t *jdata; jdata 366 orte/mca/odls/default/odls_default_module.c if (ORTE_FLAG_TEST(cd->jdata, ORTE_JOB_FLAG_FORWARD_OUTPUT)) { jdata 378 orte/mca/odls/default/odls_default_module.c orte_rtc.set(cd->jdata, cd->child, &cd->env, write_fd); jdata 380 orte/mca/odls/default/odls_default_module.c } else if (!ORTE_FLAG_TEST(cd->jdata, ORTE_JOB_FLAG_FORWARD_OUTPUT)) { jdata 83 orte/mca/plm/alps/plm_alps_module.c static int plm_alps_launch_job(orte_job_t *jdata); jdata 155 orte/mca/plm/alps/plm_alps_module.c static int plm_alps_launch_job(orte_job_t *jdata) jdata 158 orte/mca/plm/alps/plm_alps_module.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 160 orte/mca/plm/alps/plm_alps_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP); jdata 163 orte/mca/plm/alps/plm_alps_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_INIT); jdata 198 orte/mca/plm/alps/plm_alps_module.c if (ORTE_FLAG_TEST(state->jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON)) { jdata 199 orte/mca/plm/alps/plm_alps_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 200 orte/mca/plm/alps/plm_alps_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 207 orte/mca/plm/alps/plm_alps_module.c if (ORTE_SUCCESS != (rc = orte_plm_base_setup_virtual_machine(state->jdata))) { jdata 221 orte/mca/plm/alps/plm_alps_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 222 orte/mca/plm/alps/plm_alps_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 242 orte/mca/plm/alps/plm_alps_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 243 orte/mca/plm/alps/plm_alps_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 377 orte/mca/plm/alps/plm_alps_module.c for (i=0; i < state->jdata->apps->size; i++) { jdata 379 orte/mca/plm/alps/plm_alps_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(state->jdata->apps, i))) { jdata 428 orte/mca/plm/alps/plm_alps_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 463 orte/mca/plm/alps/plm_alps_module.c orte_job_t *jdata; jdata 483 orte/mca/plm/alps/plm_alps_module.c jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid); jdata 484 orte/mca/plm/alps/plm_alps_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_TERMINATED); jdata 525 orte/mca/plm/alps/plm_alps_module.c orte_job_t *jdata; jdata 542 orte/mca/plm/alps/plm_alps_module.c jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid); jdata 549 orte/mca/plm/alps/plm_alps_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_START); jdata 554 orte/mca/plm/alps/plm_alps_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ABORTED); jdata 78 orte/mca/plm/base/plm_base_jobid.c int orte_plm_base_create_jobid(orte_job_t *jdata) jdata 80 orte/mca/plm/base/plm_base_jobid.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 90 orte/mca/plm/base/plm_base_jobid.c jdata->jobid = ORTE_JOBID_INVALID; jdata 95 orte/mca/plm/base/plm_base_jobid.c jdata->jobid = ORTE_CONSTRUCT_LOCAL_JOBID(ORTE_PROC_MY_NAME->jobid, orte_plm_globals.next_jobid); jdata 162 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->total_slots_alloc = 0; jdata 173 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->total_slots_alloc += node->slots; jdata 257 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_DAEMONS_REPORTED; jdata 258 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_VM_READY); jdata 274 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_ALLOCATION_COMPLETE; jdata 275 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_MAP); jdata 278 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_ALLOCATION_COMPLETE; jdata 279 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_LAUNCH_DAEMONS); jdata 302 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata = (orte_job_t*)cbdata; jdata 307 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP); jdata 318 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_VM_READY; jdata 321 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != orte_filem.preposition_files(caddy->jdata, files_ready, caddy->jdata)) { jdata 336 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_MAP_COMPLETE; jdata 337 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_SYSTEM_PREP); jdata 366 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = caddy->job_state; jdata 369 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOBID_INVALID == caddy->jdata->jobid) { jdata 370 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_plm_base_create_jobid(caddy->jdata))) { jdata 382 orte/mca/plm/base/plm_base_launch_support.c opal_hash_table_set_value_uint32(orte_job_data, caddy->jdata->jobid, caddy->jdata); jdata 386 orte/mca/plm/base/plm_base_launch_support.c if (!ORTE_FLAG_TEST(caddy->jdata, ORTE_JOB_FLAG_RECOVERABLE) && jdata 388 orte/mca/plm/base/plm_base_launch_support.c ORTE_FLAG_SET(caddy->jdata, ORTE_JOB_FLAG_RECOVERABLE); jdata 398 orte/mca/plm/base/plm_base_launch_support.c if (orte_get_attribute(&caddy->jdata->attributes, ORTE_JOB_LAUNCH_PROXY, (void**)&nptr, OPAL_NAME)) { jdata 412 orte/mca/plm/base/plm_base_launch_support.c orte_set_attribute(&caddy->jdata->attributes, ORTE_JOB_TRANSPORT_KEY, ORTE_ATTR_LOCAL, key, OPAL_STRING); jdata 414 orte/mca/plm/base/plm_base_launch_support.c for (i=0; i < caddy->jdata->apps->size; i++) { jdata 415 orte/mca/plm/base/plm_base_launch_support.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(caddy->jdata->apps, i))) { jdata 422 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_pre_condition_transports(caddy->jdata, NULL))) { jdata 432 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_pre_condition_transports(caddy->jdata, NULL))) { jdata 441 orte/mca/plm/base/plm_base_launch_support.c for (i=0; i < caddy->jdata->apps->size; i++) { jdata 442 orte/mca/plm/base/plm_base_launch_support.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(caddy->jdata->apps, i))) { jdata 451 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_INIT_COMPLETE); jdata 464 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_ALLOCATE); jdata 470 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata, *jdatorted; jdata 484 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(caddy->jdata->jobid)); jdata 493 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = caddy->job_state; jdata 504 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; jdata 514 orte/mca/plm/base/plm_base_launch_support.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_FWDIO_TO_TOOL, NULL, OPAL_BOOL)) { jdata 517 orte/mca/plm/base/plm_base_launch_support.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_LAUNCH_PROXY, (void**)&rptr, OPAL_NAME)) { jdata 518 orte/mca/plm/base/plm_base_launch_support.c ORTE_IOF_PROXY_PULL(jdata, rptr); jdata 520 orte/mca/plm/base/plm_base_launch_support.c ORTE_IOF_PROXY_PULL(jdata, &jdata->originator); jdata 564 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_LAUNCH_APPS); jdata 573 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata = (orte_job_t*)cbdata; jdata 576 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(jdata); jdata 579 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_START); jdata 582 orte/mca/plm/base/plm_base_launch_support.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_FAILURE_TIMER_EVENT, (void**)&timer, OPAL_PTR)) { jdata 585 orte/mca/plm/base/plm_base_launch_support.c orte_remove_attribute(&jdata->attributes, ORTE_JOB_FAILURE_TIMER_EVENT); jdata 592 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata; jdata 599 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; jdata 607 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = caddy->job_state; jdata 612 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 615 orte/mca/plm/base/plm_base_launch_support.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_FIXED_DVM, NULL, OPAL_BOOL)) { jdata 620 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = opal_dss.pack(&jdata->launch_msg, &command, 1, ORTE_DAEMON_CMD))) { jdata 628 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_odls.get_add_procs_data(&jdata->launch_msg, jdata->jobid))) { jdata 642 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata; jdata 646 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; jdata 651 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 659 orte/mca/plm/base/plm_base_launch_support.c compressed = opal_compress.compress_block((uint8_t*)jdata->launch_msg.base_ptr, jdata 660 orte/mca/plm/base/plm_base_launch_support.c jdata->launch_msg.bytes_used, jdata 664 orte/mca/plm/base/plm_base_launch_support.c (int)jdata->launch_msg.bytes_used, (int)cmplen); jdata 667 orte/mca/plm/base/plm_base_launch_support.c opal_output(0, "LAUNCH MSG RAW SIZE: %d", (int)jdata->launch_msg.bytes_used); jdata 681 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_grpcomm.xcast(sig, ORTE_RML_TAG_DAEMON, &jdata->launch_msg))) { jdata 688 orte/mca/plm/base/plm_base_launch_support.c OBJ_DESTRUCT(&jdata->launch_msg); jdata 689 orte/mca/plm/base/plm_base_launch_support.c OBJ_CONSTRUCT(&jdata->launch_msg, opal_buffer_t); jdata 696 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->num_daemons_reported++; jdata 705 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 707 orte/mca/plm/base/plm_base_launch_support.c timer->payload = jdata; jdata 709 orte/mca/plm/base/plm_base_launch_support.c timer->ev, timer_cb, jdata); jdata 713 orte/mca/plm/base/plm_base_launch_support.c orte_set_attribute(&jdata->attributes, ORTE_JOB_FAILURE_TIMER_EVENT, ORTE_ATTR_LOCAL, timer, OPAL_PTR); jdata 725 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata; jdata 736 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; jdata 739 orte/mca/plm/base/plm_base_launch_support.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_FAILURE_TIMER_EVENT, (void**)&timer, OPAL_PTR)) { jdata 744 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 746 orte/mca/plm/base/plm_base_launch_support.c orte_remove_attribute(&jdata->attributes, ORTE_JOB_FAILURE_TIMER_EVENT); jdata 755 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = caddy->job_state; jdata 761 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 764 orte/mca/plm/base/plm_base_launch_support.c name.jobid = jdata->jobid; jdata 765 orte/mca/plm/base/plm_base_launch_support.c name.vpid = jdata->stdin_target; jdata 775 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOBID_INVALID == jdata->originator.jobid) { jdata 779 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 794 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (ret = opal_dss.pack(answer, &jdata->jobid, 1, ORTE_JOBID))) { jdata 802 orte/mca/plm/base/plm_base_launch_support.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_ROOM_NUM, (void**)&rmptr, OPAL_INT)) { jdata 813 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid), jdata 814 orte/mca/plm/base/plm_base_launch_support.c ORTE_NAME_PRINT(&jdata->originator))); jdata 815 orte/mca/plm/base/plm_base_launch_support.c if (0 > (ret = orte_rml.send_buffer_nb(&jdata->originator, answer, jdata 832 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata; jdata 838 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; jdata 843 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 849 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(jdata->jobid), jdata 856 orte/mca/plm/base/plm_base_launch_support.c jdata->state = caddy->job_state; jdata 859 orte/mca/plm/base/plm_base_launch_support.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON)) { jdata 860 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_READY_FOR_DEBUGGERS); jdata 882 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata; jdata 1057 orte/mca/plm/base/plm_base_launch_support.c rc = opal_hash_table_get_first_key_uint32(orte_job_data, &key, (void **)&jdata, &nptr); jdata 1059 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_PROC_MY_NAME->jobid != jdata->jobid) { jdata 1061 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOB_STATE_DAEMONS_LAUNCHED == jdata->state) { jdata 1062 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 1065 orte/mca/plm/base/plm_base_launch_support.c rc = opal_hash_table_get_next_key_uint32(orte_job_data, &key, (void **)&jdata, nptr, &nptr); jdata 1082 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata; jdata 1393 orte/mca/plm/base/plm_base_launch_support.c rc = opal_hash_table_get_first_key_uint32(orte_job_data, &key, (void **)&jdata, &nptr); jdata 1395 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_PROC_MY_NAME->jobid == jdata->jobid) { jdata 1399 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOB_STATE_DAEMONS_LAUNCHED == jdata->state) { jdata 1400 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 1403 orte/mca/plm/base/plm_base_launch_support.c rc = opal_hash_table_get_next_key_uint32(orte_job_data, &key, (void **)&jdata, nptr, &nptr); jdata 1502 orte/mca/plm/base/plm_base_launch_support.c orte_job_t *jdata; jdata 1581 orte/mca/plm/base/plm_base_launch_support.c jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid); jdata 1582 orte/mca/plm/base/plm_base_launch_support.c num_procs = jdata->num_procs; jdata 1761 orte/mca/plm/base/plm_base_launch_support.c int orte_plm_base_setup_virtual_machine(orte_job_t *jdata) jdata 1793 orte/mca/plm/base/plm_base_launch_support.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_FIXED_DVM, NULL, OPAL_BOOL)) { jdata 1803 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOBID_INVALID != jdata->originator.jobid) { jdata 1866 orte/mca/plm/base/plm_base_launch_support.c multi_sim = orte_get_attribute(&jdata->attributes, ORTE_JOB_MULTI_DAEMON_SIM, NULL, OPAL_BOOL); jdata 1964 orte/mca/plm/base/plm_base_launch_support.c for (i=0; i < jdata->apps->size; i++) { jdata 1965 orte/mca/plm/base/plm_base_launch_support.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 2151 orte/mca/plm/base/plm_base_launch_support.c for (i=0; i < jdata->apps->size; i++) { jdata 2152 orte/mca/plm/base/plm_base_launch_support.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 2325 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_set_attribute(&jdata->attributes, ORTE_JOB_LAUNCHED_DAEMONS, jdata 131 orte/mca/plm/base/plm_base_receive.c orte_job_t *jdata, *parent; jdata 165 orte/mca/plm/base/plm_base_receive.c if (ORTE_SUCCESS != (rc = opal_dss.unpack(buffer, &jdata, &count, ORTE_JOB))) { jdata 171 orte/mca/plm/base/plm_base_receive.c jdata->originator.jobid = sender->jobid; jdata 172 orte/mca/plm/base/plm_base_receive.c jdata->originator.vpid = sender->vpid; jdata 177 orte/mca/plm/base/plm_base_receive.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_LAUNCH_PROXY, (void**)&nptr, OPAL_NAME)) { jdata 193 orte/mca/plm/base/plm_base_receive.c child_app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, 0); jdata 208 orte/mca/plm/base/plm_base_receive.c for (i=0; i < jdata->apps->size; i++) { jdata 209 orte/mca/plm/base/plm_base_receive.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 223 orte/mca/plm/base/plm_base_receive.c if (ORTE_SUCCESS != (rc = orte_ras_base_add_hosts(jdata))) { jdata 237 orte/mca/plm/base/plm_base_receive.c jdata->bookmark = proc->node; jdata 240 orte/mca/plm/base/plm_base_receive.c jdata->bookmark = parent->bookmark; jdata 243 orte/mca/plm/base/plm_base_receive.c jdata->bkmark_obj = parent->bkmark_obj; jdata 250 orte/mca/plm/base/plm_base_receive.c if (ORTE_SUCCESS != (rc = orte_plm.spawn(jdata))) { jdata 274 orte/mca/plm/base/plm_base_receive.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_ROOM_NUM, (void**)&room, OPAL_INT)) { jdata 304 orte/mca/plm/base/plm_base_receive.c jdata = orte_get_job_data_object(job); jdata 339 orte/mca/plm/base/plm_base_receive.c if (NULL != jdata) { jdata 341 orte/mca/plm/base/plm_base_receive.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, vpid))) { jdata 355 orte/mca/plm/base/plm_base_receive.c if (running && NULL != jdata) { jdata 356 orte/mca/plm/base/plm_base_receive.c jdata->num_daemons_reported++; jdata 358 orte/mca/plm/base/plm_base_receive.c if (0 == jdata->num_daemons_reported % 100 || jdata 359 orte/mca/plm/base/plm_base_receive.c jdata->num_daemons_reported == orte_process_info.num_procs) { jdata 360 orte/mca/plm/base/plm_base_receive.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_REPORT_PROGRESS); jdata 382 orte/mca/plm/base/plm_base_receive.c if (NULL == (jdata = orte_get_job_data_object(job))) { jdata 404 orte/mca/plm/base/plm_base_receive.c jdata = NULL; jdata 90 orte/mca/plm/base/plm_private.h ORTE_DECLSPEC int orte_plm_base_create_jobid(orte_job_t *jdata); jdata 92 orte/mca/plm/base/plm_private.h ORTE_DECLSPEC void orte_plm_base_reset_job(orte_job_t *jdata); jdata 95 orte/mca/plm/base/plm_private.h ORTE_DECLSPEC int orte_plm_base_setup_virtual_machine(orte_job_t *jdata); jdata 127 orte/mca/plm/base/plm_private.h ORTE_DECLSPEC int orte_plm_proxy_spawn(orte_job_t *jdata); jdata 54 orte/mca/plm/isolated/plm_isolated.c static int isolated_launch(orte_job_t *jdata); jdata 104 orte/mca/plm/isolated/plm_isolated.c static int isolated_launch(orte_job_t *jdata) jdata 106 orte/mca/plm/isolated/plm_isolated.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 108 orte/mca/plm/isolated/plm_isolated.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP); jdata 111 orte/mca/plm/isolated/plm_isolated.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_INIT); jdata 125 orte/mca/plm/isolated/plm_isolated.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 82 orte/mca/plm/lsf/plm_lsf_module.c static int plm_lsf_launch_job(orte_job_t *jdata); jdata 143 orte/mca/plm/lsf/plm_lsf_module.c static int plm_lsf_launch_job(orte_job_t *jdata) jdata 145 orte/mca/plm/lsf/plm_lsf_module.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 147 orte/mca/plm/lsf/plm_lsf_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP); jdata 150 orte/mca/plm/lsf/plm_lsf_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_INIT); jdata 176 orte/mca/plm/lsf/plm_lsf_module.c orte_job_t *jdata; jdata 179 orte/mca/plm/lsf/plm_lsf_module.c jdata = state->jdata; jdata 183 orte/mca/plm/lsf/plm_lsf_module.c if (ORTE_SUCCESS != (rc = orte_plm_base_setup_virtual_machine(jdata))) { jdata 197 orte/mca/plm/lsf/plm_lsf_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 198 orte/mca/plm/lsf/plm_lsf_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 224 orte/mca/plm/lsf/plm_lsf_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 225 orte/mca/plm/lsf/plm_lsf_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 301 orte/mca/plm/lsf/plm_lsf_module.c for (i=0; i < jdata->apps->size; i++) { jdata 303 orte/mca/plm/lsf/plm_lsf_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 361 orte/mca/plm/lsf/plm_lsf_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 63 orte/mca/plm/plm.h typedef int (*orte_plm_base_module_spawn_fn_t)(orte_job_t *jdata); jdata 102 orte/mca/plm/rsh/plm_rsh_module.c static int rsh_launch(orte_job_t *jdata); jdata 264 orte/mca/plm/rsh/plm_rsh_module.c orte_job_t *jdata; jdata 298 orte/mca/plm/rsh/plm_rsh_module.c jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid); jdata 309 orte/mca/plm/rsh/plm_rsh_module.c jdata->num_terminated++; jdata 924 orte/mca/plm/rsh/plm_rsh_module.c static int rsh_launch(orte_job_t *jdata) jdata 926 orte/mca/plm/rsh/plm_rsh_module.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 928 orte/mca/plm/rsh/plm_rsh_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP); jdata 931 orte/mca/plm/rsh/plm_rsh_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_INIT); jdata 1043 orte/mca/plm/rsh/plm_rsh_module.c if (ORTE_FLAG_TEST(state->jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON)) { jdata 1044 orte/mca/plm/rsh/plm_rsh_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 1045 orte/mca/plm/rsh/plm_rsh_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 1052 orte/mca/plm/rsh/plm_rsh_module.c if (ORTE_SUCCESS != (rc = orte_plm_base_setup_virtual_machine(state->jdata))) { jdata 1066 orte/mca/plm/rsh/plm_rsh_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 1067 orte/mca/plm/rsh/plm_rsh_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 1084 orte/mca/plm/rsh/plm_rsh_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 1085 orte/mca/plm/rsh/plm_rsh_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 1135 orte/mca/plm/rsh/plm_rsh_module.c app = (orte_app_context_t*)opal_pointer_array_get_item(state->jdata->apps, 0); jdata 1285 orte/mca/plm/rsh/plm_rsh_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 1323 orte/mca/plm/rsh/plm_rsh_module.c orte_job_t *jdata; jdata 1338 orte/mca/plm/rsh/plm_rsh_module.c if (NULL == (jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid))) { jdata 1341 orte/mca/plm/rsh/plm_rsh_module.c for (i=0; i < jdata->procs->size; i++) { jdata 1342 orte/mca/plm/rsh/plm_rsh_module.c if (NULL == (proc = opal_pointer_array_get_item(jdata->procs, i))) { jdata 83 orte/mca/plm/slurm/plm_slurm_module.c static int plm_slurm_launch_job(orte_job_t *jdata); jdata 156 orte/mca/plm/slurm/plm_slurm_module.c static int plm_slurm_launch_job(orte_job_t *jdata) jdata 158 orte/mca/plm/slurm/plm_slurm_module.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 160 orte/mca/plm/slurm/plm_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP); jdata 163 orte/mca/plm/slurm/plm_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_INIT); jdata 201 orte/mca/plm/slurm/plm_slurm_module.c if (ORTE_FLAG_TEST(state->jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON)) { jdata 202 orte/mca/plm/slurm/plm_slurm_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 203 orte/mca/plm/slurm/plm_slurm_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 210 orte/mca/plm/slurm/plm_slurm_module.c if (ORTE_SUCCESS != (rc = orte_plm_base_setup_virtual_machine(state->jdata))) { jdata 224 orte/mca/plm/slurm/plm_slurm_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 225 orte/mca/plm/slurm/plm_slurm_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 245 orte/mca/plm/slurm/plm_slurm_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 246 orte/mca/plm/slurm/plm_slurm_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 378 orte/mca/plm/slurm/plm_slurm_module.c for (n=0; n < state->jdata->apps->size; n++) { jdata 380 orte/mca/plm/slurm/plm_slurm_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(state->jdata->apps, n))) { jdata 448 orte/mca/plm/slurm/plm_slurm_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 482 orte/mca/plm/slurm/plm_slurm_module.c orte_job_t *jdata; jdata 497 orte/mca/plm/slurm/plm_slurm_module.c jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid); jdata 499 orte/mca/plm/slurm/plm_slurm_module.c jdata->num_terminated = jdata->num_procs; jdata 500 orte/mca/plm/slurm/plm_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_TERMINATED); jdata 539 orte/mca/plm/slurm/plm_slurm_module.c orte_job_t *jdata; jdata 561 orte/mca/plm/slurm/plm_slurm_module.c jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid); jdata 574 orte/mca/plm/slurm/plm_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ABORTED); jdata 585 orte/mca/plm/slurm/plm_slurm_module.c jdata->num_terminated = jdata->num_procs; jdata 586 orte/mca/plm/slurm/plm_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_TERMINATED); jdata 86 orte/mca/plm/tm/plm_tm_module.c static int plm_tm_launch_job(orte_job_t *jdata); jdata 152 orte/mca/plm/tm/plm_tm_module.c static int plm_tm_launch_job(orte_job_t *jdata) jdata 154 orte/mca/plm/tm/plm_tm_module.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 156 orte/mca/plm/tm/plm_tm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP); jdata 159 orte/mca/plm/tm/plm_tm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_INIT); jdata 187 orte/mca/plm/tm/plm_tm_module.c orte_job_t *daemons, *jdata; jdata 194 orte/mca/plm/tm/plm_tm_module.c jdata = state->jdata; jdata 199 orte/mca/plm/tm/plm_tm_module.c if (ORTE_FLAG_TEST(state->jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON)) { jdata 200 orte/mca/plm/tm/plm_tm_module.c jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 201 orte/mca/plm/tm/plm_tm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 208 orte/mca/plm/tm/plm_tm_module.c if (ORTE_SUCCESS != (rc = orte_plm_base_setup_virtual_machine(jdata))) { jdata 222 orte/mca/plm/tm/plm_tm_module.c jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 223 orte/mca/plm/tm/plm_tm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 240 orte/mca/plm/tm/plm_tm_module.c jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 241 orte/mca/plm/tm/plm_tm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_REPORTED); jdata 314 orte/mca/plm/tm/plm_tm_module.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, 0); jdata 402 orte/mca/plm/tm/plm_tm_module.c state->jdata->state = ORTE_JOB_STATE_DAEMONS_LAUNCHED; jdata 452 orte/mca/plm/tm/plm_tm_module.c ORTE_ACTIVATE_JOB_STATE(state->jdata, ORTE_JOB_STATE_FAILED_TO_START); jdata 58 orte/mca/ras/alps/ras_alps_module.c static int orte_ras_alps_allocate(orte_job_t *jdata, opal_list_t *nodes); jdata 305 orte/mca/ras/alps/ras_alps_module.c orte_ras_alps_allocate(orte_job_t *jdata, opal_list_t *nodes) jdata 65 orte/mca/ras/base/base.h ORTE_DECLSPEC int orte_ras_base_add_hosts(orte_job_t *jdata); jdata 114 orte/mca/ras/base/ras_base_allocate.c orte_job_t *jdata; jdata 129 orte/mca/ras/base/ras_base_allocate.c jdata = caddy->jdata; jdata 160 orte/mca/ras/base/ras_base_allocate.c if (ORTE_SUCCESS != (rc = orte_ras_base.active_module->allocate(jdata, &nodes))) { jdata 211 orte/mca/ras/base/ras_base_allocate.c if (ORTE_SUCCESS != (rc = orte_ras_base_node_insert(&nodes, jdata))) { jdata 261 orte/mca/ras/base/ras_base_allocate.c if (ORTE_SUCCESS != (rc = orte_ras_base_node_insert(&nodes, jdata))) { jdata 279 orte/mca/ras/base/ras_base_allocate.c for (i=0; i < jdata->apps->size; i++) { jdata 280 orte/mca/ras/base/ras_base_allocate.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 313 orte/mca/ras/base/ras_base_allocate.c if (ORTE_SUCCESS != (rc = orte_ras_base_node_insert(&nodes, jdata))) { jdata 339 orte/mca/ras/base/ras_base_allocate.c for (i=0; i < jdata->apps->size; i++) { jdata 340 orte/mca/ras/base/ras_base_allocate.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 368 orte/mca/ras/base/ras_base_allocate.c if (ORTE_SUCCESS != (rc = orte_ras_base_node_insert(&nodes, jdata))) { jdata 403 orte/mca/ras/base/ras_base_allocate.c if (ORTE_SUCCESS != (rc = orte_ras_base_node_insert(&nodes, jdata))) { jdata 445 orte/mca/ras/base/ras_base_allocate.c if (ORTE_SUCCESS != (rc = orte_ras_base_node_insert(&nodes, jdata))) { jdata 471 orte/mca/ras/base/ras_base_allocate.c jdata->total_slots_alloc = orte_ras_base.total_slots_alloc; jdata 474 orte/mca/ras/base/ras_base_allocate.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ALLOCATION_COMPLETE); jdata 480 orte/mca/ras/base/ras_base_allocate.c int orte_ras_base_add_hosts(orte_job_t *jdata) jdata 505 orte/mca/ras/base/ras_base_allocate.c for (i=0; i < jdata->apps->size; i++) { jdata 506 orte/mca/ras/base/ras_base_allocate.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 537 orte/mca/ras/base/ras_base_allocate.c for (i=0; i < jdata->apps->size; i++) { jdata 538 orte/mca/ras/base/ras_base_allocate.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 580 orte/mca/ras/base/ras_base_allocate.c if (ORTE_SUCCESS != (rc = orte_ras_base_node_insert(&nodes, jdata))) { jdata 43 orte/mca/ras/base/ras_base_node.c int orte_ras_base_node_insert(opal_list_t* nodes, orte_job_t *jdata) jdata 69 orte/mca/ras/base/ras_base_node.c orte_set_attribute(&jdata->attributes, ORTE_JOB_MULTI_DAEMON_SIM, jdata 42 orte/mca/ras/gridengine/ras_gridengine_module.c static int orte_ras_gridengine_allocate(orte_job_t *jdata, opal_list_t *nodes); jdata 63 orte/mca/ras/gridengine/ras_gridengine_module.c static int orte_ras_gridengine_allocate(orte_job_t *jdata, opal_list_t *nodelist) jdata 50 orte/mca/ras/lsf/ras_lsf_module.c static int allocate(orte_job_t *jdata, opal_list_t *nodes); jdata 65 orte/mca/ras/lsf/ras_lsf_module.c static int allocate(orte_job_t *jdata, opal_list_t *nodes) jdata 130 orte/mca/ras/lsf/ras_lsf_module.c if (NULL == jdata->map) { jdata 131 orte/mca/ras/lsf/ras_lsf_module.c jdata->map = OBJ_NEW(orte_job_map_t); jdata 133 orte/mca/ras/lsf/ras_lsf_module.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_SEQ); jdata 134 orte/mca/ras/lsf/ras_lsf_module.c jdata->map->req_mapper = strdup("seq"); // need sequential mapper jdata 136 orte/mca/ras/lsf/ras_lsf_module.c orte_set_attribute(&jdata->attributes, ORTE_JOB_PHYSICAL_CPUIDS, true, NULL, OPAL_BOOL); jdata 83 orte/mca/ras/ras.h typedef int (*orte_ras_base_module_allocate_fn_t)(orte_job_t *jdata, jdata 87 orte/mca/ras/ras.h typedef void (*orte_ras_base_module_dealloc_fn_t)(orte_job_t *jdata, jdata 36 orte/mca/ras/simulator/ras_sim_module.c static int allocate(orte_job_t *jdata, opal_list_t *nodes); jdata 50 orte/mca/ras/simulator/ras_sim_module.c static int allocate(orte_job_t *jdata, opal_list_t *nodes) jdata 67 orte/mca/ras/slurm/ras_slurm_module.c static int orte_ras_slurm_allocate(orte_job_t *jdata, opal_list_t *nodes); jdata 68 orte/mca/ras/slurm/ras_slurm_module.c static void deallocate(orte_job_t *jdata, jdata 88 orte/mca/ras/slurm/ras_slurm_module.c static int dyn_allocate(orte_job_t *jdata); jdata 237 orte/mca/ras/slurm/ras_slurm_module.c static int orte_ras_slurm_allocate(orte_job_t *jdata, opal_list_t *nodes) jdata 271 orte/mca/ras/slurm/ras_slurm_module.c ret = dyn_allocate(jdata); jdata 363 orte/mca/ras/slurm/ras_slurm_module.c static void deallocate(orte_job_t *jdata, jdata 765 orte/mca/ras/slurm/ras_slurm_module.c orte_job_t *jdata; jdata 772 orte/mca/ras/slurm/ras_slurm_module.c jdata = orte_get_job_data_object(jtrk->jobid); jdata 773 orte/mca/ras/slurm/ras_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ALLOC_FAILED); jdata 790 orte/mca/ras/slurm/ras_slurm_module.c orte_job_t *jdata; jdata 825 orte/mca/ras/slurm/ras_slurm_module.c jdata = orte_get_job_data_object(jobid); jdata 859 orte/mca/ras/slurm/ras_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ALLOC_FAILED); jdata 871 orte/mca/ras/slurm/ras_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ALLOC_FAILED); jdata 877 orte/mca/ras/slurm/ras_slurm_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, idx))) { jdata 879 orte/mca/ras/slurm/ras_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ALLOC_FAILED); jdata 896 orte/mca/ras/slurm/ras_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ALLOC_FAILED); jdata 935 orte/mca/ras/slurm/ras_slurm_module.c for (idx=0; idx < jdata->apps->size; idx++) { jdata 936 orte/mca/ras/slurm/ras_slurm_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, idx))) { jdata 938 orte/mca/ras/slurm/ras_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ALLOC_FAILED); jdata 963 orte/mca/ras/slurm/ras_slurm_module.c if (ORTE_SUCCESS != (rc = orte_ras_base_node_insert(&nds, jdata))) { jdata 978 orte/mca/ras/slurm/ras_slurm_module.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_ALLOCATION_COMPLETE); jdata 987 orte/mca/ras/slurm/ras_slurm_module.c static int dyn_allocate(orte_job_t *jdata) jdata 1004 orte/mca/ras/slurm/ras_slurm_module.c jtrk->jobid = jdata->jobid; jdata 1019 orte/mca/ras/slurm/ras_slurm_module.c orte_util_convert_jobid_to_string(&jstring, jdata->jobid); jdata 1045 orte/mca/ras/slurm/ras_slurm_module.c for (i=0; i < jdata->apps->size; i++) { jdata 1046 orte/mca/ras/slurm/ras_slurm_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 44 orte/mca/ras/tm/ras_tm_module.c static int allocate(orte_job_t *jdata, opal_list_t *nodes); jdata 70 orte/mca/ras/tm/ras_tm_module.c static int allocate(orte_job_t *jdata, opal_list_t *nodes) jdata 106 orte/mca/rmaps/base/base.h ORTE_DECLSPEC int orte_rmaps_base_assign_locations(orte_job_t *jdata); jdata 127 orte/mca/rmaps/base/base.h ORTE_DECLSPEC int orte_rmaps_base_set_mapping_policy(orte_job_t *jdata, jdata 134 orte/mca/rmaps/base/base.h ORTE_DECLSPEC void orte_rmaps_base_display_map(orte_job_t *jdata); jdata 42 orte/mca/rmaps/base/rmaps_base_assign_locations.c int orte_rmaps_base_assign_locations(orte_job_t *jdata) jdata 49 orte/mca/rmaps/base/rmaps_base_assign_locations.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 57 orte/mca/rmaps/base/rmaps_base_assign_locations.c jdata->map->req_mapper = strdup(mod->component->mca_component_name); jdata 63 orte/mca/rmaps/base/rmaps_base_assign_locations.c if (ORTE_SUCCESS == (rc = mod->module->assign_locations(jdata))) { jdata 78 orte/mca/rmaps/base/rmaps_base_assign_locations.c orte_rmaps_base_print_mapping(jdata->map->mapping)); jdata 111 orte/mca/rmaps/base/rmaps_base_binding.c static void unbind_procs(orte_job_t *jdata) jdata 116 orte/mca/rmaps/base/rmaps_base_binding.c for (j=0; j < jdata->procs->size; j++) { jdata 117 orte/mca/rmaps/base/rmaps_base_binding.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, j))) { jdata 125 orte/mca/rmaps/base/rmaps_base_binding.c static int bind_generic(orte_job_t *jdata, jdata 143 orte/mca/rmaps/base/rmaps_base_binding.c ORTE_JOBID_PRINT(jdata->jobid), jdata 144 orte/mca/rmaps/base/rmaps_base_binding.c opal_hwloc_base_print_binding(jdata->map->binding)); jdata 146 orte/mca/rmaps/base/rmaps_base_binding.c map = jdata->map; jdata 155 orte/mca/rmaps/base/rmaps_base_binding.c if (proc->name.jobid != jdata->jobid) { jdata 231 orte/mca/rmaps/base/rmaps_base_binding.c !OPAL_BIND_OVERLOAD_ALLOWED(jdata->map->binding)) { jdata 232 orte/mca/rmaps/base/rmaps_base_binding.c if (OPAL_BINDING_POLICY_IS_SET(jdata->map->binding)) { jdata 245 orte/mca/rmaps/base/rmaps_base_binding.c unbind_procs(jdata); jdata 292 orte/mca/rmaps/base/rmaps_base_binding.c static int bind_in_place(orte_job_t *jdata, jdata 313 orte/mca/rmaps/base/rmaps_base_binding.c ORTE_JOBID_PRINT(jdata->jobid), jdata 314 orte/mca/rmaps/base/rmaps_base_binding.c opal_hwloc_base_print_binding(jdata->map->binding)); jdata 316 orte/mca/rmaps/base/rmaps_base_binding.c map = jdata->map; jdata 383 orte/mca/rmaps/base/rmaps_base_binding.c reset_usage(node, jdata->jobid); jdata 391 orte/mca/rmaps/base/rmaps_base_binding.c if (proc->name.jobid != jdata->jobid) { jdata 459 orte/mca/rmaps/base/rmaps_base_binding.c if (!OPAL_BIND_OVERLOAD_ALLOWED(jdata->map->binding)) { jdata 460 orte/mca/rmaps/base/rmaps_base_binding.c if (OPAL_BINDING_POLICY_IS_SET(jdata->map->binding)) { jdata 472 orte/mca/rmaps/base/rmaps_base_binding.c unbind_procs(jdata); jdata 509 orte/mca/rmaps/base/rmaps_base_binding.c static int bind_to_cpuset(orte_job_t *jdata) jdata 526 orte/mca/rmaps/base/rmaps_base_binding.c ORTE_JOBID_PRINT(jdata->jobid), jdata 529 orte/mca/rmaps/base/rmaps_base_binding.c map = jdata->map; jdata 599 orte/mca/rmaps/base/rmaps_base_binding.c if (proc->name.jobid != jdata->jobid) { jdata 602 orte/mca/rmaps/base/rmaps_base_binding.c if (OPAL_BIND_ORDERED_REQUESTED(jdata->map->binding)) { jdata 639 orte/mca/rmaps/base/rmaps_base_binding.c int orte_rmaps_base_compute_bindings(orte_job_t *jdata) jdata 652 orte/mca/rmaps/base/rmaps_base_binding.c ORTE_JOBID_PRINT(jdata->jobid), jdata 653 orte/mca/rmaps/base/rmaps_base_binding.c opal_hwloc_base_print_binding(jdata->map->binding), jdata->map->binding); jdata 655 orte/mca/rmaps/base/rmaps_base_binding.c map = ORTE_GET_MAPPING_POLICY(jdata->map->mapping); jdata 656 orte/mca/rmaps/base/rmaps_base_binding.c bind = OPAL_GET_BINDING_POLICY(jdata->map->binding); jdata 666 orte/mca/rmaps/base/rmaps_base_binding.c if (ORTE_SUCCESS != (rc = bind_to_cpuset(jdata))) { jdata 728 orte/mca/rmaps/base/rmaps_base_binding.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 729 orte/mca/rmaps/base/rmaps_base_binding.c if (ORTE_SUCCESS != (rc = bind_in_place(jdata, HWLOC_OBJ_NODE, 0))) { jdata 748 orte/mca/rmaps/base/rmaps_base_binding.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 749 orte/mca/rmaps/base/rmaps_base_binding.c if (ORTE_SUCCESS != (rc = bind_in_place(jdata, hwb, clvl))) { jdata 763 orte/mca/rmaps/base/rmaps_base_binding.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 765 orte/mca/rmaps/base/rmaps_base_binding.c for (i=0; i < jdata->map->nodes->size; i++) { jdata 766 orte/mca/rmaps/base/rmaps_base_binding.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, i))) { jdata 785 orte/mca/rmaps/base/rmaps_base_binding.c if (!OPAL_BINDING_REQUIRED(jdata->map->binding) || jdata 786 orte/mca/rmaps/base/rmaps_base_binding.c !OPAL_BINDING_POLICY_IS_SET(jdata->map->binding)) { jdata 803 orte/mca/rmaps/base/rmaps_base_binding.c OPAL_BINDING_POLICY_IS_SET(jdata->map->binding)) { jdata 819 orte/mca/rmaps/base/rmaps_base_binding.c if (!OPAL_BINDING_POLICY_IS_SET(jdata->map->binding) && jdata 831 orte/mca/rmaps/base/rmaps_base_binding.c reset_usage(node, jdata->jobid); jdata 858 orte/mca/rmaps/base/rmaps_base_binding.c if (ORTE_SUCCESS != (rc = bind_generic(jdata, node, bind_depth))) { jdata 597 orte/mca/rmaps/base/rmaps_base_frame.c int orte_rmaps_base_set_mapping_policy(orte_job_t *jdata, jdata 687 orte/mca/rmaps/base/rmaps_base_frame.c if (NULL == jdata || NULL == jdata->map) { jdata 690 orte/mca/rmaps/base/rmaps_base_frame.c jdata->map->ppr = strdup(ck); jdata 756 orte/mca/rmaps/base/rmaps_base_frame.c if (NULL == jdata || NULL == jdata->map) { jdata 759 orte/mca/rmaps/base/rmaps_base_frame.c jdata->map->mapping = tmp; jdata 50 orte/mca/rmaps/base/rmaps_base_map_job.c orte_job_t *jdata; jdata 61 orte/mca/rmaps/base/rmaps_base_map_job.c jdata = caddy->jdata; jdata 63 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->state = ORTE_JOB_STATE_MAP; jdata 67 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 71 orte/mca/rmaps/base/rmaps_base_map_job.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_LAUNCH_PROXY, NULL, OPAL_NAME)) { jdata 75 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_JOBID_PRINT(jdata->jobid), jdata 83 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL == jdata->map->ppr && NULL != orte_rmaps_base.ppr) { jdata 84 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->map->ppr = strdup(orte_rmaps_base.ppr); jdata 86 orte/mca/rmaps/base/rmaps_base_map_job.c if (0 == jdata->map->cpus_per_rank) { jdata 87 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->map->cpus_per_rank = orte_rmaps_base.cpus_per_rank; jdata 90 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL != jdata->map->ppr) { jdata 92 orte/mca/rmaps/base/rmaps_base_map_job.c ppx = strtoul(jdata->map->ppr, NULL, 10); jdata 93 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL != strstr(jdata->map->ppr, "node")) { jdata 95 orte/mca/rmaps/base/rmaps_base_map_job.c } else if (NULL != strstr(jdata->map->ppr, "socket")) { jdata 102 orte/mca/rmaps/base/rmaps_base_map_job.c for (i=0; i < jdata->apps->size; i++) { jdata 103 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL != (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 129 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_JOBID_PRINT(jdata->jobid), (int)nprocs); jdata 131 orte/mca/rmaps/base/rmaps_base_map_job.c if (inherit && !jdata->map->display_map) { jdata 132 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->map->display_map = orte_rmaps_base.display_map; jdata 136 orte/mca/rmaps/base/rmaps_base_map_job.c if (!ORTE_MAPPING_POLICY_IS_SET(jdata->map->mapping)) { jdata 140 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->map->mapping = orte_rmaps_base.mapping; jdata 151 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 155 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYHWTHREAD); jdata 159 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYCORE); jdata 166 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYNUMA); jdata 170 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSOCKET); jdata 175 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 182 orte/mca/rmaps/base/rmaps_base_map_job.c if (!(ORTE_MAPPING_SUBSCRIBE_GIVEN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping))) { jdata 184 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_OVERSUBSCRIBE); jdata 186 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_OVERSUBSCRIBE); jdata 188 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_UNSET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_OVERSUBSCRIBE); jdata 189 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_SUBSCRIBE_GIVEN); jdata 194 orte/mca/rmaps/base/rmaps_base_map_job.c if (!(ORTE_MAPPING_LOCAL_GIVEN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping))) { jdata 196 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_USE_LOCAL); jdata 202 orte/mca/rmaps/base/rmaps_base_map_job.c if (!ORTE_RANKING_POLICY_IS_SET(jdata->map->ranking)) { jdata 203 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->map->ranking = orte_rmaps_base.ranking; jdata 209 orte/mca/rmaps/base/rmaps_base_map_job.c if (!OPAL_BINDING_POLICY_IS_SET(jdata->map->binding)) { jdata 216 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->map->binding = opal_hwloc_binding_policy; jdata 217 orte/mca/rmaps/base/rmaps_base_map_job.c } else if (0 < jdata->map->cpus_per_rank) { jdata 223 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_HWTHREAD); jdata 228 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_CORE); jdata 234 orte/mca/rmaps/base/rmaps_base_map_job.c mpol = ORTE_GET_MAPPING_POLICY(jdata->map->mapping); jdata 235 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_MAPPING_GIVEN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 239 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_HWTHREAD); jdata 243 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_CORE); jdata 247 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_L1CACHE); jdata 251 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_L2CACHE); jdata 255 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_L3CACHE); jdata 259 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_SOCKET); jdata 263 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_NUMA); jdata 271 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_HWTHREAD); jdata 276 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_CORE); jdata 282 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_NUMA); jdata 286 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_SOCKET); jdata 291 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_NONE); jdata 300 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_HWTHREAD); jdata 305 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_CORE); jdata 312 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_NUMA); jdata 316 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_SOCKET); jdata 321 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_NONE); jdata 325 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->map->binding |= OPAL_BIND_ALLOW_OVERLOAD; jdata 341 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 362 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->map->req_mapper = strdup(mod->component->mca_component_name); jdata 365 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_SUCCESS == (rc = mod->module->map_job(jdata)) || jdata 375 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 385 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 392 orte/mca/rmaps/base/rmaps_base_map_job.c if (!did_map || 0 == jdata->num_procs || 0 == jdata->map->num_nodes) { jdata 395 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->num_procs, jdata->map->num_nodes); jdata 396 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 403 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED)) { jdata 404 orte/mca/rmaps/base/rmaps_base_map_job.c if (!OPAL_BINDING_POLICY_IS_SET(jdata->map->binding)) { jdata 406 orte/mca/rmaps/base/rmaps_base_map_job.c OPAL_SET_DEFAULT_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_NONE); jdata 413 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_compute_vpids(jdata))) { jdata 415 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 419 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_compute_local_ranks(jdata))) { jdata 421 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 425 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_assign_locations(jdata))) { jdata 427 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 431 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_compute_bindings(jdata))) { jdata 433 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 436 orte/mca/rmaps/base/rmaps_base_map_job.c } else if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_FULLY_DESCRIBED, NULL, OPAL_BOOL)) { jdata 438 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_assign_locations(jdata))) { jdata 440 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 445 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_compute_local_ranks(jdata))) { jdata 447 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 452 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_compute_bindings(jdata))) { jdata 454 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_FAILED); jdata 462 orte/mca/rmaps/base/rmaps_base_map_job.c jdata->offset = orte_total_procs; jdata 464 orte/mca/rmaps/base/rmaps_base_map_job.c orte_total_procs += jdata->num_procs; jdata 467 orte/mca/rmaps/base/rmaps_base_map_job.c if (ORTE_JOBID_INVALID != jdata->originator.jobid) { jdata 468 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL != (parent = orte_get_job_data_object(jdata->originator.jobid))) { jdata 469 orte/mca/rmaps/base/rmaps_base_map_job.c parent->bookmark = jdata->bookmark; jdata 475 orte/mca/rmaps/base/rmaps_base_map_job.c orte_rmaps_base_display_map(jdata); jdata 479 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP_COMPLETE); jdata 483 orte/mca/rmaps/base/rmaps_base_map_job.c for (i=0; i < jdata->map->nodes->size; i++) { jdata 484 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL != (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, i))) { jdata 493 orte/mca/rmaps/base/rmaps_base_map_job.c void orte_rmaps_base_display_map(orte_job_t *jdata) jdata 518 orte/mca/rmaps/base/rmaps_base_map_job.c for (i=0; i < jdata->map->nodes->size; i++) { jdata 519 orte/mca/rmaps/base/rmaps_base_map_job.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, i))) { jdata 551 orte/mca/rmaps/base/rmaps_base_map_job.c node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, 0); jdata 584 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_JOBID_PRINT(jdata->jobid), ORTE_VPID_PRINT(jdata->offset), jdata 585 orte/mca/rmaps/base/rmaps_base_map_job.c (long unsigned)jdata->total_slots_alloc); jdata 586 orte/mca/rmaps/base/rmaps_base_map_job.c opal_dss.print(&output, NULL, jdata->map, ORTE_JOB_MAP); jdata 54 orte/mca/rmaps/base/rmaps_base_ranking.c static int rank_span(orte_job_t *jdata, jdata 70 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 90 orte/mca/rmaps/base/rmaps_base_ranking.c for (n=0; n < jdata->apps->size; n++) { jdata 91 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 97 orte/mca/rmaps/base/rmaps_base_ranking.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 98 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 125 orte/mca/rmaps/base/rmaps_base_ranking.c if (proc->name.jobid != jdata->jobid) { jdata 161 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { jdata 165 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { jdata 172 orte/mca/rmaps/base/rmaps_base_ranking.c jdata->bookmark = node; jdata 184 orte/mca/rmaps/base/rmaps_base_ranking.c static int rank_fill(orte_job_t *jdata, jdata 200 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 212 orte/mca/rmaps/base/rmaps_base_ranking.c for (n=0; n < jdata->apps->size; n++) { jdata 213 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 218 orte/mca/rmaps/base/rmaps_base_ranking.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 219 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 246 orte/mca/rmaps/base/rmaps_base_ranking.c if (proc->name.jobid != jdata->jobid) { jdata 282 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { jdata 286 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { jdata 293 orte/mca/rmaps/base/rmaps_base_ranking.c jdata->bookmark = node; jdata 302 orte/mca/rmaps/base/rmaps_base_ranking.c static int rank_by(orte_job_t *jdata, jdata 318 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_RANKING_SPAN & ORTE_GET_RANKING_DIRECTIVE(jdata->map->ranking)) { jdata 319 orte/mca/rmaps/base/rmaps_base_ranking.c return rank_span(jdata, target, cache_level); jdata 320 orte/mca/rmaps/base/rmaps_base_ranking.c } else if (ORTE_RANKING_FILL & ORTE_GET_RANKING_DIRECTIVE(jdata->map->ranking)) { jdata 321 orte/mca/rmaps/base/rmaps_base_ranking.c return rank_fill(jdata, target, cache_level); jdata 337 orte/mca/rmaps/base/rmaps_base_ranking.c for (n=0, napp=0; napp < jdata->num_apps && n < jdata->apps->size; n++) { jdata 338 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 347 orte/mca/rmaps/base/rmaps_base_ranking.c for (m=0, nn=0; nn < jdata->map->num_nodes && m < jdata->map->nodes->size; m++) { jdata 348 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 413 orte/mca/rmaps/base/rmaps_base_ranking.c if (proc->name.jobid != jdata->jobid) { jdata 457 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { jdata 461 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { jdata 471 orte/mca/rmaps/base/rmaps_base_ranking.c jdata->bookmark = node; jdata 485 orte/mca/rmaps/base/rmaps_base_ranking.c int orte_rmaps_base_compute_vpids(orte_job_t *jdata) jdata 498 orte/mca/rmaps/base/rmaps_base_ranking.c map = jdata->map; jdata 511 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 512 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = rank_by(jdata, HWLOC_OBJ_NODE, 0))) { jdata 526 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 527 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = rank_by(jdata, HWLOC_OBJ_SOCKET, 0))) { jdata 541 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 543 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = rank_by(jdata, target, cache_level))) { jdata 557 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 559 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = rank_by(jdata, target, cache_level))) { jdata 573 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 575 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = rank_by(jdata, target, cache_level))) { jdata 589 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 590 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = rank_by(jdata, HWLOC_OBJ_CORE, 0))) { jdata 604 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 605 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = rank_by(jdata, HWLOC_OBJ_PU, 0))) { jdata 620 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 625 orte/mca/rmaps/base/rmaps_base_ranking.c for (n=0; n < jdata->apps->size; n++) { jdata 626 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 633 orte/mca/rmaps/base/rmaps_base_ranking.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 634 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 642 orte/mca/rmaps/base/rmaps_base_ranking.c if (proc->name.jobid != jdata->jobid) { jdata 654 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { jdata 658 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { jdata 667 orte/mca/rmaps/base/rmaps_base_ranking.c jdata->bookmark = node; jdata 685 orte/mca/rmaps/base/rmaps_base_ranking.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 687 orte/mca/rmaps/base/rmaps_base_ranking.c for (n=0; n < jdata->apps->size; n++) { jdata 688 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 691 orte/mca/rmaps/base/rmaps_base_ranking.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 692 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 701 orte/mca/rmaps/base/rmaps_base_ranking.c if (proc->name.jobid != jdata->jobid) { jdata 716 orte/mca/rmaps/base/rmaps_base_ranking.c jdata->bookmark = node; jdata 719 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL != (pptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->name.vpid))) { jdata 723 orte/mca/rmaps/base/rmaps_base_ranking.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { jdata 736 orte/mca/rmaps/base/rmaps_base_ranking.c int orte_rmaps_base_compute_local_ranks(orte_job_t *jdata) jdata 752 orte/mca/rmaps/base/rmaps_base_ranking.c map = jdata->map; jdata 788 orte/mca/rmaps/base/rmaps_base_ranking.c if (proc->name.jobid == jdata->jobid && jdata 817 orte/mca/rmaps/base/rmaps_base_ranking.c for (i=0; i < jdata->apps->size; i++) { jdata 818 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 823 orte/mca/rmaps/base/rmaps_base_ranking.c for (j=0; j < jdata->procs->size; j++) { jdata 824 orte/mca/rmaps/base/rmaps_base_ranking.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, j))) { jdata 843 orte/mca/rmaps/base/rmaps_base_ranking.c void orte_rmaps_base_update_local_ranks(orte_job_t *jdata, orte_node_t *oldnode, jdata 887 orte/mca/rmaps/base/rmaps_base_ranking.c if (proc->name.jobid != jdata->jobid) { jdata 511 orte/mca/rmaps/base/rmaps_base_support_fns.c orte_proc_t* orte_rmaps_base_setup_proc(orte_job_t *jdata, jdata 520 orte/mca/rmaps/base/rmaps_base_support_fns.c proc->name.jobid = jdata->jobid; jdata 536 orte/mca/rmaps/base/rmaps_base_support_fns.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON)) { jdata 555 orte/mca/rmaps/base/rmaps_base_support_fns.c orte_job_t *jdata) jdata 562 orte/mca/rmaps/base/rmaps_base_support_fns.c if (NULL != jdata->bookmark) { jdata 570 orte/mca/rmaps/base/rmaps_base_support_fns.c if (node->index == jdata->bookmark->index) { jdata 52 orte/mca/rmaps/base/rmaps_private.h ORTE_DECLSPEC orte_proc_t* orte_rmaps_base_setup_proc(orte_job_t *jdata, jdata 57 orte/mca/rmaps/base/rmaps_private.h orte_job_t *jdata); jdata 59 orte/mca/rmaps/base/rmaps_private.h ORTE_DECLSPEC int orte_rmaps_base_compute_vpids(orte_job_t *jdata); jdata 61 orte/mca/rmaps/base/rmaps_private.h ORTE_DECLSPEC int orte_rmaps_base_compute_local_ranks(orte_job_t *jdata); jdata 63 orte/mca/rmaps/base/rmaps_private.h ORTE_DECLSPEC int orte_rmaps_base_compute_bindings(orte_job_t *jdata); jdata 65 orte/mca/rmaps/base/rmaps_private.h ORTE_DECLSPEC void orte_rmaps_base_update_local_ranks(orte_job_t *jdata, orte_node_t *oldnode, jdata 47 orte/mca/rmaps/mindist/rmaps_mindist_module.c static int mindist_map(orte_job_t *jdata); jdata 48 orte/mca/rmaps/mindist/rmaps_mindist_module.c static int assign_locations(orte_job_t *jdata); jdata 58 orte/mca/rmaps/mindist/rmaps_mindist_module.c static int mindist_map(orte_job_t *jdata) jdata 88 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 91 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 94 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (NULL != jdata->map->req_mapper && jdata 95 orte/mca/rmaps/mindist/rmaps_mindist_module.c 0 != strcasecmp(jdata->map->req_mapper, c->mca_component_name)) { jdata 99 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 102 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (ORTE_MAPPING_BYDIST != ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 106 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 125 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (ORTE_MAPPING_SPAN & jdata->map->mapping) { jdata 135 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 138 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (NULL != jdata->map->last_mapper) { jdata 139 orte/mca/rmaps/mindist/rmaps_mindist_module.c free(jdata->map->last_mapper); jdata 141 orte/mca/rmaps/mindist/rmaps_mindist_module.c jdata->map->last_mapper = strdup(c->mca_component_name); jdata 144 orte/mca/rmaps/mindist/rmaps_mindist_module.c jdata->num_procs = 0; jdata 147 orte/mca/rmaps/mindist/rmaps_mindist_module.c for(i=0; i < jdata->apps->size; i++) { jdata 148 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 159 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (0 == app->num_procs && 1 < jdata->num_apps) { jdata 161 orte/mca/rmaps/mindist/rmaps_mindist_module.c true, jdata->num_apps, NULL); jdata 171 orte/mca/rmaps/mindist/rmaps_mindist_module.c jdata->map->mapping, initial_map, false))) { jdata 178 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 192 orte/mca/rmaps/mindist/rmaps_mindist_module.c jdata->bookmark = orte_rmaps_base_get_starting_point(&node_list, jdata); jdata 322 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 330 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 342 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 348 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 368 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, i))) { jdata 385 orte/mca/rmaps/mindist/rmaps_mindist_module.c jdata->map->num_nodes++; jdata 386 orte/mca/rmaps/mindist/rmaps_mindist_module.c opal_pointer_array_add(jdata->map->nodes, node); jdata 399 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 420 orte/mca/rmaps/mindist/rmaps_mindist_module.c jdata->num_procs += app->num_procs; jdata 443 orte/mca/rmaps/mindist/rmaps_mindist_module.c static int assign_locations(orte_job_t *jdata) jdata 455 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (NULL == jdata->map->last_mapper|| jdata 456 orte/mca/rmaps/mindist/rmaps_mindist_module.c 0 != strcasecmp(jdata->map->last_mapper, c->mca_component_name)) { jdata 460 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 466 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 472 orte/mca/rmaps/mindist/rmaps_mindist_module.c for (n=0; n < jdata->apps->size; n++) { jdata 473 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 476 orte/mca/rmaps/mindist/rmaps_mindist_module.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 477 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 494 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 500 orte/mca/rmaps/mindist/rmaps_mindist_module.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 519 orte/mca/rmaps/mindist/rmaps_mindist_module.c if (proc->name.jobid != jdata->jobid) { jdata 35 orte/mca/rmaps/ppr/rmaps_ppr.c static int ppr_mapper(orte_job_t *jdata); jdata 36 orte/mca/rmaps/ppr/rmaps_ppr.c static int assign_locations(orte_job_t *jdata); jdata 71 orte/mca/rmaps/ppr/rmaps_ppr.c static int ppr_mapper(orte_job_t *jdata) jdata 97 orte/mca/rmaps/ppr/rmaps_ppr.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 100 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 103 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL != jdata->map->req_mapper && jdata 104 orte/mca/rmaps/ppr/rmaps_ppr.c 0 != strcasecmp(jdata->map->req_mapper, c->mca_component_name)) { jdata 108 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 111 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == jdata->map->ppr || jdata 112 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_MAPPING_PPR != ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 116 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_JOBID_PRINT(jdata->jobid), jdata 117 orte/mca/rmaps/ppr/rmaps_ppr.c (NULL == jdata->map->ppr) ? "NULL" : jdata->map->ppr, jdata 118 orte/mca/rmaps/ppr/rmaps_ppr.c (ORTE_MAPPING_PPR == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) ? "PPRSET" : "PPR NOTSET"); jdata 124 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_JOBID_PRINT(jdata->jobid), jdata->map->ppr); jdata 127 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL != jdata->map->last_mapper) { jdata 128 orte/mca/rmaps/ppr/rmaps_ppr.c free(jdata->map->last_mapper); jdata 130 orte/mca/rmaps/ppr/rmaps_ppr.c jdata->map->last_mapper = strdup(c->mca_component_name); jdata 137 orte/mca/rmaps/ppr/rmaps_ppr.c ppr_req = opal_argv_split(jdata->map->ppr, ','); jdata 143 orte/mca/rmaps/ppr/rmaps_ppr.c orte_show_help("help-orte-rmaps-ppr.txt", "invalid-ppr", true, jdata->map->ppr); jdata 151 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYNODE); jdata 158 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYHWTHREAD); jdata 164 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYCORE); jdata 172 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSOCKET); jdata 180 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYL1CACHE); jdata 188 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYL2CACHE); jdata 196 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYL3CACHE); jdata 203 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYNUMA); jdata 208 orte/mca/rmaps/ppr/rmaps_ppr.c orte_show_help("help-orte-rmaps-ppr.txt", "unrecognized-ppr-option", true, ck[1], jdata->map->ppr); jdata 228 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_JOBID_PRINT(jdata->jobid), jdata 229 orte/mca/rmaps/ppr/rmaps_ppr.c orte_rmaps_base_print_mapping(jdata->map->mapping)); jdata 235 orte/mca/rmaps/ppr/rmaps_ppr.c for (idx=0; idx < (orte_app_idx_t)jdata->apps->size; idx++) { jdata 236 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, idx))) { jdata 253 orte/mca/rmaps/ppr/rmaps_ppr.c jdata->map->mapping, initial_map, false))) { jdata 261 orte/mca/rmaps/ppr/rmaps_ppr.c jdata->bookmark = orte_rmaps_base_get_starting_point(&node_list, jdata); jdata 280 orte/mca/rmaps/ppr/rmaps_ppr.c opal_pointer_array_add(jdata->map->nodes, node); jdata 281 orte/mca/rmaps/ppr/rmaps_ppr.c jdata->map->num_nodes++; jdata 289 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, idx))) { jdata 310 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, idx))) { jdata 325 orte/mca/rmaps/ppr/rmaps_ppr.c prune(jdata->jobid, idx, node, &level, &nprocs_mapped); jdata 329 orte/mca/rmaps/ppr/rmaps_ppr.c if (!(ORTE_MAPPING_DEBUGGER & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping))) { jdata 343 orte/mca/rmaps/ppr/rmaps_ppr.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 354 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 360 orte/mca/rmaps/ppr/rmaps_ppr.c if (!(ORTE_MAPPING_SUBSCRIBE_GIVEN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping))) { jdata 365 orte/mca/rmaps/ppr/rmaps_ppr.c } else if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 389 orte/mca/rmaps/ppr/rmaps_ppr.c true, app->app, app->num_procs, jdata->map->ppr); jdata 398 orte/mca/rmaps/ppr/rmaps_ppr.c jdata->num_procs += app->num_procs; jdata 618 orte/mca/rmaps/ppr/rmaps_ppr.c static int assign_locations(orte_job_t *jdata) jdata 631 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == jdata->map->last_mapper || jdata 632 orte/mca/rmaps/ppr/rmaps_ppr.c 0 != strcasecmp(jdata->map->last_mapper, c->mca_component_name)) { jdata 636 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_JOBID_PRINT(jdata->jobid), jdata 637 orte/mca/rmaps/ppr/rmaps_ppr.c (NULL == jdata->map->last_mapper) ? "NULL" : jdata->map->last_mapper); jdata 643 orte/mca/rmaps/ppr/rmaps_ppr.c ORTE_JOBID_PRINT(jdata->jobid), jdata->map->ppr, jdata 644 orte/mca/rmaps/ppr/rmaps_ppr.c orte_rmaps_base_print_mapping(jdata->map->mapping)); jdata 647 orte/mca/rmaps/ppr/rmaps_ppr.c if (ORTE_MAPPING_BYNODE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 649 orte/mca/rmaps/ppr/rmaps_ppr.c } else if (ORTE_MAPPING_BYHWTHREAD == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 651 orte/mca/rmaps/ppr/rmaps_ppr.c } else if (ORTE_MAPPING_BYCORE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 653 orte/mca/rmaps/ppr/rmaps_ppr.c } else if (ORTE_MAPPING_BYSOCKET == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 655 orte/mca/rmaps/ppr/rmaps_ppr.c } else if (ORTE_MAPPING_BYL1CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 658 orte/mca/rmaps/ppr/rmaps_ppr.c } else if (ORTE_MAPPING_BYL2CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 661 orte/mca/rmaps/ppr/rmaps_ppr.c } else if (ORTE_MAPPING_BYL3CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 664 orte/mca/rmaps/ppr/rmaps_ppr.c } else if (ORTE_MAPPING_BYNUMA == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 672 orte/mca/rmaps/ppr/rmaps_ppr.c ppr_req = opal_argv_split(jdata->map->ppr, ','); jdata 680 orte/mca/rmaps/ppr/rmaps_ppr.c for (n=0; n < jdata->apps->size; n++) { jdata 681 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 685 orte/mca/rmaps/ppr/rmaps_ppr.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 686 orte/mca/rmaps/ppr/rmaps_ppr.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 700 orte/mca/rmaps/ppr/rmaps_ppr.c if (proc->name.jobid != jdata->jobid) { jdata 723 orte/mca/rmaps/ppr/rmaps_ppr.c if (proc->name.jobid != jdata->jobid) { jdata 54 orte/mca/rmaps/rank_file/rmaps_rank_file.c static int orte_rmaps_rf_map(orte_job_t *jdata); jdata 75 orte/mca/rmaps/rank_file/rmaps_rank_file.c static int orte_rmaps_rf_map(orte_job_t *jdata) jdata 95 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 98 orte/mca/rmaps/rank_file/rmaps_rank_file.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 101 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (NULL != jdata->map->req_mapper && jdata 102 orte/mca/rmaps/rank_file/rmaps_rank_file.c 0 != strcasecmp(jdata->map->req_mapper, c->mca_component_name)) { jdata 106 orte/mca/rmaps/rank_file/rmaps_rank_file.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 113 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (OPAL_BIND_ORDERED_REQUESTED(jdata->map->binding)) { jdata 119 orte/mca/rmaps/rank_file/rmaps_rank_file.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 122 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (NULL != jdata->map->last_mapper) { jdata 123 orte/mca/rmaps/rank_file/rmaps_rank_file.c free(jdata->map->last_mapper); jdata 125 orte/mca/rmaps/rank_file/rmaps_rank_file.c jdata->map->last_mapper = strdup(c->mca_component_name); jdata 128 orte/mca/rmaps/rank_file/rmaps_rank_file.c map = jdata->map; jdata 145 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, 0))) { jdata 156 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (0 == app->num_procs && 1 < jdata->num_apps) { jdata 158 orte/mca/rmaps/rank_file/rmaps_rank_file.c true, jdata->num_apps, NULL); jdata 167 orte/mca/rmaps/rank_file/rmaps_rank_file.c jdata->num_procs = 0; jdata 179 orte/mca/rmaps/rank_file/rmaps_rank_file.c for(i=0; i < jdata->apps->size; i++) { jdata 180 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 293 orte/mca/rmaps/rank_file/rmaps_rank_file.c ++(jdata->map->num_nodes); jdata 295 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, i))) { jdata 302 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 313 orte/mca/rmaps/rank_file/rmaps_rank_file.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 350 orte/mca/rmaps/rank_file/rmaps_rank_file.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, jdata 355 orte/mca/rmaps/rank_file/rmaps_rank_file.c jdata->num_procs++; jdata 378 orte/mca/rmaps/rank_file/rmaps_rank_file.c orte_set_attribute(&jdata->attributes, ORTE_JOB_FULLY_DESCRIBED, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 39 orte/mca/rmaps/resilient/rmaps_resilient.c static int orte_rmaps_resilient_map(orte_job_t *jdata); jdata 40 orte/mca/rmaps/resilient/rmaps_resilient.c static int resilient_assign(orte_job_t *jdata); jdata 62 orte/mca/rmaps/resilient/rmaps_resilient.c static int map_to_ftgrps(orte_job_t *jdata); jdata 67 orte/mca/rmaps/resilient/rmaps_resilient.c static int orte_rmaps_resilient_map(orte_job_t *jdata) jdata 82 orte/mca/rmaps/resilient/rmaps_resilient.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 83 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL != jdata->map->req_mapper && jdata 84 orte/mca/rmaps/resilient/rmaps_resilient.c 0 != strcasecmp(jdata->map->req_mapper, c->mca_component_name)) { jdata 88 orte/mca/rmaps/resilient/rmaps_resilient.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 94 orte/mca/rmaps/resilient/rmaps_resilient.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 97 orte/mca/rmaps/resilient/rmaps_resilient.c } else if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_PROCS_MIGRATING)) { jdata 100 orte/mca/rmaps/resilient/rmaps_resilient.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 106 orte/mca/rmaps/resilient/rmaps_resilient.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 109 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL != jdata->map->last_mapper) { jdata 110 orte/mca/rmaps/resilient/rmaps_resilient.c free(jdata->map->last_mapper); jdata 112 orte/mca/rmaps/resilient/rmaps_resilient.c jdata->map->last_mapper = strdup(c->mca_component_name); jdata 119 orte/mca/rmaps/resilient/rmaps_resilient.c if (ORTE_JOB_STATE_INIT == jdata->state) { jdata 123 orte/mca/rmaps/resilient/rmaps_resilient.c return map_to_ftgrps(jdata); jdata 133 orte/mca/rmaps/resilient/rmaps_resilient.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 136 orte/mca/rmaps/resilient/rmaps_resilient.c for (i=0; i < jdata->procs->size; i++) { jdata 138 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 153 orte/mca/rmaps/resilient/rmaps_resilient.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, proc->app_idx); jdata 183 orte/mca/rmaps/resilient/rmaps_resilient.c jdata->map->mapping, jdata 237 orte/mca/rmaps/resilient/rmaps_resilient.c if (ORTE_SUCCESS != (rc = get_new_node(proc, app, jdata->map, &nd))) { jdata 247 orte/mca/rmaps/resilient/rmaps_resilient.c for (j=0; j < jdata->map->nodes->size; j++) { jdata 248 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL == (nptr = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, j))) { jdata 258 orte/mca/rmaps/resilient/rmaps_resilient.c opal_pointer_array_add(jdata->map->nodes, nd); jdata 274 orte/mca/rmaps/resilient/rmaps_resilient.c orte_rmaps_base_update_local_ranks(jdata, oldnode, nd, proc); jdata 281 orte/mca/rmaps/resilient/rmaps_resilient.c static int resilient_assign(orte_job_t *jdata) jdata 285 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL == jdata->map->last_mapper || jdata 286 orte/mca/rmaps/resilient/rmaps_resilient.c 0 != strcasecmp(jdata->map->last_mapper, c->mca_component_name)) { jdata 290 orte/mca/rmaps/resilient/rmaps_resilient.c ORTE_JOBID_PRINT(jdata->jobid), jdata 291 orte/mca/rmaps/resilient/rmaps_resilient.c (NULL == jdata->map->last_mapper) ? "NULL" : jdata->map->last_mapper); jdata 697 orte/mca/rmaps/resilient/rmaps_resilient.c static int map_to_ftgrps(orte_job_t *jdata) jdata 715 orte/mca/rmaps/resilient/rmaps_resilient.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 718 orte/mca/rmaps/resilient/rmaps_resilient.c jdata->num_procs = 0; jdata 719 orte/mca/rmaps/resilient/rmaps_resilient.c map = jdata->map; jdata 721 orte/mca/rmaps/resilient/rmaps_resilient.c for (i=0; i < jdata->apps->size; i++) { jdata 723 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 848 orte/mca/rmaps/resilient/rmaps_resilient.c if (NULL == orte_rmaps_base_setup_proc(jdata, nd, app->idx)) { jdata 854 orte/mca/rmaps/resilient/rmaps_resilient.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 864 orte/mca/rmaps/resilient/rmaps_resilient.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 877 orte/mca/rmaps/resilient/rmaps_resilient.c jdata->num_procs += app->num_procs; jdata 71 orte/mca/rmaps/rmaps.h typedef int (*orte_rmaps_base_module_map_fn_t)(orte_job_t *jdata); jdata 77 orte/mca/rmaps/rmaps.h typedef int (*orte_rmaps_base_module_assign_loc_fn_t)(orte_job_t *jdata); jdata 46 orte/mca/rmaps/round_robin/rmaps_rr.c static int orte_rmaps_rr_map(orte_job_t *jdata) jdata 61 orte/mca/rmaps/round_robin/rmaps_rr.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 64 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 67 orte/mca/rmaps/round_robin/rmaps_rr.c if (NULL != jdata->map->req_mapper && jdata 68 orte/mca/rmaps/round_robin/rmaps_rr.c 0 != strcasecmp(jdata->map->req_mapper, c->mca_component_name)) { jdata 72 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 75 orte/mca/rmaps/round_robin/rmaps_rr.c if (ORTE_MAPPING_RR < ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 79 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 85 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 88 orte/mca/rmaps/round_robin/rmaps_rr.c if (NULL != jdata->map->last_mapper) { jdata 89 orte/mca/rmaps/round_robin/rmaps_rr.c free(jdata->map->last_mapper); jdata 91 orte/mca/rmaps/round_robin/rmaps_rr.c jdata->map->last_mapper = strdup(c->mca_component_name); jdata 94 orte/mca/rmaps/round_robin/rmaps_rr.c jdata->num_procs = 0; jdata 97 orte/mca/rmaps/round_robin/rmaps_rr.c for(i=0; i < jdata->apps->size; i++) { jdata 100 orte/mca/rmaps/round_robin/rmaps_rr.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 111 orte/mca/rmaps/round_robin/rmaps_rr.c if (0 == app->num_procs && 1 < jdata->num_apps) { jdata 113 orte/mca/rmaps/round_robin/rmaps_rr.c true, jdata->num_apps, NULL); jdata 123 orte/mca/rmaps/round_robin/rmaps_rr.c jdata->map->mapping, initial_map, false))) { jdata 131 orte/mca/rmaps/round_robin/rmaps_rr.c jdata->bookmark = orte_rmaps_base_get_starting_point(&node_list, jdata); jdata 147 orte/mca/rmaps/round_robin/rmaps_rr.c if (ORTE_MAPPING_BYNODE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 148 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_bynode(jdata, app, &node_list, num_slots, jdata 150 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYSLOT == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 151 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byslot(jdata, app, &node_list, num_slots, jdata 153 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYHWTHREAD == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 154 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byobj(jdata, app, &node_list, num_slots, jdata 161 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 162 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byslot(jdata, app, &node_list, num_slots, jdata 165 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYCORE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 166 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byobj(jdata, app, &node_list, num_slots, jdata 173 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 174 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byslot(jdata, app, &node_list, num_slots, jdata 177 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYL1CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 179 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byobj(jdata, app, &node_list, num_slots, app->num_procs, jdata 186 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 187 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byslot(jdata, app, &node_list, num_slots, jdata 190 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYL2CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 192 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byobj(jdata, app, &node_list, num_slots, app->num_procs, jdata 199 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 200 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byslot(jdata, app, &node_list, num_slots, jdata 203 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYL3CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 205 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byobj(jdata, app, &node_list, num_slots, app->num_procs, jdata 212 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 213 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byslot(jdata, app, &node_list, num_slots, jdata 216 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYSOCKET == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 217 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byobj(jdata, app, &node_list, num_slots, jdata 224 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 225 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byslot(jdata, app, &node_list, num_slots, jdata 228 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYNUMA == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 229 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byobj(jdata, app, &node_list, num_slots, jdata 236 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 237 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_byslot(jdata, app, &node_list, num_slots, jdata 244 orte/mca/rmaps/round_robin/rmaps_rr.c orte_rmaps_base_print_mapping(jdata->map->mapping)); jdata 257 orte/mca/rmaps/round_robin/rmaps_rr.c jdata->num_procs += app->num_procs; jdata 279 orte/mca/rmaps/round_robin/rmaps_rr.c static int orte_rmaps_rr_assign_locations(orte_job_t *jdata) jdata 286 orte/mca/rmaps/round_robin/rmaps_rr.c if (NULL == jdata->map->last_mapper || jdata 287 orte/mca/rmaps/round_robin/rmaps_rr.c 0 != strcasecmp(jdata->map->last_mapper, c->mca_component_name)) { jdata 291 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 297 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 301 orte/mca/rmaps/round_robin/rmaps_rr.c if (ORTE_MAPPING_BYNODE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping) || jdata 302 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_MAPPING_BYSLOT == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 303 orte/mca/rmaps/round_robin/rmaps_rr.c return orte_rmaps_rr_assign_root_level(jdata); jdata 307 orte/mca/rmaps/round_robin/rmaps_rr.c if (ORTE_MAPPING_BYHWTHREAD == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 308 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_byobj(jdata, HWLOC_OBJ_PU, 0); jdata 314 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 315 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_root_level(jdata); jdata 317 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYCORE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 318 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_byobj(jdata, HWLOC_OBJ_CORE, 0); jdata 324 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 325 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_root_level(jdata); jdata 327 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYL1CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 329 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_byobj(jdata, target, cache_level); jdata 335 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 336 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_root_level(jdata); jdata 338 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYL2CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 340 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_byobj(jdata, target, cache_level); jdata 346 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 347 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_root_level(jdata); jdata 349 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYL3CACHE == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 351 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_byobj(jdata, target, cache_level); jdata 357 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 358 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_root_level(jdata); jdata 360 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYSOCKET == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 361 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_byobj(jdata, HWLOC_OBJ_SOCKET, 0); jdata 367 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 368 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_root_level(jdata); jdata 370 orte/mca/rmaps/round_robin/rmaps_rr.c } else if (ORTE_MAPPING_BYNUMA == ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 371 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_byobj(jdata, HWLOC_OBJ_NODE, 0); jdata 377 orte/mca/rmaps/round_robin/rmaps_rr.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYSLOT); jdata 378 orte/mca/rmaps/round_robin/rmaps_rr.c rc = orte_rmaps_rr_assign_root_level(jdata); jdata 384 orte/mca/rmaps/round_robin/rmaps_rr.c orte_rmaps_base_print_mapping(jdata->map->mapping)); jdata 40 orte/mca/rmaps/round_robin/rmaps_rr.h ORTE_MODULE_DECLSPEC int orte_rmaps_rr_bynode(orte_job_t *jdata, jdata 45 orte/mca/rmaps/round_robin/rmaps_rr.h ORTE_MODULE_DECLSPEC int orte_rmaps_rr_byslot(orte_job_t *jdata, jdata 51 orte/mca/rmaps/round_robin/rmaps_rr.h ORTE_MODULE_DECLSPEC int orte_rmaps_rr_byobj(orte_job_t *jdata, orte_app_context_t *app, jdata 57 orte/mca/rmaps/round_robin/rmaps_rr.h ORTE_MODULE_DECLSPEC int orte_rmaps_rr_assign_root_level(orte_job_t *jdata); jdata 59 orte/mca/rmaps/round_robin/rmaps_rr.h ORTE_MODULE_DECLSPEC int orte_rmaps_rr_assign_byobj(orte_job_t *jdata, jdata 40 orte/mca/rmaps/round_robin/rmaps_rr_assign.c int orte_rmaps_rr_assign_root_level(orte_job_t *jdata) jdata 49 orte/mca/rmaps/round_robin/rmaps_rr_assign.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 51 orte/mca/rmaps/round_robin/rmaps_rr_assign.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 52 orte/mca/rmaps/round_robin/rmaps_rr_assign.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 70 orte/mca/rmaps/round_robin/rmaps_rr_assign.c if (proc->name.jobid != jdata->jobid) { jdata 86 orte/mca/rmaps/round_robin/rmaps_rr_assign.c int orte_rmaps_rr_assign_byobj(orte_job_t *jdata, jdata 100 orte/mca/rmaps/round_robin/rmaps_rr_assign.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 107 orte/mca/rmaps/round_robin/rmaps_rr_assign.c for (n=0; n < jdata->apps->size; n++) { jdata 108 orte/mca/rmaps/round_robin/rmaps_rr_assign.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 111 orte/mca/rmaps/round_robin/rmaps_rr_assign.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 112 orte/mca/rmaps/round_robin/rmaps_rr_assign.c if (NULL == (node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m))) { jdata 131 orte/mca/rmaps/round_robin/rmaps_rr_assign.c if (ORTE_JOBID_INVALID != jdata->originator.jobid) { jdata 132 orte/mca/rmaps/round_robin/rmaps_rr_assign.c start = (jdata->bkmark_obj + 1) % nobjs; jdata 142 orte/mca/rmaps/round_robin/rmaps_rr_assign.c if (proc->name.jobid != jdata->jobid) { jdata 40 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c int orte_rmaps_rr_byslot(orte_job_t *jdata, jdata 56 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_JOBID_PRINT(jdata->jobid), (int)num_slots, (unsigned long)num_procs); jdata 60 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 112 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c opal_pointer_array_add(jdata->map->nodes, node); jdata 113 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ++(jdata->map->num_nodes); jdata 115 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, app->idx))) { jdata 130 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 164 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c opal_pointer_array_add(jdata->map->nodes, node); jdata 165 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ++(jdata->map->num_nodes); jdata 187 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, app->idx))) { jdata 201 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 207 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (!(ORTE_MAPPING_SUBSCRIBE_GIVEN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping))) { jdata 212 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c } else if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 229 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c int orte_rmaps_rr_bynode(orte_job_t *jdata, jdata 247 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_JOBID_PRINT(jdata->jobid), (int)app->idx, jdata 252 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 312 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c opal_pointer_array_add(jdata->map->nodes, node); jdata 313 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ++(jdata->map->num_nodes); jdata 375 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, app->idx))) { jdata 389 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 395 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (!(ORTE_MAPPING_SUBSCRIBE_GIVEN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping))) { jdata 400 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c } else if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 429 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, app->idx))) { jdata 442 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 454 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c static int byobj_span(orte_job_t *jdata, jdata 465 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c int orte_rmaps_rr_byobj(orte_job_t *jdata, jdata 495 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (ORTE_MAPPING_SPAN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 496 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c return byobj_span(jdata, app, node_list, num_slots, jdata 503 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_JOBID_PRINT(jdata->jobid), jdata 508 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 543 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (ORTE_JOBID_INVALID != jdata->originator.jobid) { jdata 544 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c start = (jdata->bkmark_obj + 1) % nobjs; jdata 580 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c opal_pointer_array_add(jdata->map->nodes, node); jdata 581 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ++(jdata->map->num_nodes); jdata 602 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, app->idx))) { jdata 619 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 625 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (!(ORTE_MAPPING_SUBSCRIBE_GIVEN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping))) { jdata 630 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c } else if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 655 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c static int byobj_span(orte_job_t *jdata, jdata 672 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_JOBID_PRINT(jdata->jobid), jdata 677 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 728 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c opal_pointer_array_add(jdata->map->nodes, node); jdata 729 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ++(jdata->map->num_nodes); jdata 768 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c if (NULL == (proc = orte_rmaps_base_setup_proc(jdata, node, app->idx))) { jdata 775 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c jdata->bookmark = node; jdata 785 orte/mca/rmaps/round_robin/rmaps_rr_mappers.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 53 orte/mca/rmaps/seq/rmaps_seq.c static int orte_rmaps_seq_map(orte_job_t *jdata); jdata 92 orte/mca/rmaps/seq/rmaps_seq.c static int orte_rmaps_seq_map(orte_job_t *jdata) jdata 115 orte/mca/rmaps/seq/rmaps_seq.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 121 orte/mca/rmaps/seq/rmaps_seq.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 124 orte/mca/rmaps/seq/rmaps_seq.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 127 orte/mca/rmaps/seq/rmaps_seq.c if (NULL != jdata->map->req_mapper) { jdata 128 orte/mca/rmaps/seq/rmaps_seq.c if (0 != strcasecmp(jdata->map->req_mapper, c->mca_component_name)) { jdata 132 orte/mca/rmaps/seq/rmaps_seq.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 138 orte/mca/rmaps/seq/rmaps_seq.c if (ORTE_MAPPING_SEQ != ORTE_GET_MAPPING_POLICY(jdata->map->mapping)) { jdata 142 orte/mca/rmaps/seq/rmaps_seq.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 149 orte/mca/rmaps/seq/rmaps_seq.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 152 orte/mca/rmaps/seq/rmaps_seq.c if (NULL != jdata->map->last_mapper) { jdata 153 orte/mca/rmaps/seq/rmaps_seq.c free(jdata->map->last_mapper); jdata 155 orte/mca/rmaps/seq/rmaps_seq.c jdata->map->last_mapper = strdup(c->mca_component_name); jdata 158 orte/mca/rmaps/seq/rmaps_seq.c map = jdata->map; jdata 211 orte/mca/rmaps/seq/rmaps_seq.c jdata->num_procs = 0; jdata 217 orte/mca/rmaps/seq/rmaps_seq.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_PHYSICAL_CPUIDS, NULL, OPAL_BOOL)) { jdata 235 orte/mca/rmaps/seq/rmaps_seq.c for(i=0; i < jdata->apps->size; i++) { jdata 236 orte/mca/rmaps/seq/rmaps_seq.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 398 orte/mca/rmaps/seq/rmaps_seq.c jdata->map->num_nodes++; jdata 401 orte/mca/rmaps/seq/rmaps_seq.c proc = orte_rmaps_base_setup_proc(jdata, node, i); jdata 404 orte/mca/rmaps/seq/rmaps_seq.c if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 415 orte/mca/rmaps/seq/rmaps_seq.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_OVERSUBSCRIBED); jdata 421 orte/mca/rmaps/seq/rmaps_seq.c if (!(ORTE_MAPPING_SUBSCRIBE_GIVEN & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping))) { jdata 426 orte/mca/rmaps/seq/rmaps_seq.c } else if (ORTE_MAPPING_NO_OVERSUBSCRIBE & ORTE_GET_MAPPING_DIRECTIVE(jdata->map->mapping)) { jdata 481 orte/mca/rmaps/seq/rmaps_seq.c OPAL_SET_BINDING_POLICY(jdata->map->binding, OPAL_BIND_TO_CPUSET); jdata 483 orte/mca/rmaps/seq/rmaps_seq.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_BYUSER); jdata 484 orte/mca/rmaps/seq/rmaps_seq.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_GIVEN); jdata 501 orte/mca/rmaps/seq/rmaps_seq.c if (ORTE_SUCCESS != (rc = opal_pointer_array_set_item(jdata->procs, proc->name.vpid, proc))) { jdata 510 orte/mca/rmaps/seq/rmaps_seq.c jdata->num_procs += app->num_procs; jdata 522 orte/mca/rmaps/seq/rmaps_seq.c orte_set_attribute(&jdata->attributes, ORTE_JOB_FULLY_DESCRIBED, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 93 orte/mca/routed/base/routed_base_fns.c orte_job_t *jdata; jdata 100 orte/mca/routed/base/routed_base_fns.c if (NULL == (jdata = orte_get_job_data_object(job))) { jdata 127 orte/mca/routed/base/routed_base_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, vpid))) { jdata 284 orte/mca/routed/direct/routed_direct.c orte_job_t *jdata; jdata 301 orte/mca/routed/direct/routed_direct.c if (NULL == (jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid))) { jdata 305 orte/mca/routed/direct/routed_direct.c for (i=1; i < jdata->procs->size; i++) { jdata 306 orte/mca/routed/direct/routed_direct.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 65 orte/mca/rtc/base/base.h ORTE_DECLSPEC void orte_rtc_base_assign(orte_job_t *jdata); jdata 66 orte/mca/rtc/base/base.h ORTE_DECLSPEC void orte_rtc_base_set(orte_job_t *jdata, orte_proc_t *proc, jdata 21 orte/mca/rtc/base/rtc_base_stubs.c void orte_rtc_base_assign(orte_job_t *jdata) jdata 28 orte/mca/rtc/base/rtc_base_stubs.c active->module->assign(jdata); jdata 33 orte/mca/rtc/base/rtc_base_stubs.c void orte_rtc_base_set(orte_job_t *jdata, orte_proc_t *proc, jdata 41 orte/mca/rtc/base/rtc_base_stubs.c active->module->set(jdata, proc, environ_copy, error_fd); jdata 55 orte/mca/rtc/hwloc/rtc_hwloc.c static void assign(orte_job_t *jdata); jdata 56 orte/mca/rtc/hwloc/rtc_hwloc.c static void set(orte_job_t *jdata, jdata 208 orte/mca/rtc/hwloc/rtc_hwloc.c static void assign(orte_job_t *jdata) jdata 221 orte/mca/rtc/hwloc/rtc_hwloc.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_INFO_CACHE, (void**)&cache, OPAL_PTR) || jdata 224 orte/mca/rtc/hwloc/rtc_hwloc.c orte_set_attribute(&jdata->attributes, ORTE_JOB_INFO_CACHE, ORTE_ATTR_LOCAL, cache, OPAL_PTR); jdata 47 orte/mca/rtc/rtc.h typedef void (*orte_rtc_base_module_assign_fn_t)(orte_job_t *jdata); jdata 57 orte/mca/rtc/rtc.h typedef void (*orte_rtc_base_module_set_fn_t)(orte_job_t *jdata, jdata 73 orte/mca/schizo/base/base.h ORTE_DECLSPEC int orte_schizo_base_setup_fork(orte_job_t *jdata, jdata 111 orte/mca/schizo/base/schizo_base_stubs.c int orte_schizo_base_setup_fork(orte_job_t *jdata, jdata 119 orte/mca/schizo/base/schizo_base_stubs.c rc = mod->module->setup_fork(jdata, context); jdata 129 orte/mca/schizo/base/schizo_base_stubs.c int orte_schizo_base_setup_child(orte_job_t *jdata, jdata 139 orte/mca/schizo/base/schizo_base_stubs.c rc = mod->module->setup_child(jdata, child, app, env); jdata 61 orte/mca/schizo/ompi/schizo_ompi.c static int setup_fork(orte_job_t *jdata, jdata 799 orte/mca/schizo/ompi/schizo_ompi.c static int setup_fork(orte_job_t *jdata, jdata 819 orte/mca/schizo/ompi/schizo_ompi.c if (NULL == jdata->personality) { jdata 825 orte/mca/schizo/ompi/schizo_ompi.c for (i=0; NULL != jdata->personality[i]; i++) { jdata 826 orte/mca/schizo/ompi/schizo_ompi.c if (0 == strcmp(jdata->personality[i], "ompi")) { jdata 874 orte/mca/schizo/ompi/schizo_ompi.c tmp_app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, 0); jdata 929 orte/mca/schizo/ompi/schizo_ompi.c opal_asprintf(¶m, "%ld", (long)jdata->total_slots_alloc); jdata 934 orte/mca/schizo/ompi/schizo_ompi.c opal_asprintf(¶m, "%ld", (long)(jdata->map->num_nodes)); jdata 978 orte/mca/schizo/ompi/schizo_ompi.c if (OPAL_BIND_TO_NONE != OPAL_GET_BINDING_POLICY(jdata->map->binding)) { jdata 996 orte/mca/schizo/ompi/schizo_ompi.c opal_asprintf(¶m, "%ld", (long)jdata->num_procs); jdata 1017 orte/mca/schizo/ompi/schizo_ompi.c opal_asprintf(¶m, "%ld", (long)jdata->num_local_procs); jdata 1031 orte/mca/schizo/ompi/schizo_ompi.c opal_asprintf(&num_app_ctx, "%lu", (unsigned long)jdata->num_apps); jdata 1036 orte/mca/schizo/ompi/schizo_ompi.c for (i=0; i < jdata->apps->size; i++) { jdata 1037 orte/mca/schizo/ompi/schizo_ompi.c if (NULL == (tmp_app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 1060 orte/mca/schizo/ompi/schizo_ompi.c OPAL_LIST_FOREACH(attr, &jdata->attributes, orte_attribute_t) { jdata 1185 orte/mca/schizo/ompi/schizo_ompi.c static int setup_child(orte_job_t *jdata, jdata 1200 orte/mca/schizo/ompi/schizo_ompi.c if (NULL == jdata->personality) { jdata 1206 orte/mca/schizo/ompi/schizo_ompi.c for (i=0; NULL != jdata->personality[i]; i++) { jdata 1207 orte/mca/schizo/ompi/schizo_ompi.c if (0 == strcmp(jdata->personality[i], "ompi")) { jdata 1306 orte/mca/schizo/ompi/schizo_ompi.c if (!ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_FORWARD_OUTPUT)) { jdata 84 orte/mca/schizo/schizo.h typedef int (*orte_schizo_base_module_setup_fork_fn_t)(orte_job_t *jdata, jdata 89 orte/mca/schizo/schizo.h typedef int (*orte_schizo_base_module_setup_child_fn_t)(orte_job_t *jdata, jdata 231 orte/mca/snapc/full/snapc_full_global.c orte_job_t *jdata = NULL; jdata 255 orte/mca/snapc/full/snapc_full_global.c if (NULL == (jdata = orte_get_job_data_object(current_global_jobid))) { jdata 260 orte/mca/snapc/full/snapc_full_global.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RESTART)) { jdata 589 orte/mca/snapc/full/snapc_full_global.c orte_job_t *jdata = NULL; jdata 597 orte/mca/snapc/full/snapc_full_global.c if (NULL == (jdata = orte_get_job_data_object(current_global_jobid))) { jdata 604 orte/mca/snapc/full/snapc_full_global.c map = jdata->map; jdata 684 orte/mca/snapc/full/snapc_full_global.c orte_job_t *jdata = NULL; jdata 693 orte/mca/snapc/full/snapc_full_global.c if (NULL == (jdata = orte_get_job_data_object(current_global_jobid))) { jdata 745 orte/mca/snapc/full/snapc_full_global.c map = jdata->map; jdata 721 orte/mca/sstore/central/sstore_central_global.c orte_job_t *jdata = NULL; jdata 748 orte/mca/sstore/central/sstore_central_global.c jdata = orte_get_job_data_object(handle_info->jobid); jdata 749 orte/mca/sstore/central/sstore_central_global.c handle_info->num_procs_total = (int)jdata->num_procs; jdata 922 orte/mca/sstore/stage/sstore_stage_global.c orte_job_t *jdata = NULL; jdata 966 orte/mca/sstore/stage/sstore_stage_global.c jdata = orte_get_job_data_object(handle_info->jobid); jdata 967 orte/mca/sstore/stage/sstore_stage_global.c handle_info->num_procs_total = (int)jdata->num_procs; jdata 48 orte/mca/state/base/state_base_fns.c void orte_state_base_activate_job_state(orte_job_t *jdata, jdata 70 orte/mca/state/base/state_base_fns.c (NULL == jdata) ? "NULL" : ORTE_JOBID_PRINT(jdata->jobid), jdata 76 orte/mca/state/base/state_base_fns.c (NULL == jdata) ? "ALL" : ORTE_JOBID_PRINT(jdata->jobid), jdata 81 orte/mca/state/base/state_base_fns.c if (NULL != jdata) { jdata 82 orte/mca/state/base/state_base_fns.c caddy->jdata = jdata; jdata 84 orte/mca/state/base/state_base_fns.c OBJ_RETAIN(jdata); jdata 108 orte/mca/state/base/state_base_fns.c if (NULL != jdata) { jdata 109 orte/mca/state/base/state_base_fns.c caddy->jdata = jdata; jdata 111 orte/mca/state/base/state_base_fns.c OBJ_RETAIN(jdata); jdata 116 orte/mca/state/base/state_base_fns.c (NULL == jdata) ? "NULL" : ORTE_JOBID_PRINT(jdata->jobid), jdata 431 orte/mca/state/base/state_base_fns.c orte_job_t *jdata = state->jdata; jdata 434 orte/mca/state/base/state_base_fns.c if (0 == jdata->num_daemons_reported % 100 || jdata 435 orte/mca/state/base/state_base_fns.c jdata->num_daemons_reported == orte_process_info.num_procs) { jdata 436 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_REPORT_PROGRESS); jdata 445 orte/mca/state/base/state_base_fns.c orte_job_t *jdata; jdata 448 orte/mca/state/base/state_base_fns.c jdata = caddy->jdata; jdata 453 orte/mca/state/base/state_base_fns.c (NULL == jdata) ? "NULL" : ORTE_JOBID_PRINT(jdata->jobid))); jdata 456 orte/mca/state/base/state_base_fns.c jdata->state = ORTE_JOB_STATE_NOTIFIED; jdata 458 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_TERMINATED); jdata 465 orte/mca/state/base/state_base_fns.c orte_job_t *jdata; jdata 468 orte/mca/state/base/state_base_fns.c jdata = caddy->jdata; jdata 471 orte/mca/state/base/state_base_fns.c (int)jdata->num_daemons_reported, (int)orte_process_info.num_procs, jdata 472 orte/mca/state/base/state_base_fns.c (int)jdata->num_launched, (int)jdata->num_procs); jdata 633 orte/mca/state/base/state_base_fns.c orte_job_t *jdata; jdata 649 orte/mca/state/base/state_base_fns.c if (NULL == (jdata = orte_get_job_data_object(proc->jobid))) { jdata 653 orte/mca/state/base/state_base_fns.c pdata = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); jdata 660 orte/mca/state/base/state_base_fns.c jdata->num_launched++; jdata 661 orte/mca/state/base/state_base_fns.c if (jdata->num_launched == jdata->num_procs) { jdata 662 orte/mca/state/base/state_base_fns.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON)) { jdata 663 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_READY_FOR_DEBUGGERS); jdata 665 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_RUNNING); jdata 673 orte/mca/state/base/state_base_fns.c jdata->num_reported++; jdata 674 orte/mca/state/base/state_base_fns.c if (jdata->num_reported == jdata->num_procs) { jdata 675 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_REGISTERED); jdata 737 orte/mca/state/base/state_base_fns.c jdata->num_terminated++; jdata 738 orte/mca/state/base/state_base_fns.c if (jdata->num_terminated == jdata->num_procs) { jdata 741 orte/mca/state/base/state_base_fns.c orte_state_base_check_fds(jdata); jdata 746 orte/mca/state/base/state_base_fns.c target.jobid = jdata->jobid; jdata 750 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_TERMINATED); jdata 754 orte/mca/state/base/state_base_fns.c parent.jobid = jdata->jobid; jdata 767 orte/mca/state/base/state_base_fns.c orte_job_t *jdata; jdata 782 orte/mca/state/base/state_base_fns.c jdata = caddy->jdata; jdata 787 orte/mca/state/base/state_base_fns.c (NULL == jdata) ? "NULL" : ORTE_JOBID_PRINT(jdata->jobid)); jdata 789 orte/mca/state/base/state_base_fns.c if (NULL == jdata || jdata->jobid == ORTE_PROC_MY_NAME->jobid) { jdata 799 orte/mca/state/base/state_base_fns.c if (jdata->state < ORTE_JOB_STATE_UNTERMINATED) { jdata 800 orte/mca/state/base/state_base_fns.c jdata->state = ORTE_JOB_STATE_TERMINATED; jdata 806 orte/mca/state/base/state_base_fns.c orte_iof.complete(jdata); jdata 811 orte/mca/state/base/state_base_fns.c opal_pmix.server_deregister_nspace(jdata->jobid, NULL, NULL); jdata 815 orte/mca/state/base/state_base_fns.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_NUM_NONZERO_EXIT, (void**)&i32ptr, OPAL_INT32) && !orte_abort_non_zero_exit) { jdata 816 orte/mca/state/base/state_base_fns.c if (!orte_report_child_jobs_separately || 1 == ORTE_LOCAL_JOBID(jdata->jobid)) { jdata 823 orte/mca/state/base/state_base_fns.c (1 == ORTE_LOCAL_JOBID(jdata->jobid)) ? "the primary" : "child", jdata 824 orte/mca/state/base/state_base_fns.c (1 == ORTE_LOCAL_JOBID(jdata->jobid)) ? "" : ORTE_LOCAL_JOBID_PRINT(jdata->jobid), jdata 832 orte/mca/state/base/state_base_fns.c ORTE_JOBID_PRINT(jdata->jobid), jdata 833 orte/mca/state/base/state_base_fns.c orte_job_state_to_str(jdata->state))); jdata 838 orte/mca/state/base/state_base_fns.c if (NULL != jdata && jdata 839 orte/mca/state/base/state_base_fns.c (orte_get_attribute(&jdata->attributes, ORTE_JOB_CONTINUOUS_OP, NULL, OPAL_BOOL) || jdata 840 orte/mca/state/base/state_base_fns.c ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_RECOVERABLE))) { jdata 855 orte/mca/state/base/state_base_fns.c if (jdata == NULL || jdata->jobid == ORTE_PROC_MY_NAME->jobid) { jdata 861 orte/mca/state/base/state_base_fns.c if (NULL == jdata) { jdata 862 orte/mca/state/base/state_base_fns.c jdata = orte_get_job_data_object(ORTE_PROC_MY_NAME->jobid); jdata 864 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DAEMONS_TERMINATED); jdata 880 orte/mca/state/base/state_base_fns.c if (NULL != jdata->map && jdata->state == ORTE_JOB_STATE_TERMINATED) { jdata 881 orte/mca/state/base/state_base_fns.c map = jdata->map; jdata 889 orte/mca/state/base/state_base_fns.c ORTE_JOBID_PRINT(jdata->jobid), node->name)); jdata 894 orte/mca/state/base/state_base_fns.c if (proc->name.jobid != jdata->jobid) { jdata 915 orte/mca/state/base/state_base_fns.c jdata->map = NULL; jdata 941 orte/mca/state/base/state_base_fns.c if (NULL != jdata && job->jobid == jdata->jobid) { jdata 942 orte/mca/state/base/state_base_fns.c if (jdata->state == ORTE_JOB_STATE_TERMINATED) { jdata 946 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_NOTIFY_COMPLETED); jdata 948 orte/mca/state/base/state_base_fns.c } else if (jdata->state == ORTE_JOB_STATE_KILLED_BY_CMD || jdata 949 orte/mca/state/base/state_base_fns.c jdata->state == ORTE_JOB_STATE_NOTIFIED) { jdata 958 orte/mca/state/base/state_base_fns.c if (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON)) { jdata 960 orte/mca/state/base/state_base_fns.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DEBUGGER_DETACH); jdata 962 orte/mca/state/base/state_base_fns.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, NULL); jdata 963 orte/mca/state/base/state_base_fns.c OBJ_RELEASE(jdata); jdata 993 orte/mca/state/base/state_base_fns.c (NULL == jdata) ? "UNKNOWN" : orte_job_state_to_str(jdata->state) )); jdata 1033 orte/mca/state/base/state_base_fns.c void orte_state_base_check_fds(orte_job_t *jdata) jdata 1122 orte/mca/state/base/state_base_fns.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), cnt, ORTE_LOCAL_JOBID(jdata->jobid), result); jdata 101 orte/mca/state/base/state_base_frame.c caddy->jdata = NULL; jdata 106 orte/mca/state/base/state_base_frame.c if (NULL != caddy->jdata) { jdata 107 orte/mca/state/base/state_base_frame.c OBJ_RELEASE(caddy->jdata); jdata 39 orte/mca/state/base/state_private.h ORTE_DECLSPEC void orte_state_base_activate_job_state(orte_job_t *jdata, jdata 80 orte/mca/state/base/state_private.h ORTE_DECLSPEC void orte_state_base_check_fds(orte_job_t *jdata); jdata 341 orte/mca/state/hnp/state_hnp.c orte_job_t *jdata = caddy->jdata; jdata 345 orte/mca/state/hnp/state_hnp.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_NOTIFY_COMPLETION, NULL, OPAL_BOOL)) { jdata 349 orte/mca/state/hnp/state_hnp.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_LAUNCH_PROXY, (void**)&npptr, OPAL_NAME)) { jdata 351 orte/mca/state/hnp/state_hnp.c target.jobid = jdata->jobid; jdata 355 orte/mca/state/hnp/state_hnp.c target.jobid = jdata->jobid; jdata 360 orte/mca/state/hnp/state_hnp.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_NOTIFIED); jdata 202 orte/mca/state/novm/state_novm.c orte_job_t *jdata; jdata 209 orte/mca/state/novm/state_novm.c jdata = state->jdata; jdata 211 orte/mca/state/novm/state_novm.c jdata->state = ORTE_JOB_STATE_ALLOCATION_COMPLETE; jdata 250 orte/mca/state/novm/state_novm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_MAP); jdata 261 orte/mca/state/novm/state_novm.c orte_job_t *jdata; jdata 264 orte/mca/state/novm/state_novm.c jdata = state->jdata; jdata 266 orte/mca/state/novm/state_novm.c jdata->state = ORTE_JOB_STATE_MAP_COMPLETE; jdata 268 orte/mca/state/novm/state_novm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_LAUNCH_DAEMONS); jdata 277 orte/mca/state/novm/state_novm.c orte_job_t *jdata; jdata 280 orte/mca/state/novm/state_novm.c jdata = state->jdata; jdata 285 orte/mca/state/novm/state_novm.c jdata->state = ORTE_JOB_STATE_VM_READY; jdata 286 orte/mca/state/novm/state_novm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_SYSTEM_PREP); jdata 68 orte/mca/state/orted/state_orted.c static int pack_state_update(opal_buffer_t *buf, orte_job_t *jdata); jdata 176 orte/mca/state/orted/state_orted.c ORTE_JOBID_PRINT(caddy->jdata->jobid))); jdata 187 orte/mca/state/orted/state_orted.c if (ORTE_SUCCESS != (rc = opal_dss.pack(alert, &caddy->jdata->jobid, 1, ORTE_JOBID))) { jdata 197 orte/mca/state/orted/state_orted.c if (child->name.jobid == caddy->jdata->jobid) { jdata 259 orte/mca/state/orted/state_orted.c orte_job_t *jdata; jdata 280 orte/mca/state/orted/state_orted.c if (NULL == (jdata = orte_get_job_data_object(proc->jobid))) { jdata 284 orte/mca/state/orted/state_orted.c pdata = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); jdata 289 orte/mca/state/orted/state_orted.c jdata->num_launched++; jdata 290 orte/mca/state/orted/state_orted.c if (jdata->num_launched == jdata->num_local_procs) { jdata 295 orte/mca/state/orted/state_orted.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_LOCAL_LAUNCH_COMPLETE); jdata 301 orte/mca/state/orted/state_orted.c jdata->num_reported++; jdata 302 orte/mca/state/orted/state_orted.c if (jdata->num_reported == jdata->num_local_procs) { jdata 376 orte/mca/state/orted/state_orted.c jdata->num_terminated++; jdata 412 orte/mca/state/orted/state_orted.c if (jdata->num_terminated == jdata->num_local_procs && jdata 413 orte/mca/state/orted/state_orted.c !orte_get_attribute(&jdata->attributes, ORTE_JOB_TERM_NOTIFIED, NULL, OPAL_BOOL)) { jdata 422 orte/mca/state/orted/state_orted.c if (ORTE_SUCCESS != (rc = pack_state_update(alert, jdata))) { jdata 429 orte/mca/state/orted/state_orted.c ORTE_JOBID_PRINT(jdata->jobid))); jdata 436 orte/mca/state/orted/state_orted.c orte_set_attribute(&jdata->attributes, ORTE_JOB_TERM_NOTIFIED, ORTE_ATTR_LOCAL, NULL, OPAL_BOOL); jdata 443 orte/mca/state/orted/state_orted.c if (pptr->name.jobid == jdata->jobid) { jdata 451 orte/mca/state/orted/state_orted.c orte_iof.complete(jdata); jdata 456 orte/mca/state/orted/state_orted.c opal_pmix.server_deregister_nspace(jdata->jobid, NULL, NULL); jdata 460 orte/mca/state/orted/state_orted.c if (NULL != jdata->map) { jdata 461 orte/mca/state/orted/state_orted.c map = jdata->map; jdata 474 orte/mca/state/orted/state_orted.c if (pptr->name.jobid != jdata->jobid) { jdata 499 orte/mca/state/orted/state_orted.c jdata->map = NULL; jdata 504 orte/mca/state/orted/state_orted.c orte_state_base_check_fds(jdata); jdata 510 orte/mca/state/orted/state_orted.c target.jobid = jdata->jobid; jdata 516 orte/mca/state/orted/state_orted.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, NULL); jdata 517 orte/mca/state/orted/state_orted.c OBJ_RELEASE(jdata); jdata 553 orte/mca/state/orted/state_orted.c static int pack_state_update(opal_buffer_t *alert, orte_job_t *jdata) jdata 560 orte/mca/state/orted/state_orted.c if (ORTE_SUCCESS != (rc = opal_dss.pack(alert, &jdata->jobid, 1, ORTE_JOBID))) { jdata 569 orte/mca/state/orted/state_orted.c if (child->name.jobid == jdata->jobid) { jdata 149 orte/mca/state/state.h typedef void (*orte_state_base_module_activate_job_state_fn_t)(orte_job_t *jdata, jdata 69 orte/mca/state/state_types.h orte_job_t *jdata; jdata 107 orte/orted/orted_comm.c orte_job_t *jdata; jdata 209 orte/orted/orted_comm.c jdata = orte_get_job_data_object(job); jdata 225 orte/orted/orted_comm.c if (NULL != jdata) { jdata 226 orte/orted/orted_comm.c jdata->state |= ORTE_JOB_STATE_SUSPENDED; jdata 228 orte/orted/orted_comm.c } else if (SIGCONT == signal && NULL != jdata) { jdata 229 orte/orted/orted_comm.c jdata->state &= ~ORTE_JOB_STATE_SUSPENDED; jdata 478 orte/orted/orted_comm.c if (ORTE_SUCCESS != (ret = opal_dss.unpack(buffer, &jdata, &n, ORTE_JOB))) { jdata 480 orte/orted/orted_comm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_LAUNCH); jdata 484 orte/orted/orted_comm.c jdata->originator = *sender; jdata 486 orte/orted/orted_comm.c if (ORTE_SUCCESS != (ret = orte_plm_base_create_jobid(jdata))) { jdata 488 orte/orted/orted_comm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_LAUNCH); jdata 492 orte/orted/orted_comm.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata); jdata 506 orte/orted/orted_comm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_LAUNCH); jdata 510 orte/orted/orted_comm.c source.jobid = jdata->jobid; jdata 515 orte/orted/orted_comm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_LAUNCH); jdata 522 orte/orted/orted_comm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_LAUNCH); jdata 535 orte/orted/orted_comm.c if (ORTE_SUCCESS != (ret = orte_plm.spawn(jdata))) { jdata 537 orte/orted/orted_comm.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_FAILED_TO_LAUNCH); jdata 554 orte/orted/orted_comm.c if (NULL == (jdata = orte_get_job_data_object(job))) { jdata 560 orte/orted/orted_comm.c if (ORTE_SUCCESS != (ret = orte_set_attribute(&jdata->attributes, ORTE_JOB_CANCELLED, jdata 583 orte/orted/orted_comm.c if (NULL == (jdata = orte_get_job_data_object(job))) { jdata 592 orte/orted/orted_comm.c if (0 < jdata->num_local_procs) { jdata 598 orte/orted/orted_comm.c if (NULL != jdata->map) { jdata 599 orte/orted/orted_comm.c map = (orte_job_map_t*)jdata->map; jdata 608 orte/orted/orted_comm.c if (proct->name.jobid != jdata->jobid) { jdata 627 orte/orted/orted_comm.c jdata->map = NULL; jdata 969 orte/orted/orted_comm.c orte_job_t *jdata; jdata 987 orte/orted/orted_comm.c if (NULL == (jdata = orte_get_job_data_object(job))) { jdata 1003 orte/orted/orted_comm.c for (i=0; i < jdata->procs->size; i++) { jdata 1004 orte/orted/orted_comm.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 1040 orte/orted/orted_comm.c for (i=0; i < jdata->procs->size; i++) { jdata 1041 orte/orted/orted_comm.c if (NULL != opal_pointer_array_get_item(jdata->procs, i)) { jdata 1052 orte/orted/orted_comm.c for (i=0; i < jdata->procs->size; i++) { jdata 1053 orte/orted/orted_comm.c if (NULL != (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 537 orte/orted/orted_main.c orte_job_t *jdata; jdata 545 orte/orted/orted_main.c jdata = OBJ_NEW(orte_job_t); jdata 547 orte/orted/orted_main.c opal_argv_append_nosize(&jdata->personality, "ompi"); jdata 548 orte/orted/orted_main.c orte_plm_base_create_jobid(jdata); jdata 549 orte/orted/orted_main.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata); jdata 556 orte/orted/orted_main.c jdata->map = OBJ_NEW(orte_job_map_t); jdata 562 orte/orted/orted_main.c opal_pointer_array_add(jdata->apps, app); jdata 563 orte/orted/orted_main.c jdata->num_apps = 1; jdata 571 orte/orted/orted_main.c proc->name.jobid = jdata->jobid; jdata 581 orte/orted/orted_main.c opal_pointer_array_add(jdata->procs, proc); jdata 582 orte/orted/orted_main.c jdata->num_procs = 1; jdata 585 orte/orted/orted_main.c opal_pointer_array_add(jdata->map->nodes, node); jdata 586 orte/orted/orted_main.c jdata->map->num_nodes++; jdata 594 orte/orted/orted_main.c jdata->num_local_procs = 1; jdata 604 orte/orted/orted_main.c orte_pre_condition_transports(jdata, NULL); jdata 607 orte/orted/orted_main.c if (ORTE_SUCCESS != (ret = orte_pmix_server_register_nspace(jdata, false))) { jdata 618 orte/orted/orted_main.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_TRANSPORT_KEY, (void**)&string_key, OPAL_STRING) || NULL == string_key) { jdata 134 orte/orted/orted_submit.c orte_job_t *jdata, jdata 139 orte/orted/orted_submit.c static int parse_locals(orte_job_t *jdata, int argc, char* argv[]); jdata 141 orte/orted/orted_submit.c static int parse_appfile(orte_job_t *jdata, char *filename, char ***env); jdata 175 orte/orted/orted_submit.c static void orte_debugger_init_before_spawn(orte_job_t *jdata); jdata 190 orte/orted/orted_submit.c orte_job_t *jdata; jdata 199 orte/orted/orted_submit.c p->jdata = NULL; jdata 207 orte/orted/orted_submit.c if (NULL != p->jdata) { jdata 208 orte/orted/orted_submit.c OBJ_RELEASE(p->jdata); jdata 699 orte/orted/orted_submit.c if (OPAL_SUCCESS != (rc = opal_dss.pack(req, &trk->jdata->jobid, 1, ORTE_JOBID))) { jdata 752 orte/orted/orted_submit.c orte_job_t *jdata = NULL, *daemons; jdata 789 orte/orted/orted_submit.c jdata = OBJ_NEW(orte_job_t); jdata 790 orte/orted/orted_submit.c if (NULL == jdata) { jdata 798 orte/orted/orted_submit.c jdata->personality = opal_argv_split(orte_cmd_options.personality, ','); jdata 801 orte/orted/orted_submit.c opal_argv_append_nosize(&jdata->personality, "ompi"); jdata 805 orte/orted/orted_submit.c trk->jdata = jdata; jdata 814 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ROOM_NUM, ORTE_ATTR_GLOBAL, &trk->index, OPAL_INT); jdata 819 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_TAG_OUTPUT, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 823 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_TIMESTAMP_OUTPUT, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 835 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_OUTPUT_TO_FILE, ORTE_ATTR_GLOBAL, path, OPAL_STRING); jdata 838 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_OUTPUT_TO_FILE, ORTE_ATTR_GLOBAL, orte_cmd_options.output_filename, OPAL_STRING); jdata 843 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_MERGE_STDERR_STDOUT, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 849 orte/orted/orted_submit.c jdata->stdin_target = ORTE_VPID_WILDCARD; jdata 851 orte/orted/orted_submit.c jdata->stdin_target = ORTE_VPID_INVALID; jdata 853 orte/orted/orted_submit.c jdata->stdin_target = strtoul(orte_cmd_options.stdin_target, NULL, 10); jdata 859 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_INDEX_ARGV, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 863 orte/orted/orted_submit.c parse_locals(jdata, argc, argv); jdata 865 orte/orted/orted_submit.c if (0 == jdata->num_apps) { jdata 875 orte/orted/orted_submit.c jdata->map = OBJ_NEW(orte_job_map_t); jdata 878 orte/orted/orted_submit.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_set_mapping_policy(jdata, &jdata->map->mapping, NULL, orte_cmd_options.mapping_policy))) { jdata 883 orte/orted/orted_submit.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_PPR); jdata 884 orte/orted/orted_submit.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_GIVEN); jdata 886 orte/orted/orted_submit.c jdata->map->ppr = strdup("1:node"); jdata 888 orte/orted/orted_submit.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_PPR); jdata 889 orte/orted/orted_submit.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_GIVEN); jdata 891 orte/orted/orted_submit.c opal_asprintf(&jdata->map->ppr, "%d:node", orte_cmd_options.npernode); jdata 893 orte/orted/orted_submit.c ORTE_SET_MAPPING_POLICY(jdata->map->mapping, ORTE_MAPPING_PPR); jdata 894 orte/orted/orted_submit.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_GIVEN); jdata 896 orte/orted/orted_submit.c opal_asprintf(&jdata->map->ppr, "%d:socket", orte_cmd_options.npersocket); jdata 902 orte/orted/orted_submit.c jdata->map->cpus_per_rank = orte_cmd_options.cpus_per_proc; jdata 906 orte/orted/orted_submit.c if (ORTE_SUCCESS != (rc = orte_rmaps_base_set_ranking_policy(&jdata->map->ranking, jdata 907 orte/orted/orted_submit.c jdata->map->mapping, jdata 915 orte/orted/orted_submit.c if (ORTE_SUCCESS != (rc = opal_hwloc_base_set_binding_policy(&jdata->map->binding, jdata 924 orte/orted/orted_submit.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_USE_LOCAL); jdata 927 orte/orted/orted_submit.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_OVERSUBSCRIBE); jdata 930 orte/orted/orted_submit.c ORTE_UNSET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_OVERSUBSCRIBE); jdata 931 orte/orted/orted_submit.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_SUBSCRIBE_GIVEN); jdata 934 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_REPORT_BINDINGS, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 937 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_CPU_LIST, ORTE_ATTR_GLOBAL, orte_cmd_options.cpu_list, OPAL_STRING); jdata 942 orte/orted/orted_submit.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_RECOVERABLE); jdata 945 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_CONTINUOUS_OP, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 950 orte/orted/orted_submit.c for (i=0; i < jdata->num_apps; i++) { jdata 951 orte/orted/orted_submit.c if (NULL != (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 959 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_CONTINUOUS_OP, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 966 orte/orted/orted_submit.c for (n=0; n < (int)jdata->num_apps; n++) { jdata 967 orte/orted/orted_submit.c if (NULL != (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 981 orte/orted/orted_submit.c ORTE_FLAG_UNSET(jdata, ORTE_JOB_FLAG_FORWARD_OUTPUT); jdata 1009 orte/orted/orted_submit.c orte_timeout_wakeup, jdata); jdata 1027 orte/orted/orted_submit.c orte_profile_wakeup, jdata); jdata 1070 orte/orted/orted_submit.c if (NULL != (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, 0)) && jdata 1123 orte/orted/orted_submit.c orte_debugger_init_before_spawn(jdata); jdata 1125 orte/orted/orted_submit.c rc = orte_plm.spawn(jdata); jdata 1128 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_DVM_JOB, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 1132 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_FIXED_DVM, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 1139 orte/orted/orted_submit.c if (OPAL_SUCCESS != (rc = opal_dss.pack(req, &jdata, 1, ORTE_JOB))) { jdata 1262 orte/orted/orted_submit.c static int parse_locals(orte_job_t *jdata, int argc, char* argv[]) jdata 1290 orte/orted/orted_submit.c rc = create_app(temp_argc, temp_argv, jdata, &app, &made_app, &env); jdata 1301 orte/orted/orted_submit.c opal_pointer_array_add(jdata->apps, app); jdata 1302 orte/orted/orted_submit.c ++jdata->num_apps; jdata 1318 orte/orted/orted_submit.c rc = create_app(temp_argc, temp_argv, jdata, &app, &made_app, &env); jdata 1327 orte/orted/orted_submit.c opal_pointer_array_add(jdata->apps, app); jdata 1328 orte/orted/orted_submit.c ++jdata->num_apps; jdata 1341 orte/orted/orted_submit.c size1 = (size_t)opal_pointer_array_get_size(jdata->apps); jdata 1345 orte/orted/orted_submit.c opal_pointer_array_get_item(jdata->apps, j); jdata 1370 orte/orted/orted_submit.c if (opal_pointer_array_get_size(jdata->apps) >= 1) { jdata 1375 orte/orted/orted_submit.c opal_pointer_array_get_item(jdata->apps, 0); jdata 1378 orte/orted/orted_submit.c for (j = 1; j < opal_pointer_array_get_size(jdata->apps); ++j) { jdata 1379 orte/orted/orted_submit.c if (NULL != opal_pointer_array_get_item(jdata->apps, j)) { jdata 1441 orte/orted/orted_submit.c orte_job_t *jdata, jdata 1485 orte/orted/orted_submit.c return parse_appfile(jdata, strdup(orte_cmd_options.appfile), app_env); jdata 1894 orte/orted/orted_submit.c static int parse_appfile(orte_job_t *jdata, char *filename, char ***env) jdata 2008 orte/orted/orted_submit.c rc = create_app(argc, argv, jdata, &app, &made_app, &tmp_env); jdata 2020 orte/orted/orted_submit.c opal_pointer_array_add(jdata->apps, app); jdata 2021 orte/orted/orted_submit.c ++jdata->num_apps; jdata 2080 orte/orted/orted_submit.c trk->jdata->jobid = jobid; jdata 2087 orte/orted/orted_submit.c if (OPAL_SUCCESS == opal_dss.unpack(buffer, &trk->jdata->state, &cnt, ORTE_JOB_STATE_T)) { jdata 2091 orte/orted/orted_submit.c app = (orte_app_context_t*)opal_pointer_array_get_item(trk->jdata->apps, proc->app_idx); jdata 2094 orte/orted/orted_submit.c orte_print_aborted_job(trk->jdata, app, proc, node); jdata 2100 orte/orted/orted_submit.c trk->launch_cb(tool_job_index, trk->jdata, ret, trk->launch_cbdata); jdata 2158 orte/orted/orted_submit.c opal_dss.unpack(buffer, &trk->jdata->state, &cnt, ORTE_JOB_STATE_T); jdata 2162 orte/orted/orted_submit.c app = (orte_app_context_t*)opal_pointer_array_get_item(trk->jdata->apps, proc->app_idx); jdata 2165 orte/orted/orted_submit.c orte_print_aborted_job(trk->jdata, app, proc, node); jdata 2170 orte/orted/orted_submit.c trk->complete_cb(tool_job_index, trk->jdata, ret, trk->complete_cbdata); jdata 2266 orte/orted/orted_submit.c static void orte_debugger_init_before_spawn(orte_job_t *jdata) jdata 2327 orte/orted/orted_submit.c for (i=0; i < jdata->apps->size; i++) { jdata 2328 orte/orted/orted_submit.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 2517 orte/orted/orted_submit.c orte_job_t *jdata = caddy->jdata; jdata 2527 orte/orted/orted_submit.c if (MPIR_proctable || 0 == jdata->num_procs) { jdata 2571 orte/orted/orted_submit.c MPIR_proctable_size = jdata->num_procs; jdata 2583 orte/orted/orted_submit.c opal_output(orte_clean_output, "MPIR Proctable for job %s", ORTE_JOBID_PRINT(jdata->jobid)); jdata 2587 orte/orted/orted_submit.c for (j=0; j < jdata->num_procs; j++) { jdata 2588 orte/orted/orted_submit.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, j))) { jdata 2595 orte/orted/orted_submit.c if (NULL == (appctx = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, proc->app_idx))) { jdata 2675 orte/orted/orted_submit.c setup_debugger_job(jdata->jobid); jdata 3170 orte/orted/orted_submit.c orte_job_t *jdata; jdata 3191 orte/orted/orted_submit.c rc = opal_hash_table_get_first_key_uint32(orte_job_data, &key, (void **)&jdata, &nptr); jdata 3194 orte/orted/orted_submit.c fprintf(stderr, "DATA FOR JOB: %s\n", ORTE_JOBID_PRINT(jdata->jobid)); jdata 3196 orte/orted/orted_submit.c (int)jdata->num_apps, (int)jdata->num_procs, jdata 3197 orte/orted/orted_submit.c orte_job_state_to_str(jdata->state), jdata 3198 orte/orted/orted_submit.c (ORTE_FLAG_TEST(jdata, ORTE_JOB_FLAG_ABORTED)) ? "True" : "False"); jdata 3200 orte/orted/orted_submit.c (long)jdata->num_launched, (long)jdata->num_reported, (long)jdata->num_terminated); jdata 3202 orte/orted/orted_submit.c for (i=0; i < jdata->procs->size; i++) { jdata 3203 orte/orted/orted_submit.c if (NULL != (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 3212 orte/orted/orted_submit.c rc = opal_hash_table_get_next_key_uint32(orte_job_data, &key, (void **)&jdata, nptr, &nptr); jdata 28 orte/orted/orted_submit.h typedef void (*orte_submit_cbfunc_t)(int index, orte_job_t *jdata, int ret, void *cbdata); jdata 486 orte/orted/pmix/pmix_server.c orte_job_t *jdata; jdata 510 orte/orted/pmix/pmix_server.c if (NULL == (jdata = orte_get_job_data_object(name.jobid))) { jdata 530 orte/orted/pmix/pmix_server.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, name.vpid))) { jdata 688 orte/orted/pmix/pmix_server.c p->jdata = NULL; jdata 702 orte/orted/pmix/pmix_server.c if (NULL != p->jdata) { jdata 703 orte/orted/pmix/pmix_server.c OBJ_RELEASE(p->jdata); jdata 38 orte/orted/pmix/pmix_server.h ORTE_DECLSPEC int orte_pmix_server_register_nspace(orte_job_t *jdata, bool force); jdata 64 orte/orted/pmix/pmix_server_dyn.c orte_job_t *jdata; jdata 101 orte/orted/pmix/pmix_server_dyn.c jdata = orte_get_job_data_object(jobid); jdata 102 orte/orted/pmix/pmix_server_dyn.c ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_TERMINATED); jdata 124 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&req->jdata->attributes, ORTE_JOB_ROOM_NUM, jdata 138 orte/orted/pmix/pmix_server_dyn.c if (ORTE_SUCCESS != (rc = opal_dss.pack(buf, &req->jdata, 1, ORTE_JOB))) { jdata 169 orte/orted/pmix/pmix_server_dyn.c orte_job_t *jdata; jdata 184 orte/orted/pmix/pmix_server_dyn.c jdata = OBJ_NEW(orte_job_t); jdata 185 orte/orted/pmix/pmix_server_dyn.c jdata->map = OBJ_NEW(orte_job_map_t); jdata 190 orte/orted/pmix/pmix_server_dyn.c app->idx = opal_pointer_array_add(jdata->apps, app); jdata 191 orte/orted/pmix/pmix_server_dyn.c jdata->num_apps++; jdata 197 orte/orted/pmix/pmix_server_dyn.c OBJ_RELEASE(jdata); jdata 236 orte/orted/pmix/pmix_server_dyn.c OBJ_RELEASE(jdata); jdata 283 orte/orted/pmix/pmix_server_dyn.c jdata->personality = opal_argv_split(info->data.string, ','); jdata 287 orte/orted/pmix/pmix_server_dyn.c jdata->map->req_mapper = strdup(info->data.string); jdata 291 orte/orted/pmix/pmix_server_dyn.c OPAL_CHECK_BOOL(info, jdata->map->display_map); jdata 295 orte/orted/pmix/pmix_server_dyn.c if (ORTE_MAPPING_POLICY_IS_SET(jdata->map->mapping)) { jdata 302 orte/orted/pmix/pmix_server_dyn.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_PPR); jdata 303 orte/orted/pmix/pmix_server_dyn.c jdata->map->ppr = strdup(info->data.string); jdata 307 orte/orted/pmix/pmix_server_dyn.c if (ORTE_MAPPING_POLICY_IS_SET(jdata->map->mapping)) { jdata 314 orte/orted/pmix/pmix_server_dyn.c rc = orte_rmaps_base_set_mapping_policy(jdata, &jdata->map->mapping, jdata 322 orte/orted/pmix/pmix_server_dyn.c if (ORTE_RANKING_POLICY_IS_SET(jdata->map->ranking)) { jdata 329 orte/orted/pmix/pmix_server_dyn.c rc = orte_rmaps_base_set_ranking_policy(&jdata->map->ranking, jdata 330 orte/orted/pmix/pmix_server_dyn.c jdata->map->mapping, jdata 338 orte/orted/pmix/pmix_server_dyn.c if (OPAL_BINDING_POLICY_IS_SET(jdata->map->binding)) { jdata 345 orte/orted/pmix/pmix_server_dyn.c rc = opal_hwloc_base_set_binding_policy(&jdata->map->binding, jdata 353 orte/orted/pmix/pmix_server_dyn.c jdata->map->cpus_per_rank = info->data.uint32; jdata 359 orte/orted/pmix/pmix_server_dyn.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_USE_LOCAL); jdata 361 orte/orted/pmix/pmix_server_dyn.c ORTE_UNSET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_USE_LOCAL); jdata 364 orte/orted/pmix/pmix_server_dyn.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_LOCAL_GIVEN); jdata 370 orte/orted/pmix/pmix_server_dyn.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_OVERSUBSCRIBE); jdata 372 orte/orted/pmix/pmix_server_dyn.c ORTE_UNSET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_NO_OVERSUBSCRIBE); jdata 375 orte/orted/pmix/pmix_server_dyn.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_SUBSCRIBE_GIVEN); jdata 380 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_REPORT_BINDINGS, jdata 385 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_CPU_LIST, jdata 392 orte/orted/pmix/pmix_server_dyn.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_RECOVERABLE); jdata 394 orte/orted/pmix/pmix_server_dyn.c ORTE_FLAG_UNSET(jdata, ORTE_JOB_FLAG_RECOVERABLE); jdata 399 orte/orted/pmix/pmix_server_dyn.c for (i=0; i < jdata->apps->size; i++) { jdata 400 orte/orted/pmix/pmix_server_dyn.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, i))) { jdata 410 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_CONTINUOUS_OP, jdata 416 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_NON_ORTE_JOB, jdata 422 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_DVM_JOB, jdata 426 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_FWDIO_TO_TOOL, jdata 433 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_NOTIFY_COMPLETION, jdata 444 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_TAG_OUTPUT, jdata 450 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_TIMESTAMP_OUTPUT, jdata 455 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_OUTPUT_TO_FILE, jdata 461 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_MERGE_STDERR_STDOUT, jdata 467 orte/orted/pmix/pmix_server_dyn.c jdata->stdin_target = ORTE_VPID_WILDCARD; jdata 469 orte/orted/pmix/pmix_server_dyn.c jdata->stdin_target = ORTE_VPID_INVALID; jdata 471 orte/orted/pmix/pmix_server_dyn.c jdata->stdin_target = strtoul(info->data.string, NULL, 10); jdata 477 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_INDEX_ARGV, jdata 482 orte/orted/pmix/pmix_server_dyn.c ORTE_FLAG_SET(jdata, ORTE_JOB_FLAG_DEBUGGER_DAEMON); jdata 483 orte/orted/pmix/pmix_server_dyn.c ORTE_SET_MAPPING_DIRECTIVE(jdata->map->mapping, ORTE_MAPPING_DEBUGGER); jdata 488 orte/orted/pmix/pmix_server_dyn.c orte_add_attribute(&jdata->attributes, ORTE_JOB_SET_ENVAR, jdata 491 orte/orted/pmix/pmix_server_dyn.c orte_add_attribute(&jdata->attributes, ORTE_JOB_ADD_ENVAR, jdata 494 orte/orted/pmix/pmix_server_dyn.c orte_add_attribute(&jdata->attributes, ORTE_JOB_UNSET_ENVAR, jdata 497 orte/orted/pmix/pmix_server_dyn.c orte_add_attribute(&jdata->attributes, ORTE_JOB_PREPEND_ENVAR, jdata 500 orte/orted/pmix/pmix_server_dyn.c orte_add_attribute(&jdata->attributes, ORTE_JOB_APPEND_ENVAR, jdata 508 orte/orted/pmix/pmix_server_dyn.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_INFO_CACHE, (void**)&cache, OPAL_PTR) && jdata 514 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_INFO_CACHE, ORTE_ATTR_LOCAL, (void*)cache, OPAL_PTR); jdata 519 orte/orted/pmix/pmix_server_dyn.c if (NULL == jdata->personality) { jdata 520 orte/orted/pmix/pmix_server_dyn.c opal_argv_append_nosize(&jdata->personality, "ompi"); jdata 524 orte/orted/pmix/pmix_server_dyn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_LAUNCH_PROXY, jdata 530 orte/orted/pmix/pmix_server_dyn.c ORTE_SPN_REQ(jdata, spawn, cbfunc, cbdata); jdata 542 orte/orted/pmix/pmix_server_dyn.c orte_job_t *jdata; jdata 576 orte/orted/pmix/pmix_server_dyn.c if (OPAL_SUCCESS != (rc = opal_dss.unpack(&buf, &jdata, &cnt, ORTE_JOB))) { jdata 655 orte/orted/pmix/pmix_server_dyn.c opal_pointer_array_set_item(jdata->procs, pname.vpid, proc); jdata 670 orte/orted/pmix/pmix_server_dyn.c if (ORTE_SUCCESS != (rc = orte_pmix_server_register_nspace(jdata, true))) { jdata 672 orte/orted/pmix/pmix_server_dyn.c OBJ_RELEASE(jdata); jdata 677 orte/orted/pmix/pmix_server_dyn.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata); jdata 699 orte/orted/pmix/pmix_server_dyn.c orte_job_t *jdata; jdata 717 orte/orted/pmix/pmix_server_dyn.c if (NULL == (jdata = orte_get_job_data_object(nm->name.jobid))) { jdata 750 orte/orted/pmix/pmix_server_dyn.c if (!orte_get_attribute(&jdata->attributes, ORTE_JOB_NSPACE_REGISTERED, NULL, OPAL_BOOL)) { jdata 752 orte/orted/pmix/pmix_server_dyn.c if (ORTE_SUCCESS != (rc = orte_pmix_server_register_nspace(jdata, true))) { jdata 135 orte/orted/pmix/pmix_server_fence.c orte_job_t *jdata; jdata 184 orte/orted/pmix/pmix_server_fence.c if (NULL == (jdata = orte_get_job_data_object(req->target.jobid))) { jdata 202 orte/orted/pmix/pmix_server_fence.c rc = orte_pmix_server_register_nspace(jdata, true); jdata 215 orte/orted/pmix/pmix_server_fence.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, req->target.vpid))) { jdata 58 orte/orted/pmix/pmix_server_gen.c orte_job_t *jdata; jdata 70 orte/orted/pmix/pmix_server_gen.c if (NULL == (jdata = orte_get_job_data_object(cd->proc.jobid))) { jdata 73 orte/orted/pmix/pmix_server_gen.c for (i=0; i < jdata->procs->size; i++) { jdata 74 orte/orted/pmix/pmix_server_gen.c if (NULL == (ptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 109 orte/orted/pmix/pmix_server_gen.c orte_job_t *jdata; jdata 121 orte/orted/pmix/pmix_server_gen.c if (NULL == (jdata = orte_get_job_data_object(cd->proc.jobid))) { jdata 124 orte/orted/pmix/pmix_server_gen.c for (i=0; i < jdata->procs->size; i++) { jdata 125 orte/orted/pmix/pmix_server_gen.c if (NULL == (ptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 169 orte/orted/pmix/pmix_server_gen.c orte_job_t *jdata; jdata 180 orte/orted/pmix/pmix_server_gen.c if (NULL == (jdata = orte_get_job_data_object(cd->proc.jobid))) { jdata 183 orte/orted/pmix/pmix_server_gen.c for (i=0; i < jdata->procs->size; i++) { jdata 184 orte/orted/pmix/pmix_server_gen.c if (NULL == (ptr = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 489 orte/orted/pmix/pmix_server_gen.c orte_job_t *jdata; jdata 520 orte/orted/pmix/pmix_server_gen.c rc = opal_hash_table_get_first_key_uint32(orte_job_data, &key, (void **)&jdata, &nptr); jdata 522 orte/orted/pmix/pmix_server_gen.c if (ORTE_PROC_MY_NAME->jobid != jdata->jobid) { jdata 524 orte/orted/pmix/pmix_server_gen.c (void)opal_snprintf_jobid(nspace, 512, jdata->jobid); jdata 527 orte/orted/pmix/pmix_server_gen.c rc = opal_hash_table_get_next_key_uint32(orte_job_data, &key, (void **)&jdata, nptr, &nptr); jdata 724 orte/orted/pmix/pmix_server_gen.c jdata = orte_get_job_data_object(jobid); jdata 725 orte/orted/pmix/pmix_server_gen.c if (NULL == jdata) { jdata 737 orte/orted/pmix/pmix_server_gen.c for (k=0; k < jdata->procs->size; k++) { jdata 738 orte/orted/pmix/pmix_server_gen.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, k))) { jdata 748 orte/orted/pmix/pmix_server_gen.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, proct->app_idx); jdata 773 orte/orted/pmix/pmix_server_gen.c jdata = orte_get_job_data_object(jobid); jdata 774 orte/orted/pmix/pmix_server_gen.c if (NULL == jdata) { jdata 786 orte/orted/pmix/pmix_server_gen.c for (k=0; k < jdata->procs->size; k++) { jdata 787 orte/orted/pmix/pmix_server_gen.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, k))) { jdata 798 orte/orted/pmix/pmix_server_gen.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, proct->app_idx); jdata 852 orte/orted/pmix/pmix_server_gen.c orte_job_t *jdata; jdata 899 orte/orted/pmix/pmix_server_gen.c jdata = OBJ_NEW(orte_job_t); jdata 900 orte/orted/pmix/pmix_server_gen.c rc = orte_plm_base_create_jobid(jdata); jdata 902 orte/orted/pmix/pmix_server_gen.c OBJ_RELEASE(jdata); jdata 912 orte/orted/pmix/pmix_server_gen.c tool.jobid = jdata->jobid; jdata 927 orte/orted/pmix/pmix_server_gen.c jdata = OBJ_NEW(orte_job_t); jdata 928 orte/orted/pmix/pmix_server_gen.c jdata->jobid = tool.jobid; jdata 931 orte/orted/pmix/pmix_server_gen.c opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata); jdata 940 orte/orted/pmix/pmix_server_gen.c jdata->map = OBJ_NEW(orte_job_map_t); jdata 946 orte/orted/pmix/pmix_server_gen.c opal_pointer_array_add(jdata->apps, app); jdata 947 orte/orted/pmix/pmix_server_gen.c jdata->num_apps = 1; jdata 955 orte/orted/pmix/pmix_server_gen.c proc->name.jobid = jdata->jobid; jdata 993 orte/orted/pmix/pmix_server_gen.c opal_pointer_array_add(jdata->procs, proc); jdata 994 orte/orted/pmix/pmix_server_gen.c jdata->num_procs = 1; jdata 997 orte/orted/pmix/pmix_server_gen.c opal_pointer_array_add(jdata->map->nodes, node); jdata 998 orte/orted/pmix/pmix_server_gen.c jdata->map->num_nodes++; jdata 1007 orte/orted/pmix/pmix_server_gen.c orte_set_attribute(&jdata->attributes, ORTE_JOB_SILENT_TERMINATION, jdata 1012 orte/orted/pmix/pmix_server_gen.c orte_set_attribute(&jdata->attributes, ORTE_JOB_SILENT_TERMINATION, jdata 77 orte/orted/pmix/pmix_server_internal.h orte_job_t *jdata; jdata 134 orte/orted/pmix/pmix_server_internal.h _req->jdata = (j); \ jdata 57 orte/orted/pmix/pmix_server_register_fns.c int orte_pmix_server_register_nspace(orte_job_t *jdata, bool force) jdata 81 orte/orted/pmix/pmix_server_register_fns.c ORTE_JOBID_PRINT(jdata->jobid)); jdata 104 orte/orted/pmix/pmix_server_register_fns.c kv->data.string = strdup(ORTE_JOBID_PRINT(jdata->jobid)); jdata 111 orte/orted/pmix/pmix_server_register_fns.c kv->data.uint32 = jdata->offset; jdata 117 orte/orted/pmix/pmix_server_register_fns.c if (orte_get_attribute(&jdata->attributes, ORTE_JOB_INFO_CACHE, (void**)&cache, OPAL_PTR) && jdata 122 orte/orted/pmix/pmix_server_register_fns.c orte_remove_attribute(&jdata->attributes, ORTE_JOB_INFO_CACHE); jdata 129 orte/orted/pmix/pmix_server_register_fns.c map = jdata->map; jdata 137 orte/orted/pmix/pmix_server_register_fns.c if (jdata->jobid == pptr->name.jobid) { jdata 232 orte/orted/pmix/pmix_server_register_fns.c kv->data.uint32 = jdata->total_slots_alloc; jdata 239 orte/orted/pmix/pmix_server_register_fns.c kv->data.uint32 = jdata->num_procs; jdata 246 orte/orted/pmix/pmix_server_register_fns.c kv->data.uint32 = jdata->num_apps; jdata 253 orte/orted/pmix/pmix_server_register_fns.c kv->data.uint32 = jdata->num_local_procs; jdata 260 orte/orted/pmix/pmix_server_register_fns.c kv->data.uint32 = jdata->total_slots_alloc; jdata 288 orte/orted/pmix/pmix_server_register_fns.c kv->data.string = strdup(orte_rmaps_base_print_mapping(jdata->map->mapping)); jdata 295 orte/orted/pmix/pmix_server_register_fns.c kv->data.string = strdup(orte_rmaps_base_print_ranking(jdata->map->ranking)); jdata 302 orte/orted/pmix/pmix_server_register_fns.c kv->data.string = strdup(opal_hwloc_base_print_binding(jdata->map->binding)); jdata 314 orte/orted/pmix/pmix_server_register_fns.c if (pptr->name.jobid == jdata->jobid) { jdata 361 orte/orted/pmix/pmix_server_register_fns.c if (pptr->name.jobid != jdata->jobid) { jdata 404 orte/orted/pmix/pmix_server_register_fns.c kv->data.name.vpid = pptr->name.vpid + jdata->offset; jdata 407 orte/orted/pmix/pmix_server_register_fns.c if (1 < jdata->num_apps) { jdata 416 orte/orted/pmix/pmix_server_register_fns.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, pptr->app_idx); jdata 437 orte/orted/pmix/pmix_server_register_fns.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, pptr->app_idx); jdata 448 orte/orted/pmix/pmix_server_register_fns.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, 0); jdata 492 orte/orted/pmix/pmix_server_register_fns.c orte_set_attribute(&jdata->attributes, ORTE_JOB_NSPACE_REGISTERED, ORTE_ATTR_LOCAL, NULL, OPAL_BOOL); jdata 496 orte/orted/pmix/pmix_server_register_fns.c rc = opal_pmix.server_register_nspace(jdata->jobid, jdata 497 orte/orted/pmix/pmix_server_register_fns.c jdata->num_local_procs, jdata 510 orte/orted/pmix/pmix_server_register_fns.c if (ORTE_PROC_IS_HNP && ORTE_JOB_FAMILY(ORTE_PROC_MY_NAME->jobid) == ORTE_JOB_FAMILY(jdata->jobid)) { jdata 514 orte/orted/pmix/pmix_server_register_fns.c if (OPAL_SUCCESS != (rc = opal_dss.pack(&buf, &jdata, 1, ORTE_JOB))) { jdata 521 orte/orted/pmix/pmix_server_register_fns.c map = jdata->map; jdata 535 orte/orted/pmix/pmix_server_register_fns.c for (i=0; i < jdata->procs->size; i++) { jdata 536 orte/orted/pmix/pmix_server_register_fns.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 550 orte/orted/pmix/pmix_server_register_fns.c orte_util_convert_jobid_to_string(&kv->key, jdata->jobid); jdata 411 orte/runtime/orte_globals.c orte_job_t *jdata; jdata 418 orte/runtime/orte_globals.c jdata = NULL; jdata 419 orte/runtime/orte_globals.c opal_hash_table_get_value_uint32(orte_job_data, job, (void**)&jdata); jdata 420 orte/runtime/orte_globals.c return jdata; jdata 425 orte/runtime/orte_globals.c orte_job_t *jdata; jdata 428 orte/runtime/orte_globals.c if (NULL == (jdata = orte_get_job_data_object(proc->jobid))) { jdata 431 orte/runtime/orte_globals.c proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); jdata 437 orte/runtime/orte_globals.c orte_job_t *jdata; jdata 440 orte/runtime/orte_globals.c if (NULL == (jdata = orte_get_job_data_object(proc->jobid))) { jdata 443 orte/runtime/orte_globals.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid))) { jdata 516 orte/runtime/orte_globals.c orte_job_t *jdata; jdata 519 orte/runtime/orte_globals.c if (NULL == (jdata = orte_get_job_data_object(job))) { jdata 532 orte/runtime/orte_globals.c for (i=0; i < jdata->procs->size; i++) { jdata 533 orte/runtime/orte_globals.c if (NULL == (proc = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, i))) { jdata 17 orte/test/system/orte_loop_spawn.c orte_job_t *jdata; jdata 29 orte/test/system/orte_loop_spawn.c jdata = OBJ_NEW(orte_job_t); jdata 30 orte/test/system/orte_loop_spawn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_NON_ORTE_JOB, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 42 orte/test/system/orte_loop_spawn.c opal_pointer_array_add(jdata->apps, app); jdata 43 orte/test/system/orte_loop_spawn.c jdata->num_apps = 1; jdata 46 orte/test/system/orte_loop_spawn.c if (ORTE_SUCCESS != (rc = orte_plm.spawn(jdata))) { jdata 25 orte/test/system/orte_spawn.c orte_job_t *jdata; jdata 39 orte/test/system/orte_spawn.c jdata = OBJ_NEW(orte_job_t); jdata 40 orte/test/system/orte_spawn.c orte_set_attribute(&jdata->attributes, ORTE_JOB_NON_ORTE_JOB, ORTE_ATTR_GLOBAL, NULL, OPAL_BOOL); jdata 56 orte/test/system/orte_spawn.c opal_pointer_array_add(jdata->apps, app); jdata 57 orte/test/system/orte_spawn.c jdata->num_apps = 1; jdata 60 orte/test/system/orte_spawn.c jdata->map = OBJ_NEW(orte_job_map_t); jdata 61 orte/test/system/orte_spawn.c jdata->map->display_map = true; jdata 65 orte/test/system/orte_spawn.c if (ORTE_SUCCESS != (rc = orte_plm.spawn(jdata))) { jdata 74 orte/test/system/orte_spawn.c name.jobid = jdata->jobid; jdata 24 orte/test/system/orte_tool.c orte_job_t *jdata=NULL, **jobs=NULL; jdata 60 orte/test/system/orte_tool.c jdata = OBJ_NEW(orte_job_t); jdata 65 orte/test/system/orte_tool.c opal_pointer_array_add(jdata->apps, app); jdata 66 orte/test/system/orte_tool.c jdata->num_apps++; jdata 80 orte/test/system/orte_tool.c if (ORTE_SUCCESS != (rc = orte_util_comm_spawn_job(&hnp->name, jdata))) { jdata 86 orte/test/system/orte_tool.c fprintf(stderr, "orte_tool: spawned jobid %s\n", ORTE_JOBID_PRINT(jdata->jobid)); jdata 97 orte/test/system/orte_tool.c if (NULL != jdata) OBJ_RELEASE(jdata); jdata 16 orte/test/system/psm_keygen.c orte_job_t *jdata; jdata 25 orte/test/system/psm_keygen.c jdata = OBJ_NEW(orte_job_t); jdata 27 orte/test/system/psm_keygen.c opal_pointer_array_set_item(jdata->apps, 0, app); jdata 28 orte/test/system/psm_keygen.c jdata->num_apps = 1; jdata 30 orte/test/system/psm_keygen.c if (ORTE_SUCCESS != orte_pre_condition_transports(jdata)) { jdata 43 orte/test/system/psm_keygen.c OBJ_RELEASE(jdata); jdata 107 orte/tools/orterun/orterun.c orte_job_t *jdata; jdata 111 orte/tools/orterun/orterun.c static void launched(int index, orte_job_t *jdata, int ret, void *cbdata) jdata 116 orte/tools/orterun/orterun.c OBJ_RETAIN(jdata); jdata 117 orte/tools/orterun/orterun.c launchst->jdata = jdata; jdata 120 orte/tools/orterun/orterun.c static void completed(int index, orte_job_t *jdata, int ret, void *cbdata) jdata 125 orte/tools/orterun/orterun.c OBJ_RETAIN(jdata); jdata 126 orte/tools/orterun/orterun.c completest->jdata = jdata; jdata 205 orte/tools/orterun/orterun.c (NULL == launchst.jdata) ? "UNKNOWN" : ORTE_JOBID_PRINT(launchst.jdata->jobid)); jdata 631 orte/util/comm/comm.c int orte_util_comm_spawn_job(const orte_process_name_t *hnp, orte_job_t *jdata) jdata 655 orte/util/comm/comm.c if (ORTE_SUCCESS != (rc = opal_dss.pack(buf, &jdata, 1, ORTE_JOB))) { jdata 690 orte/util/comm/comm.c if (ORTE_SUCCESS != (rc = opal_dss.unpack(buf, &(jdata->jobid), &count, ORTE_JOBID))) { jdata 695 orte/util/comm/comm.c if (ORTE_JOBID_INVALID == jdata->jobid) { jdata 57 orte/util/comm/comm.h ORTE_DECLSPEC int orte_util_comm_spawn_job(const orte_process_name_t *hnp, orte_job_t *jdata); jdata 1036 orte/util/nidmap.c int orte_util_generate_ppn(orte_job_t *jdata, jdata 1054 orte/util/nidmap.c for (i=0; i < jdata->num_apps; i++) { jdata 1056 orte/util/nidmap.c for (j=0; j < jdata->map->nodes->size; j++) { jdata 1057 orte/util/nidmap.c if (NULL == (nptr = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, j))) { jdata 1066 orte/util/nidmap.c if (proc->name.jobid == jdata->jobid) { jdata 1121 orte/util/nidmap.c int orte_util_decode_ppn(orte_job_t *jdata, jdata 1143 orte/util/nidmap.c for (n=0; n < jdata->num_apps; n++) { jdata 1207 orte/util/nidmap.c opal_pointer_array_add(jdata->map->nodes, node); jdata 1219 orte/util/nidmap.c proc->name.jobid = jdata->jobid; jdata 1243 orte/util/nidmap.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 1244 orte/util/nidmap.c node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m); jdata 1254 orte/util/nidmap.c for (m=0; m < jdata->map->nodes->size; m++) { jdata 1255 orte/util/nidmap.c node = (orte_node_t*)opal_pointer_array_get_item(jdata->map->nodes, m); jdata 46 orte/util/nidmap.h ORTE_DECLSPEC int orte_util_generate_ppn(orte_job_t *jdata, jdata 49 orte/util/nidmap.h ORTE_DECLSPEC int orte_util_decode_ppn(orte_job_t *jdata, jdata 134 orte/util/pre_condition_transports.c int orte_pre_condition_transports(orte_job_t *jdata, char **key) jdata 168 orte/util/pre_condition_transports.c if (NULL != jdata) { jdata 169 orte/util/pre_condition_transports.c orte_set_attribute(&jdata->attributes, ORTE_JOB_TRANSPORT_KEY, ORTE_ATTR_LOCAL, string_key, OPAL_STRING); jdata 177 orte/util/pre_condition_transports.c for (n=0; n < jdata->apps->size; n++) { jdata 178 orte/util/pre_condition_transports.c if (NULL == (app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, n))) { jdata 36 orte/util/pre_condition_transports.h ORTE_DECLSPEC int orte_pre_condition_transports(orte_job_t *jdata, char **key);