caddy 536 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_ACQUIRE_OBJECT(caddy); caddy 874 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_dmdx_reply_caddy_t *caddy = (pmix_dmdx_reply_caddy_t *)cbdata; caddy 889 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_ACQUIRE_OBJECT(caddy); caddy 894 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->lcd->proc.nspace, caddy->lcd->proc.rank); caddy 899 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c if (0 == strcmp(caddy->lcd->proc.nspace, ns->nspace)) { caddy 910 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c nptr->nspace = strdup(caddy->lcd->proc.nspace); caddy 927 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c if (PMIX_SUCCESS == caddy->status) { caddy 931 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_LIST_FOREACH(dm, &caddy->lcd->loc_reqs, pmix_dmdx_request_t) { caddy 961 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c if (NULL == caddy->data) { caddy 984 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_STORE_KV(rc, peer, &caddy->lcd->proc, PMIX_INTERNAL, kv); caddy 992 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_LOAD_BUFFER(pmix_globals.mypeer, &pbkt, caddy->data, caddy->ndata); caddy 998 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c if (caddy->lcd->proc.rank == PMIX_RANK_WILDCARD) { caddy 999 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_STORE_KV(rc, peer, &caddy->lcd->proc, PMIX_INTERNAL, kv); caddy 1001 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_STORE_KV(rc, peer, &caddy->lcd->proc, PMIX_REMOTE, kv); caddy 1005 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->status = rc; caddy 1018 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->status = rc; caddy 1028 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_pending_resolve(nptr, caddy->lcd->proc.rank, caddy->status, caddy->lcd); caddy 1032 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c if (NULL != caddy->relcbfunc) { caddy 1033 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->relcbfunc(caddy->cbdata); caddy 1035 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_RELEASE(caddy); caddy 1044 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_dmdx_reply_caddy_t *caddy; caddy 1049 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy = PMIX_NEW(pmix_dmdx_reply_caddy_t); caddy 1050 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->status = status; caddy 1052 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->relcbfunc = release_fn; caddy 1053 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->cbdata = release_cbdata; caddy 1057 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->data = data; caddy 1058 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->ndata = ndata; caddy 1059 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->lcd = (pmix_dmdx_local_t *)cbdata; caddy 1063 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c caddy->lcd->proc.nspace, caddy->lcd->proc.rank); caddy 1064 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_THREADSHIFT(caddy, _process_dmdx_reply); caddy 153 orte/mca/errmgr/default_app/errmgr_default_app.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 156 orte/mca/errmgr/default_app/errmgr_default_app.c ORTE_ACQUIRE_OBJECT(caddy); caddy 161 orte/mca/errmgr/default_app/errmgr_default_app.c ORTE_NAME_PRINT(&caddy->name), caddy 162 orte/mca/errmgr/default_app/errmgr_default_app.c orte_proc_state_to_str(caddy->proc_state))); caddy 168 orte/mca/errmgr/default_app/errmgr_default_app.c OBJ_RELEASE(caddy); caddy 172 orte/mca/errmgr/default_app/errmgr_default_app.c if (ORTE_PROC_STATE_UNABLE_TO_SEND_MSG == caddy->proc_state) { caddy 174 orte/mca/errmgr/default_app/errmgr_default_app.c nodename = orte_get_proc_hostname(&caddy->name); caddy 179 orte/mca/errmgr/default_app/errmgr_default_app.c ORTE_NAME_PRINT(&caddy->name), caddy 185 orte/mca/errmgr/default_app/errmgr_default_app.c } else if (ORTE_PROC_STATE_LIFELINE_LOST == caddy->proc_state) { caddy 190 orte/mca/errmgr/default_app/errmgr_default_app.c OBJ_RELEASE(caddy); caddy 191 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 200 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACQUIRE_OBJECT(caddy); caddy 215 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (NULL == caddy->jdata) { caddy 217 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c OBJ_RELEASE(caddy); caddy 222 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jdata = caddy->jdata; caddy 223 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c jobstate = caddy->job_state; caddy 248 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_TERMINATED); caddy 256 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c OBJ_RELEASE(caddy); caddy 262 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c OBJ_RELEASE(caddy); caddy 271 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c OBJ_RELEASE(caddy); caddy 288 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c OBJ_RELEASE(caddy); caddy 345 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_FORCED_EXIT); caddy 348 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c OBJ_RELEASE(caddy); caddy 353 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 356 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_process_name_t *proc = &caddy->name; caddy 357 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_proc_state_t state = caddy->proc_state; caddy 361 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_ACQUIRE_OBJECT(caddy); caddy 800 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c OBJ_RELEASE(caddy); caddy 235 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 242 orte/mca/errmgr/default_orted/errmgr_default_orted.c ORTE_ACQUIRE_OBJECT(caddy); caddy 254 orte/mca/errmgr/default_orted/errmgr_default_orted.c if (NULL == caddy->jdata) { caddy 256 orte/mca/errmgr/default_orted/errmgr_default_orted.c OBJ_RELEASE(caddy); caddy 261 orte/mca/errmgr/default_orted/errmgr_default_orted.c jdata = caddy->jdata; caddy 262 orte/mca/errmgr/default_orted/errmgr_default_orted.c jobstate = caddy->job_state; caddy 313 orte/mca/errmgr/default_orted/errmgr_default_orted.c OBJ_RELEASE(caddy); caddy 318 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 320 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_process_name_t *proc = &caddy->name; caddy 321 orte/mca/errmgr/default_orted/errmgr_default_orted.c orte_proc_state_t state = caddy->proc_state; caddy 329 orte/mca/errmgr/default_orted/errmgr_default_orted.c ORTE_ACQUIRE_OBJECT(caddy); caddy 681 orte/mca/errmgr/default_orted/errmgr_default_orted.c OBJ_RELEASE(caddy); caddy 85 orte/mca/errmgr/default_tool/errmgr_default_tool.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 87 orte/mca/errmgr/default_tool/errmgr_default_tool.c ORTE_ACQUIRE_OBJECT(caddy); caddy 92 orte/mca/errmgr/default_tool/errmgr_default_tool.c ORTE_NAME_PRINT(&caddy->name), caddy 93 orte/mca/errmgr/default_tool/errmgr_default_tool.c orte_proc_state_to_str(caddy->proc_state))); caddy 99 orte/mca/errmgr/default_tool/errmgr_default_tool.c OBJ_RELEASE(caddy); caddy 105 orte/mca/errmgr/default_tool/errmgr_default_tool.c if (ORTE_PROC_STATE_LIFELINE_LOST == caddy->proc_state) { caddy 106 orte/mca/errmgr/default_tool/errmgr_default_tool.c ORTE_POST_OBJECT(caddy); caddy 113 orte/mca/errmgr/default_tool/errmgr_default_tool.c OBJ_RELEASE(caddy); caddy 1066 orte/mca/odls/base/odls_base_default_fns.c orte_odls_launch_local_t *caddy = (orte_odls_launch_local_t*)cbdata; caddy 1068 orte/mca/odls/base/odls_base_default_fns.c orte_jobid_t job = caddy->job; caddy 1069 orte/mca/odls/base/odls_base_default_fns.c orte_odls_base_fork_local_proc_fn_t fork_local = caddy->fork_local; caddy 1079 orte/mca/odls/base/odls_base_default_fns.c ORTE_ACQUIRE_OBJECT(caddy); caddy 1129 orte/mca/odls/base/odls_base_default_fns.c if (2 < caddy->retries) { caddy 1138 orte/mca/odls/base/odls_base_default_fns.c ORTE_DETECT_TIMEOUT(1000, 1000, -1, timer_cb, caddy); caddy 1156 orte/mca/odls/base/odls_base_default_fns.c if (2 < caddy->retries) { caddy 1170 orte/mca/odls/base/odls_base_default_fns.c ORTE_DETECT_TIMEOUT(1000, 1000, -1, timer_cb, caddy); caddy 1473 orte/mca/odls/base/odls_base_default_fns.c OBJ_RELEASE(caddy); caddy 130 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 139 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 162 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->total_slots_alloc = 0; caddy 173 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->total_slots_alloc += node->slots; caddy 191 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 205 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 212 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 222 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 234 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 249 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 257 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_DAEMONS_REPORTED; caddy 258 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_VM_READY); caddy 261 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 266 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 268 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 274 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_ALLOCATION_COMPLETE; caddy 275 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_MAP); caddy 278 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_ALLOCATION_COMPLETE; caddy 279 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_LAUNCH_DAEMONS); caddy 283 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 288 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 290 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 297 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 313 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 315 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 318 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_VM_READY; caddy 321 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != orte_filem.preposition_files(caddy->jdata, files_ready, caddy->jdata)) { caddy 326 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 331 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 333 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 336 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = ORTE_JOB_STATE_MAP_COMPLETE; caddy 337 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_SYSTEM_PREP); caddy 340 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 349 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 354 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 360 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOB_STATE_INIT != caddy->job_state) { caddy 362 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 366 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = caddy->job_state; caddy 369 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOBID_INVALID == caddy->jdata->jobid) { caddy 370 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_plm_base_create_jobid(caddy->jdata))) { caddy 373 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 382 orte/mca/plm/base/plm_base_launch_support.c opal_hash_table_set_value_uint32(orte_job_data, caddy->jdata->jobid, caddy->jdata); caddy 386 orte/mca/plm/base/plm_base_launch_support.c if (!ORTE_FLAG_TEST(caddy->jdata, ORTE_JOB_FLAG_RECOVERABLE) && caddy 388 orte/mca/plm/base/plm_base_launch_support.c ORTE_FLAG_SET(caddy->jdata, ORTE_JOB_FLAG_RECOVERABLE); caddy 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)) { caddy 403 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 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); caddy 414 orte/mca/plm/base/plm_base_launch_support.c for (i=0; i < caddy->jdata->apps->size; i++) { caddy 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))) { caddy 422 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_pre_condition_transports(caddy->jdata, NULL))) { caddy 425 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 432 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_SUCCESS != (rc = orte_pre_condition_transports(caddy->jdata, NULL))) { caddy 435 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 441 orte/mca/plm/base/plm_base_launch_support.c for (i=0; i < caddy->jdata->apps->size; i++) { caddy 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))) { caddy 451 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_INIT_COMPLETE); caddy 454 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 459 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 461 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 464 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACTIVATE_JOB_STATE(caddy->jdata, ORTE_JOB_STATE_ALLOCATE); caddy 465 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 471 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 479 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 484 orte/mca/plm/base/plm_base_launch_support.c ORTE_JOBID_PRINT(caddy->jdata->jobid)); caddy 487 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOB_STATE_SYSTEM_PREP != caddy->job_state) { caddy 489 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 493 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = caddy->job_state; caddy 499 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 504 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; caddy 567 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 591 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 596 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 599 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; caddy 601 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOB_STATE_LAUNCH_APPS != caddy->job_state) { caddy 603 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 607 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = caddy->job_state; caddy 623 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 633 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 639 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 646 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; caddy 671 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 685 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 696 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->num_daemons_reported++; caddy 719 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 726 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 733 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 736 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; caddy 749 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOB_STATE_RUNNING != caddy->job_state) { caddy 751 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 755 orte/mca/plm/base/plm_base_launch_support.c caddy->jdata->state = caddy->job_state; caddy 770 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 790 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 797 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 806 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 821 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 827 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 833 orte/mca/plm/base/plm_base_launch_support.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 835 orte/mca/plm/base/plm_base_launch_support.c ORTE_ACQUIRE_OBJECT(caddy); caddy 838 orte/mca/plm/base/plm_base_launch_support.c jdata = caddy->jdata; caddy 845 orte/mca/plm/base/plm_base_launch_support.c if (ORTE_JOB_STATE_REGISTERED != caddy->job_state) { caddy 850 orte/mca/plm/base/plm_base_launch_support.c orte_job_state_to_str(caddy->job_state))); caddy 852 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 856 orte/mca/plm/base/plm_base_launch_support.c jdata->state = caddy->job_state; caddy 863 orte/mca/plm/base/plm_base_launch_support.c OBJ_RELEASE(caddy); caddy 266 orte/mca/plm/rsh/plm_rsh_module.c orte_plm_rsh_caddy_t *caddy=(orte_plm_rsh_caddy_t*)t2->cbdata; caddy 267 orte/mca/plm/rsh/plm_rsh_module.c orte_proc_t *daemon = caddy->daemon; caddy 273 orte/mca/plm/rsh/plm_rsh_module.c OBJ_RELEASE(caddy); caddy 793 orte/mca/plm/rsh/plm_rsh_module.c orte_plm_rsh_caddy_t *caddy; caddy 873 orte/mca/plm/rsh/plm_rsh_module.c caddy = OBJ_NEW(orte_plm_rsh_caddy_t); caddy 874 orte/mca/plm/rsh/plm_rsh_module.c caddy->argc = argc; caddy 875 orte/mca/plm/rsh/plm_rsh_module.c caddy->argv = opal_argv_copy(argv); caddy 879 orte/mca/plm/rsh/plm_rsh_module.c caddy->daemon = OBJ_NEW(orte_proc_t); caddy 880 orte/mca/plm/rsh/plm_rsh_module.c caddy->daemon->name.jobid = ORTE_PROC_MY_NAME->jobid; caddy 881 orte/mca/plm/rsh/plm_rsh_module.c caddy->daemon->name.vpid = target.vpid; caddy 882 orte/mca/plm/rsh/plm_rsh_module.c opal_list_append(&launch_list, &caddy->super); caddy 940 orte/mca/plm/rsh/plm_rsh_module.c orte_plm_rsh_caddy_t *caddy; caddy 942 orte/mca/plm/rsh/plm_rsh_module.c ORTE_ACQUIRE_OBJECT(caddy); caddy 950 orte/mca/plm/rsh/plm_rsh_module.c caddy = (orte_plm_rsh_caddy_t*)item; caddy 952 orte/mca/plm/rsh/plm_rsh_module.c ORTE_FLAG_SET(caddy->daemon, ORTE_PROC_FLAG_ALIVE); caddy 953 orte/mca/plm/rsh/plm_rsh_module.c orte_wait_cb(caddy->daemon, rsh_wait_daemon, orte_event_base, (void*)caddy); caddy 959 orte/mca/plm/rsh/plm_rsh_module.c orte_wait_cb_cancel(caddy->daemon); caddy 991 orte/mca/plm/rsh/plm_rsh_module.c ssh_child(caddy->argc, caddy->argv); caddy 1005 orte/mca/plm/rsh/plm_rsh_module.c caddy->daemon->state = ORTE_PROC_STATE_RUNNING; caddy 1007 orte/mca/plm/rsh/plm_rsh_module.c caddy->daemon->pid = pid; caddy 1012 orte/mca/plm/rsh/plm_rsh_module.c ORTE_NAME_PRINT(&(caddy->daemon->name)))); caddy 1032 orte/mca/plm/rsh/plm_rsh_module.c orte_plm_rsh_caddy_t *caddy; caddy 1263 orte/mca/plm/rsh/plm_rsh_module.c caddy = OBJ_NEW(orte_plm_rsh_caddy_t); caddy 1264 orte/mca/plm/rsh/plm_rsh_module.c caddy->argc = argc; caddy 1265 orte/mca/plm/rsh/plm_rsh_module.c caddy->argv = opal_argv_copy(argv); caddy 1271 orte/mca/plm/rsh/plm_rsh_module.c opal_argv_insert_element(&caddy->argv, node_name_index1+1, "-p"); caddy 1273 orte/mca/plm/rsh/plm_rsh_module.c opal_argv_insert_element(&caddy->argv, node_name_index1+2, portname); caddy 1275 orte/mca/plm/rsh/plm_rsh_module.c caddy->daemon = node->daemon; caddy 1276 orte/mca/plm/rsh/plm_rsh_module.c OBJ_RETAIN(caddy->daemon); caddy 1277 orte/mca/plm/rsh/plm_rsh_module.c opal_list_append(&launch_list, &caddy->super); caddy 119 orte/mca/ras/base/ras_base_allocate.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 122 orte/mca/ras/base/ras_base_allocate.c ORTE_ACQUIRE_OBJECT(caddy); caddy 129 orte/mca/ras/base/ras_base_allocate.c jdata = caddy->jdata; caddy 164 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 185 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 197 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 215 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 227 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 249 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 264 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 299 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 316 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 354 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 371 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 391 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 406 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 427 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 449 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 466 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 477 orte/mca/ras/base/ras_base_allocate.c OBJ_RELEASE(caddy); caddy 49 orte/mca/rmaps/base/rmaps_base_map_job.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 60 orte/mca/rmaps/base/rmaps_base_map_job.c ORTE_ACQUIRE_OBJECT(caddy); caddy 61 orte/mca/rmaps/base/rmaps_base_map_job.c jdata = caddy->jdata; caddy 340 orte/mca/rmaps/base/rmaps_base_map_job.c OBJ_RELEASE(caddy); caddy 490 orte/mca/rmaps/base/rmaps_base_map_job.c OBJ_RELEASE(caddy); caddy 53 orte/mca/state/base/state_base_fns.c orte_state_caddy_t *caddy; caddy 80 orte/mca/state/base/state_base_fns.c caddy = OBJ_NEW(orte_state_caddy_t); caddy 82 orte/mca/state/base/state_base_fns.c caddy->jdata = jdata; caddy 83 orte/mca/state/base/state_base_fns.c caddy->job_state = state; caddy 86 orte/mca/state/base/state_base_fns.c ORTE_THREADSHIFT(caddy, orte_event_base, s->cbfunc, s->priority); caddy 107 orte/mca/state/base/state_base_fns.c caddy = OBJ_NEW(orte_state_caddy_t); caddy 109 orte/mca/state/base/state_base_fns.c caddy->jdata = jdata; caddy 110 orte/mca/state/base/state_base_fns.c caddy->job_state = state; caddy 118 orte/mca/state/base/state_base_fns.c ORTE_THREADSHIFT(caddy, orte_event_base, s->cbfunc, s->priority); caddy 236 orte/mca/state/base/state_base_fns.c orte_state_caddy_t *caddy; caddy 263 orte/mca/state/base/state_base_fns.c caddy = OBJ_NEW(orte_state_caddy_t); caddy 264 orte/mca/state/base/state_base_fns.c caddy->name = *proc; caddy 265 orte/mca/state/base/state_base_fns.c caddy->proc_state = state; caddy 266 orte/mca/state/base/state_base_fns.c ORTE_THREADSHIFT(caddy, orte_event_base, s->cbfunc, s->priority); caddy 287 orte/mca/state/base/state_base_fns.c caddy = OBJ_NEW(orte_state_caddy_t); caddy 288 orte/mca/state/base/state_base_fns.c caddy->name = *proc; caddy 289 orte/mca/state/base/state_base_fns.c caddy->proc_state = state; caddy 295 orte/mca/state/base/state_base_fns.c ORTE_THREADSHIFT(caddy, orte_event_base, s->cbfunc, s->priority); caddy 444 orte/mca/state/base/state_base_fns.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 447 orte/mca/state/base/state_base_fns.c ORTE_ACQUIRE_OBJECT(caddy); caddy 448 orte/mca/state/base/state_base_fns.c jdata = caddy->jdata; caddy 459 orte/mca/state/base/state_base_fns.c OBJ_RELEASE(caddy); caddy 464 orte/mca/state/base/state_base_fns.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 467 orte/mca/state/base/state_base_fns.c ORTE_ACQUIRE_OBJECT(caddy); caddy 468 orte/mca/state/base/state_base_fns.c jdata = caddy->jdata; caddy 473 orte/mca/state/base/state_base_fns.c OBJ_RELEASE(caddy); caddy 630 orte/mca/state/base/state_base_fns.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 638 orte/mca/state/base/state_base_fns.c ORTE_ACQUIRE_OBJECT(caddy); caddy 639 orte/mca/state/base/state_base_fns.c proc = &caddy->name; caddy 640 orte/mca/state/base/state_base_fns.c state = caddy->proc_state; caddy 761 orte/mca/state/base/state_base_fns.c OBJ_RELEASE(caddy); caddy 766 orte/mca/state/base/state_base_fns.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 781 orte/mca/state/base/state_base_fns.c ORTE_ACQUIRE_OBJECT(caddy); caddy 782 orte/mca/state/base/state_base_fns.c jdata = caddy->jdata; caddy 865 orte/mca/state/base/state_base_fns.c OBJ_RELEASE(caddy); caddy 868 orte/mca/state/base/state_base_fns.c OBJ_RELEASE(caddy); caddy 1004 orte/mca/state/base/state_base_fns.c OBJ_RELEASE(caddy); caddy 1029 orte/mca/state/base/state_base_fns.c OBJ_RELEASE(caddy); caddy 98 orte/mca/state/base/state_base_frame.c static void orte_state_caddy_construct(orte_state_caddy_t *caddy) caddy 100 orte/mca/state/base/state_base_frame.c memset(&caddy->ev, 0, sizeof(opal_event_t)); caddy 101 orte/mca/state/base/state_base_frame.c caddy->jdata = NULL; caddy 103 orte/mca/state/base/state_base_frame.c static void orte_state_caddy_destruct(orte_state_caddy_t *caddy) caddy 105 orte/mca/state/base/state_base_frame.c opal_event_del(&caddy->ev); caddy 106 orte/mca/state/base/state_base_frame.c if (NULL != caddy->jdata) { caddy 107 orte/mca/state/base/state_base_frame.c OBJ_RELEASE(caddy->jdata); caddy 134 orte/mca/state/hnp/state_hnp.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 138 orte/mca/state/hnp/state_hnp.c OBJ_RELEASE(caddy); caddy 340 orte/mca/state/hnp/state_hnp.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 341 orte/mca/state/hnp/state_hnp.c orte_job_t *jdata = caddy->jdata; caddy 353 orte/mca/state/hnp/state_hnp.c _send_notification(OPAL_ERR_JOB_TERMINATED, caddy->proc_state, &target, ORTE_NAME_WILDCARD); caddy 357 orte/mca/state/hnp/state_hnp.c _send_notification(OPAL_ERR_JOB_TERMINATED, caddy->proc_state, &target, &parent); caddy 362 orte/mca/state/hnp/state_hnp.c OBJ_RELEASE(caddy); caddy 208 orte/mca/state/novm/state_novm.c ORTE_ACQUIRE_OBJECT(caddy); caddy 263 orte/mca/state/novm/state_novm.c ORTE_ACQUIRE_OBJECT(caddy); caddy 279 orte/mca/state/novm/state_novm.c ORTE_ACQUIRE_OBJECT(caddy); caddy 162 orte/mca/state/orted/state_orted.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 170 orte/mca/state/orted/state_orted.c ORTE_ACQUIRE_OBJECT(caddy); caddy 172 orte/mca/state/orted/state_orted.c if (ORTE_JOB_STATE_LOCAL_LAUNCH_COMPLETE == caddy->job_state) { caddy 176 orte/mca/state/orted/state_orted.c ORTE_JOBID_PRINT(caddy->jdata->jobid))); caddy 187 orte/mca/state/orted/state_orted.c if (ORTE_SUCCESS != (rc = opal_dss.pack(alert, &caddy->jdata->jobid, 1, ORTE_JOBID))) { caddy 197 orte/mca/state/orted/state_orted.c if (child->name.jobid == caddy->jdata->jobid) { caddy 251 orte/mca/state/orted/state_orted.c OBJ_RELEASE(caddy); caddy 256 orte/mca/state/orted/state_orted.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 269 orte/mca/state/orted/state_orted.c ORTE_ACQUIRE_OBJECT(caddy); caddy 270 orte/mca/state/orted/state_orted.c proc = &caddy->name; caddy 271 orte/mca/state/orted/state_orted.c state = caddy->proc_state; caddy 522 orte/mca/state/orted/state_orted.c OBJ_RELEASE(caddy); caddy 2516 orte/orted/orted_submit.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 2517 orte/orted/orted_submit.c orte_job_t *jdata = caddy->jdata; caddy 2536 orte/orted/orted_submit.c OBJ_RELEASE(caddy); caddy 2578 orte/orted/orted_submit.c OBJ_RELEASE(caddy); caddy 2678 orte/orted/orted_submit.c OBJ_RELEASE(caddy); caddy 2683 orte/orted/orted_submit.c OBJ_RELEASE(caddy); caddy 3102 orte/orted/orted_submit.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 3103 orte/orted/orted_submit.c OBJ_RELEASE(caddy); caddy 77 orte/runtime/orte_quit.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata; caddy 79 orte/runtime/orte_quit.c ORTE_ACQUIRE_OBJECT(caddy); caddy 82 orte/runtime/orte_quit.c if (NULL != caddy) { caddy 83 orte/runtime/orte_quit.c OBJ_RELEASE(caddy); caddy 38 orte/test/system/opal-evpri-test.c orte_state_caddy_t *caddy = (orte_state_caddy_t*)arg; caddy 56 orte/test/system/opal-evpri-test.c OBJ_RELEASE(caddy); caddy 63 orte/test/system/opal-evpri-test.c orte_state_caddy_t *caddy; caddy 90 orte/test/system/opal-evpri-test.c caddy = OBJ_NEW(orte_state_caddy_t); caddy 91 orte/test/system/opal-evpri-test.c opal_event_set(orte_event_base, &caddy->ev, -1, OPAL_EV_READ, t1func, caddy); caddy 92 orte/test/system/opal-evpri-test.c opal_event_set_priority(&caddy->ev, ORTE_SYS_PRI); caddy 93 orte/test/system/opal-evpri-test.c opal_event_active(&caddy->ev, OPAL_EV_WRITE, 1);