proct 524 ompi/dpm/dpm.c ompi_proc_t *proct; proct 529 ompi/dpm/dpm.c proct = group->grp_proc_pointers[i]; proct 531 ompi/dpm/dpm.c proct = ompi_group_peer_lookup(group, i); proct 533 ompi/dpm/dpm.c if (NULL == proct) { proct 537 ompi/dpm/dpm.c if (ompi_proc_is_sentinel (proct)) { proct 538 ompi/dpm/dpm.c proc_name = ompi_proc_sentinel_to_name ((uintptr_t)proct); proct 540 ompi/dpm/dpm.c proc_name = proct->super.proc_name; proct 94 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_query(pmix_proc_t *proct, proct 949 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_query(pmix_proc_t *proct, proct 971 opal/mca/pmix/ext2x/ext2x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 975 opal/mca/pmix/ext2x/ext2x_server_north.c requestor.vpid = ext2x_convert_rank(proct->rank); proct 1076 opal/mca/pmix/ext2x/ext2x_server_north.c static void server_log(const pmix_proc_t *proct, proct 1101 opal/mca/pmix/ext2x/ext2x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1109 opal/mca/pmix/ext2x/ext2x_server_north.c requestor.vpid = ext2x_convert_rank(proct->rank); proct 1151 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_allocate(const pmix_proc_t *proct, proct 1173 opal/mca/pmix/ext2x/ext2x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1177 opal/mca/pmix/ext2x/ext2x_server_north.c requestor.vpid = ext2x_convert_rank(proct->rank); proct 1204 opal/mca/pmix/ext2x/ext2x_server_north.c static pmix_status_t server_job_control(const pmix_proc_t *proct, proct 1226 opal/mca/pmix/ext2x/ext2x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1230 opal/mca/pmix/ext2x/ext2x_server_north.c requestor.vpid = ext2x_convert_rank(proct->rank); proct 94 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_query(pmix_proc_t *proct, proct 965 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_query(pmix_proc_t *proct, proct 987 opal/mca/pmix/ext3x/ext3x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 991 opal/mca/pmix/ext3x/ext3x_server_north.c requestor.vpid = ext3x_convert_rank(proct->rank); proct 1128 opal/mca/pmix/ext3x/ext3x_server_north.c static void server_log(const pmix_proc_t *proct, proct 1153 opal/mca/pmix/ext3x/ext3x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1161 opal/mca/pmix/ext3x/ext3x_server_north.c requestor.vpid = ext3x_convert_rank(proct->rank); proct 1203 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_allocate(const pmix_proc_t *proct, proct 1225 opal/mca/pmix/ext3x/ext3x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1229 opal/mca/pmix/ext3x/ext3x_server_north.c requestor.vpid = ext3x_convert_rank(proct->rank); proct 1256 opal/mca/pmix/ext3x/ext3x_server_north.c static pmix_status_t server_job_control(const pmix_proc_t *proct, proct 1278 opal/mca/pmix/ext3x/ext3x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1282 opal/mca/pmix/ext3x/ext3x_server_north.c requestor.vpid = ext3x_convert_rank(proct->rank); proct 95 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t query_fn(pmix_proc_t *proct, proct 810 opal/mca/pmix/pmix4x/pmix/examples/server.c static pmix_status_t query_fn(pmix_proc_t *proct, proct 290 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h typedef pmix_status_t (*pmix_server_query_fn_t)(pmix_proc_t *proct, proct 1506 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_proc_t proct; proct 1526 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c &pbkt, &proct, &cnt, PMIX_PROC); proct 1541 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c PMIX_GDS_STORE_KV(rc, pmix_globals.mypeer, &proct, PMIX_INTERNAL, kv); proct 92 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t query_fn(pmix_proc_t *proct, proct 962 opal/mca/pmix/pmix4x/pmix/test/simple/gwtest.c static pmix_status_t query_fn(pmix_proc_t *proct, proct 98 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t query_fn(pmix_proc_t *proct, proct 1120 opal/mca/pmix/pmix4x/pmix/test/simple/simptest.c static pmix_status_t query_fn(pmix_proc_t *proct, proct 98 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t query_fn(pmix_proc_t *proct, proct 798 opal/mca/pmix/pmix4x/pmix/test/simple/stability.c static pmix_status_t query_fn(pmix_proc_t *proct, proct 93 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_query(pmix_proc_t *proct, proct 964 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_query(pmix_proc_t *proct, proct 986 opal/mca/pmix/pmix4x/pmix4x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 990 opal/mca/pmix/pmix4x/pmix4x_server_north.c requestor.vpid = pmix4x_convert_rank(proct->rank); proct 1127 opal/mca/pmix/pmix4x/pmix4x_server_north.c static void server_log(const pmix_proc_t *proct, proct 1152 opal/mca/pmix/pmix4x/pmix4x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1160 opal/mca/pmix/pmix4x/pmix4x_server_north.c requestor.vpid = pmix4x_convert_rank(proct->rank); proct 1202 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_allocate(const pmix_proc_t *proct, proct 1224 opal/mca/pmix/pmix4x/pmix4x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1228 opal/mca/pmix/pmix4x/pmix4x_server_north.c requestor.vpid = pmix4x_convert_rank(proct->rank); proct 1255 opal/mca/pmix/pmix4x/pmix4x_server_north.c static pmix_status_t server_job_control(const pmix_proc_t *proct, proct 1277 opal/mca/pmix/pmix4x/pmix4x_server_north.c if (OPAL_SUCCESS != (rc = opal_convert_string_to_jobid(&requestor.jobid, proct->nspace))) { proct 1281 opal/mca/pmix/pmix4x/pmix4x_server_north.c requestor.vpid = pmix4x_convert_rank(proct->rank); proct 355 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c orte_proc_t *pptr, *proct; proct 416 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (NULL != (proct = (orte_proc_t*)opal_pointer_array_get_item(orte_local_children, i)) && proct 417 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_FLAG_TEST(pptr, ORTE_PROC_FLAG_ALIVE) && proct->state < ORTE_PROC_STATE_UNTERMINATED) { proct 422 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c ORTE_NAME_PRINT(&proct->name))); proct 485 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (NULL != (proct = (orte_proc_t*)opal_pointer_array_get_item(orte_local_children, i))) { proct 486 orte/mca/errmgr/default_hnp/errmgr_default_hnp.c if (ORTE_FLAG_TEST(proct, ORTE_PROC_FLAG_ALIVE)) { proct 251 orte/mca/iof/base/iof_base_frame.c orte_iof_proc_t *proct = (orte_iof_proc_t*)rev->proc; proct 258 orte/mca/iof/base/iof_base_frame.c (NULL == proct) ? "UNKNOWN" : ORTE_NAME_PRINT(&proct->name))); proct 265 orte/mca/iof/base/iof_base_frame.c if (NULL != proct) { proct 266 orte/mca/iof/base/iof_base_frame.c OBJ_RELEASE(proct); proct 286 orte/mca/iof/base/iof_base_setup.c orte_iof_proc_t *proct) proct 315 orte/mca/iof/base/iof_base_setup.c proct->copy = false; proct 323 orte/mca/iof/base/iof_base_setup.c (int)ORTE_LOCAL_JOBID(proct->name.jobid), proct 324 orte/mca/iof/base/iof_base_setup.c numdigs, (unsigned long)proct->name.vpid); proct 327 orte/mca/iof/base/iof_base_setup.c numdigs, (unsigned long)proct->name.vpid); proct 335 orte/mca/iof/base/iof_base_setup.c if (NULL != proct->revstdout && NULL == proct->revstdout->sink) { proct 346 orte/mca/iof/base/iof_base_setup.c ORTE_IOF_SINK_DEFINE(&proct->revstdout->sink, dst_name, proct 351 orte/mca/iof/base/iof_base_setup.c if (NULL != proct->revstderr && NULL == proct->revstderr->sink) { proct 357 orte/mca/iof/base/iof_base_setup.c OBJ_RETAIN(proct->revstdout->sink); proct 358 orte/mca/iof/base/iof_base_setup.c proct->revstdout->sink->tag = ORTE_IOF_STDMERGE; // show that it is merged proct 359 orte/mca/iof/base/iof_base_setup.c proct->revstderr->sink = proct->revstdout->sink; proct 370 orte/mca/iof/base/iof_base_setup.c ORTE_IOF_SINK_DEFINE(&proct->revstderr->sink, dst_name, proct 376 orte/mca/iof/base/iof_base_setup.c if (NULL != proct->revstddiag && NULL == proct->revstddiag->sink) { proct 378 orte/mca/iof/base/iof_base_setup.c OBJ_RETAIN(proct->revstderr->sink); proct 379 orte/mca/iof/base/iof_base_setup.c proct->revstddiag->sink = proct->revstderr->sink; proct 62 orte/mca/iof/base/iof_base_setup.h orte_iof_proc_t *proct); proct 138 orte/mca/iof/hnp/iof_hnp.c orte_iof_proc_t *proct, *pptr; proct 153 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { proct 154 orte/mca/iof/hnp/iof_hnp.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &proct->name, dst_name)) { proct 160 orte/mca/iof/hnp/iof_hnp.c proct = OBJ_NEW(orte_iof_proc_t); proct 161 orte/mca/iof/hnp/iof_hnp.c proct->name.jobid = dst_name->jobid; proct 162 orte/mca/iof/hnp/iof_hnp.c proct->name.vpid = dst_name->vpid; proct 163 orte/mca/iof/hnp/iof_hnp.c opal_list_append(&mca_iof_hnp_component.procs, &proct->super); proct 178 orte/mca/iof/hnp/iof_hnp.c if (NULL == (jdata = orte_get_job_data_object(proct->name.jobid))) { proct 184 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_EVENT(&proct->revstdout, proct, fd, ORTE_IOF_STDOUT, proct 187 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_EVENT(&proct->revstderr, proct, fd, ORTE_IOF_STDERR, proct 191 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_EVENT(&proct->revstddiag, proct, fd, ORTE_IOF_STDDIAG, proct 196 orte/mca/iof/hnp/iof_hnp.c if (ORTE_SUCCESS != (rc = orte_iof_base_setup_output_files(dst_name, jdata, proct))) { proct 206 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->revstdout && proct 208 orte/mca/iof/hnp/iof_hnp.c NULL != proct->revstddiag && proct 210 orte/mca/iof/hnp/iof_hnp.c (orte_iof_base.redirect_app_stderr_to_stdout || NULL != proct->revstderr)) { proct 211 orte/mca/iof/hnp/iof_hnp.c if (proct->copy) { proct 219 orte/mca/iof/hnp/iof_hnp.c proct->subscribers = pptr->subscribers; proct 224 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_ACTIVATE(proct->revstdout); proct 226 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_ACTIVATE(proct->revstderr); proct 229 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->revstddiag) { proct 230 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_ACTIVATE(proct->revstddiag); proct 242 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_SINK_DEFINE(&proct->stdinev, dst_name, -1, ORTE_IOF_STDIN, proct 244 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.jobid = ORTE_PROC_MY_NAME->jobid; proct 245 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.vpid = ORTE_VPID_WILDCARD; proct 258 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_SINK_DEFINE(&proct->stdinev, dst_name, -1, ORTE_IOF_STDIN, proct 260 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.jobid = ORTE_PROC_MY_NAME->jobid; proct 261 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.vpid = proc->node->daemon->name.vpid; proct 304 orte/mca/iof/hnp/iof_hnp.c proct, fd, ORTE_IOF_STDIN, proct 319 orte/mca/iof/hnp/iof_hnp.c proct, fd, ORTE_IOF_STDIN, proct 336 orte/mca/iof/hnp/iof_hnp.c orte_iof_proc_t *proct; proct 362 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { proct 363 orte/mca/iof/hnp/iof_hnp.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &proct->name, dst_name)) { proct 369 orte/mca/iof/hnp/iof_hnp.c proct = OBJ_NEW(orte_iof_proc_t); proct 370 orte/mca/iof/hnp/iof_hnp.c proct->name.jobid = dst_name->jobid; proct 371 orte/mca/iof/hnp/iof_hnp.c proct->name.vpid = dst_name->vpid; proct 372 orte/mca/iof/hnp/iof_hnp.c opal_list_append(&mca_iof_hnp_component.procs, &proct->super); proct 375 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_SINK_DEFINE(&proct->stdinev, dst_name, fd, ORTE_IOF_STDIN, proct 377 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.jobid = ORTE_PROC_MY_NAME->jobid; proct 378 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.vpid = ORTE_PROC_MY_NAME->vpid; proct 390 orte/mca/iof/hnp/iof_hnp.c orte_iof_proc_t* proct; proct 393 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { proct 394 orte/mca/iof/hnp/iof_hnp.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &proct->name, peer)) { proct 396 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->stdinev) { proct 397 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(proct->stdinev); proct 399 orte/mca/iof/hnp/iof_hnp.c proct->stdinev = NULL; proct 403 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->revstdout) { proct 404 orte/mca/iof/hnp/iof_hnp.c orte_iof_base_static_dump_output(proct->revstdout); proct 405 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(proct->revstdout); proct 407 orte/mca/iof/hnp/iof_hnp.c proct->revstdout = NULL; proct 410 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->revstderr) { proct 411 orte/mca/iof/hnp/iof_hnp.c orte_iof_base_static_dump_output(proct->revstderr); proct 412 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(proct->revstderr); proct 414 orte/mca/iof/hnp/iof_hnp.c proct->revstderr = NULL; proct 418 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->revstddiag) { proct 419 orte/mca/iof/hnp/iof_hnp.c orte_iof_base_static_dump_output(proct->revstddiag); proct 420 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(proct->revstddiag); proct 422 orte/mca/iof/hnp/iof_hnp.c proct->revstddiag = NULL; proct 426 orte/mca/iof/hnp/iof_hnp.c if (NULL == proct->stdinev && proct 427 orte/mca/iof/hnp/iof_hnp.c NULL == proct->revstdout && proct 429 orte/mca/iof/hnp/iof_hnp.c NULL == proct->revstddiag && proct 431 orte/mca/iof/hnp/iof_hnp.c NULL == proct->revstderr) { proct 432 orte/mca/iof/hnp/iof_hnp.c opal_list_remove_item(&mca_iof_hnp_component.procs, &proct->super); proct 433 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(proct); proct 443 orte/mca/iof/hnp/iof_hnp.c orte_iof_proc_t *proct, *next; proct 446 orte/mca/iof/hnp/iof_hnp.c OPAL_LIST_FOREACH_SAFE(proct, next, &mca_iof_hnp_component.procs, orte_iof_proc_t) { proct 447 orte/mca/iof/hnp/iof_hnp.c if (jdata->jobid == proct->name.jobid) { proct 448 orte/mca/iof/hnp/iof_hnp.c opal_list_remove_item(&mca_iof_hnp_component.procs, &proct->super); proct 449 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(proct); proct 457 orte/mca/iof/hnp/iof_hnp.c orte_iof_proc_t *proct; proct 499 orte/mca/iof/hnp/iof_hnp.c while (NULL != (proct = (orte_iof_proc_t*)opal_list_remove_first(&mca_iof_hnp_component.procs))) { proct 500 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->revstdout) { proct 501 orte/mca/iof/hnp/iof_hnp.c orte_iof_base_static_dump_output(proct->revstdout); proct 503 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->revstderr) { proct 504 orte/mca/iof/hnp/iof_hnp.c orte_iof_base_static_dump_output(proct->revstderr); proct 507 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->revstddiag) { proct 508 orte/mca/iof/hnp/iof_hnp.c orte_iof_base_static_dump_output(proct->revstddiag); proct 511 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(proct); proct 106 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_proc_t *proct = (orte_iof_proc_t*)rev->proc; proct 123 orte/mca/iof/hnp/iof_hnp_read.c if (NULL == proct) { proct 141 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(&proct->name), fd)); proct 154 orte/mca/iof/hnp/iof_hnp_read.c if (NULL == proct->stdinev) { proct 167 orte/mca/iof/hnp/iof_hnp_read.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, ORTE_PROC_MY_NAME, &proct->stdinev->daemon)) { proct 171 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(&proct->name))); proct 176 orte/mca/iof/hnp/iof_hnp_read.c if (NULL != proct->stdinev->wev) { proct 177 orte/mca/iof/hnp/iof_hnp_read.c if (ORTE_IOF_MAX_INPUT_BUFFERS < orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, proct->stdinev->wev)) { proct 189 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(&proct->stdinev->daemon))); proct 199 orte/mca/iof/hnp/iof_hnp_read.c if( ORTE_SUCCESS != (rc = orte_iof_hnp_send_data_to_endpoint(&proct->stdinev->daemon, &proct->stdinev->name, ORTE_IOF_STDIN, data, numbytes))) { proct 209 orte/mca/iof/hnp/iof_hnp_read.c if (0 != opal_list_get_size(&proct->stdinev->wev->outputs)) { proct 211 orte/mca/iof/hnp/iof_hnp_read.c proct->stdinev->closed = true; proct 214 orte/mca/iof/hnp/iof_hnp_read.c OBJ_RELEASE(proct->stdinev); proct 236 orte/mca/iof/hnp/iof_hnp_read.c if (NULL != proct->subscribers) { proct 237 orte/mca/iof/hnp/iof_hnp_read.c OPAL_LIST_FOREACH(sink, proct->subscribers, orte_iof_sink_t) { proct 243 orte/mca/iof/hnp/iof_hnp_read.c sink->name.jobid == proct->name.jobid && proct 244 orte/mca/iof/hnp/iof_hnp_read.c (ORTE_VPID_WILDCARD == sink->name.vpid || sink->name.vpid == proct->name.vpid)) { proct 258 orte/mca/iof/hnp/iof_hnp_read.c rc = opal_pmix.server_iof_push(&proct->name, rev->tag, data, numbytes); proct 268 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_hnp_send_data_to_endpoint(&sink->daemon, &proct->name, rev->tag, data, numbytes)); proct 281 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(&proct->name))); proct 288 orte/mca/iof/hnp/iof_hnp_read.c OBJ_RETAIN(proct); proct 290 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_static_dump_output(proct->revstdout); proct 291 orte/mca/iof/hnp/iof_hnp_read.c OBJ_RELEASE(proct->revstdout); proct 293 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_static_dump_output(proct->revstderr); proct 294 orte/mca/iof/hnp/iof_hnp_read.c OBJ_RELEASE(proct->revstderr); proct 297 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_static_dump_output(proct->revstddiag); proct 298 orte/mca/iof/hnp/iof_hnp_read.c OBJ_RELEASE(proct->revstddiag); proct 302 orte/mca/iof/hnp/iof_hnp_read.c if (NULL == proct->revstdout && proct 304 orte/mca/iof/hnp/iof_hnp_read.c NULL == proct->revstddiag && proct 306 orte/mca/iof/hnp/iof_hnp_read.c NULL == proct->revstderr) { proct 308 orte/mca/iof/hnp/iof_hnp_read.c ORTE_ACTIVATE_PROC_STATE(&proct->name, ORTE_PROC_STATE_IOF_COMPLETE); proct 310 orte/mca/iof/hnp/iof_hnp_read.c OBJ_RELEASE(proct); proct 314 orte/mca/iof/hnp/iof_hnp_read.c if (proct->copy) { proct 315 orte/mca/iof/hnp/iof_hnp_read.c if (NULL != proct->subscribers) { proct 319 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, orte_iof_base.iof_write_stdout->wev); proct 321 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, orte_iof_base.iof_write_stderr->wev); proct 327 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, orte_iof_base.iof_write_stdout->wev); proct 329 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, orte_iof_base.iof_write_stderr->wev); proct 336 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev); proct 66 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_proc_t *proct; proct 132 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { proct 133 orte/mca/iof/hnp/iof_hnp_receive.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &proct->name, &origin)) { proct 139 orte/mca/iof/hnp/iof_hnp_receive.c proct = OBJ_NEW(orte_iof_proc_t); proct 140 orte/mca/iof/hnp/iof_hnp_receive.c proct->name.jobid = origin.jobid; proct 141 orte/mca/iof/hnp/iof_hnp_receive.c proct->name.vpid = origin.vpid; proct 142 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(&mca_iof_hnp_component.procs, &proct->super); proct 148 orte/mca/iof/hnp/iof_hnp_receive.c if (NULL == proct->subscribers) { proct 149 orte/mca/iof/hnp/iof_hnp_receive.c proct->subscribers = OBJ_NEW(opal_list_t); proct 156 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(proct->subscribers, &sink->super); proct 163 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(proct->subscribers, &sink->super); proct 170 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(proct->subscribers, &sink->super); proct 184 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { proct 185 orte/mca/iof/hnp/iof_hnp_receive.c if (OPAL_EQUAL != orte_util_compare_name_fields(mask, &proct->name, &origin)) { proct 188 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH_SAFE(sink, next, proct->subscribers, orte_iof_sink_t) { proct 203 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_remove_item(proct->subscribers, &sink->super); proct 225 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH(proct, &mca_iof_hnp_component.procs, orte_iof_proc_t) { proct 226 orte/mca/iof/hnp/iof_hnp_receive.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &proct->name, &origin)) { proct 232 orte/mca/iof/hnp/iof_hnp_receive.c proct = OBJ_NEW(orte_iof_proc_t); proct 233 orte/mca/iof/hnp/iof_hnp_receive.c proct->name.jobid = origin.jobid; proct 234 orte/mca/iof/hnp/iof_hnp_receive.c proct->name.vpid = origin.vpid; proct 235 orte/mca/iof/hnp/iof_hnp_receive.c opal_list_append(&mca_iof_hnp_component.procs, &proct->super); proct 240 orte/mca/iof/hnp/iof_hnp_receive.c if (NULL != proct->subscribers) { proct 241 orte/mca/iof/hnp/iof_hnp_receive.c OPAL_LIST_FOREACH(sink, proct->subscribers, orte_iof_sink_t) { proct 255 orte/mca/iof/hnp/iof_hnp_receive.c rc = opal_pmix.server_iof_push(&proct->name, stream, data, numbytes); proct 270 orte/mca/iof/hnp/iof_hnp_receive.c if (!proct->copy) { proct 131 orte/mca/iof/orted/iof_orted.c orte_iof_proc_t *proct; proct 153 orte/mca/iof/orted/iof_orted.c OPAL_LIST_FOREACH(proct, &mca_iof_orted_component.procs, orte_iof_proc_t) { proct 156 orte/mca/iof/orted/iof_orted.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &proct->name, dst_name)) { proct 162 orte/mca/iof/orted/iof_orted.c proct = OBJ_NEW(orte_iof_proc_t); proct 163 orte/mca/iof/orted/iof_orted.c proct->name.jobid = dst_name->jobid; proct 164 orte/mca/iof/orted/iof_orted.c proct->name.vpid = dst_name->vpid; proct 165 orte/mca/iof/orted/iof_orted.c opal_list_append(&mca_iof_orted_component.procs, &proct->super); proct 169 orte/mca/iof/orted/iof_orted.c if (NULL == (jobdat = orte_get_job_data_object(proct->name.jobid))) { proct 175 orte/mca/iof/orted/iof_orted.c ORTE_IOF_READ_EVENT(&proct->revstdout, proct, fd, ORTE_IOF_STDOUT, proct 178 orte/mca/iof/orted/iof_orted.c ORTE_IOF_READ_EVENT(&proct->revstderr, proct, fd, ORTE_IOF_STDERR, proct 182 orte/mca/iof/orted/iof_orted.c ORTE_IOF_READ_EVENT(&proct->revstddiag, proct, fd, ORTE_IOF_STDDIAG, proct 187 orte/mca/iof/orted/iof_orted.c if (ORTE_SUCCESS != (rc = orte_iof_base_setup_output_files(dst_name, jobdat, proct))) { proct 197 orte/mca/iof/orted/iof_orted.c if (NULL != proct->revstdout && proct 199 orte/mca/iof/orted/iof_orted.c NULL != proct->revstddiag && proct 201 orte/mca/iof/orted/iof_orted.c (orte_iof_base.redirect_app_stderr_to_stdout || NULL != proct->revstderr)) { proct 202 orte/mca/iof/orted/iof_orted.c ORTE_IOF_READ_ACTIVATE(proct->revstdout); proct 204 orte/mca/iof/orted/iof_orted.c ORTE_IOF_READ_ACTIVATE(proct->revstderr); proct 207 orte/mca/iof/orted/iof_orted.c if (NULL != proct->revstddiag) { proct 208 orte/mca/iof/orted/iof_orted.c ORTE_IOF_READ_ACTIVATE(proct->revstddiag); proct 229 orte/mca/iof/orted/iof_orted.c orte_iof_proc_t *proct; proct 255 orte/mca/iof/orted/iof_orted.c OPAL_LIST_FOREACH(proct, &mca_iof_orted_component.procs, orte_iof_proc_t) { proct 256 orte/mca/iof/orted/iof_orted.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &proct->name, dst_name)) { proct 262 orte/mca/iof/orted/iof_orted.c proct = OBJ_NEW(orte_iof_proc_t); proct 263 orte/mca/iof/orted/iof_orted.c proct->name.jobid = dst_name->jobid; proct 264 orte/mca/iof/orted/iof_orted.c proct->name.vpid = dst_name->vpid; proct 265 orte/mca/iof/orted/iof_orted.c opal_list_append(&mca_iof_orted_component.procs, &proct->super); proct 268 orte/mca/iof/orted/iof_orted.c ORTE_IOF_SINK_DEFINE(&proct->stdinev, dst_name, fd, ORTE_IOF_STDIN, proct 283 orte/mca/iof/orted/iof_orted.c orte_iof_proc_t* proct; proct 286 orte/mca/iof/orted/iof_orted.c OPAL_LIST_FOREACH(proct, &mca_iof_orted_component.procs, orte_iof_proc_t) { proct 287 orte/mca/iof/orted/iof_orted.c if (OPAL_EQUAL == orte_util_compare_name_fields(mask, &proct->name, peer)) { proct 289 orte/mca/iof/orted/iof_orted.c if (NULL != proct->stdinev) { proct 290 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(proct->stdinev); proct 292 orte/mca/iof/orted/iof_orted.c proct->stdinev = NULL; proct 296 orte/mca/iof/orted/iof_orted.c if (NULL != proct->revstdout) { proct 297 orte/mca/iof/orted/iof_orted.c orte_iof_base_static_dump_output(proct->revstdout); proct 298 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(proct->revstdout); proct 300 orte/mca/iof/orted/iof_orted.c proct->revstdout = NULL; proct 303 orte/mca/iof/orted/iof_orted.c if (NULL != proct->revstderr) { proct 304 orte/mca/iof/orted/iof_orted.c orte_iof_base_static_dump_output(proct->revstderr); proct 305 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(proct->revstderr); proct 307 orte/mca/iof/orted/iof_orted.c proct->revstderr = NULL; proct 311 orte/mca/iof/orted/iof_orted.c if (NULL != proct->revstddiag) { proct 312 orte/mca/iof/orted/iof_orted.c orte_iof_base_static_dump_output(proct->revstddiag); proct 313 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(proct->revstddiag); proct 315 orte/mca/iof/orted/iof_orted.c proct->revstddiag = NULL; proct 319 orte/mca/iof/orted/iof_orted.c if (NULL == proct->stdinev && proct 320 orte/mca/iof/orted/iof_orted.c NULL == proct->revstdout && proct 322 orte/mca/iof/orted/iof_orted.c NULL == proct->revstddiag && proct 324 orte/mca/iof/orted/iof_orted.c NULL == proct->revstderr) { proct 325 orte/mca/iof/orted/iof_orted.c opal_list_remove_item(&mca_iof_orted_component.procs, &proct->super); proct 326 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(proct); proct 337 orte/mca/iof/orted/iof_orted.c orte_iof_proc_t *proct, *next; proct 340 orte/mca/iof/orted/iof_orted.c OPAL_LIST_FOREACH_SAFE(proct, next, &mca_iof_orted_component.procs, orte_iof_proc_t) { proct 341 orte/mca/iof/orted/iof_orted.c if (jdata->jobid == proct->name.jobid) { proct 342 orte/mca/iof/orted/iof_orted.c opal_list_remove_item(&mca_iof_orted_component.procs, &proct->super); proct 343 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(proct); proct 350 orte/mca/iof/orted/iof_orted.c orte_iof_proc_t *proct; proct 354 orte/mca/iof/orted/iof_orted.c while (NULL != (proct = (orte_iof_proc_t*)opal_list_remove_first(&mca_iof_orted_component.procs))) { proct 355 orte/mca/iof/orted/iof_orted.c if (NULL != proct->revstdout) { proct 356 orte/mca/iof/orted/iof_orted.c orte_iof_base_static_dump_output(proct->revstdout); proct 358 orte/mca/iof/orted/iof_orted.c if (NULL != proct->revstderr) { proct 359 orte/mca/iof/orted/iof_orted.c orte_iof_base_static_dump_output(proct->revstderr); proct 362 orte/mca/iof/orted/iof_orted.c if (NULL != proct->revstddiag) { proct 363 orte/mca/iof/orted/iof_orted.c orte_iof_base_static_dump_output(proct->revstddiag); proct 366 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(proct); proct 54 orte/mca/iof/orted/iof_orted_read.c orte_iof_proc_t *proct = (orte_iof_proc_t*)rev->proc; proct 75 orte/mca/iof/orted/iof_orted_read.c if (NULL == proct) { proct 84 orte/mca/iof/orted/iof_orted_read.c numbytes, ORTE_NAME_PRINT(&proct->name), fd)); proct 98 orte/mca/iof/orted/iof_orted_read.c ORTE_NAME_PRINT(&proct->name), fd)); proct 107 orte/mca/iof/orted/iof_orted_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev); proct 109 orte/mca/iof/orted/iof_orted_read.c if (!proct->copy) { proct 127 orte/mca/iof/orted/iof_orted_read.c if (ORTE_SUCCESS != (rc = opal_dss.pack(buf, &proct->name, 1, ORTE_NAME))) { proct 157 orte/mca/iof/orted/iof_orted_read.c if( NULL != proct->revstdout ) { proct 158 orte/mca/iof/orted/iof_orted_read.c orte_iof_base_static_dump_output(proct->revstdout); proct 159 orte/mca/iof/orted/iof_orted_read.c OBJ_RELEASE(proct->revstdout); proct 162 orte/mca/iof/orted/iof_orted_read.c if( NULL != proct->revstderr ) { proct 163 orte/mca/iof/orted/iof_orted_read.c orte_iof_base_static_dump_output(proct->revstderr); proct 164 orte/mca/iof/orted/iof_orted_read.c OBJ_RELEASE(proct->revstderr); proct 168 orte/mca/iof/orted/iof_orted_read.c if( NULL != proct->revstddiag ) { proct 169 orte/mca/iof/orted/iof_orted_read.c orte_iof_base_static_dump_output(proct->revstddiag); proct 170 orte/mca/iof/orted/iof_orted_read.c OBJ_RELEASE(proct->revstddiag); proct 175 orte/mca/iof/orted/iof_orted_read.c if (NULL == proct->revstdout && proct 177 orte/mca/iof/orted/iof_orted_read.c NULL == proct->revstddiag && proct 179 orte/mca/iof/orted/iof_orted_read.c NULL == proct->revstderr) { proct 181 orte/mca/iof/orted/iof_orted_read.c ORTE_ACTIVATE_PROC_STATE(&proct->name, ORTE_PROC_STATE_IOF_COMPLETE); proct 97 orte/mca/iof/orted/iof_orted_receive.c orte_iof_proc_t *proct; proct 134 orte/mca/iof/orted/iof_orted_receive.c OPAL_LIST_FOREACH(proct, &mca_iof_orted_component.procs, orte_iof_proc_t) { proct 136 orte/mca/iof/orted/iof_orted_receive.c if (target.jobid == proct->name.jobid) { proct 139 orte/mca/iof/orted/iof_orted_receive.c proct->name.vpid == target.vpid) { proct 143 orte/mca/iof/orted/iof_orted_receive.c ORTE_NAME_PRINT(&proct->name))); proct 144 orte/mca/iof/orted/iof_orted_receive.c if (NULL == proct->stdinev) { proct 151 orte/mca/iof/orted/iof_orted_receive.c if (ORTE_IOF_MAX_INPUT_BUFFERS < orte_iof_base_write_output(&target, stream, data, numbytes, proct->stdinev->wev)) { proct 113 orte/orted/orted_comm.c orte_proc_t *proct; proct 164 orte/orted/orted_comm.c proct = OBJ_NEW(orte_proc_t); proct 165 orte/orted/orted_comm.c proct->name.jobid = proc.jobid; proct 166 orte/orted/orted_comm.c proct->name.vpid = proc.vpid; proct 168 orte/orted/orted_comm.c opal_pointer_array_add(&procarray, proct); proct 192 orte/orted/orted_comm.c if (NULL != (proct = (orte_proc_t*)opal_pointer_array_get_item(&procarray, i))) { proct 193 orte/orted/orted_comm.c free(proct); proct 386 orte/orted/orted_comm.c if (NULL != (proct = (orte_proc_t*)opal_pointer_array_get_item(orte_local_children, i)) && proct 387 orte/orted/orted_comm.c ORTE_FLAG_TEST(proct, ORTE_PROC_FLAG_ALIVE)) { proct 392 orte/orted/orted_comm.c ORTE_NAME_PRINT(&proct->name)); proct 428 orte/orted/orted_comm.c if (NULL != (proct = (orte_proc_t*)opal_pointer_array_get_item(orte_local_children, i)) && proct 429 orte/orted/orted_comm.c ORTE_FLAG_TEST(proct, ORTE_PROC_FLAG_ALIVE)) { proct 605 orte/orted/orted_comm.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(node->procs, i))) { proct 608 orte/orted/orted_comm.c if (proct->name.jobid != jdata->jobid) { proct 617 orte/orted/orted_comm.c OBJ_RELEASE(proct); proct 1274 orte/orted/orted_comm.c if (NULL != (proct = (orte_proc_t*)opal_pointer_array_get_item(orte_local_children, i)) && proct 1275 orte/orted/orted_comm.c ORTE_FLAG_TEST(proct, ORTE_PROC_FLAG_ALIVE)) { proct 1277 orte/orted/orted_comm.c if (OPAL_SUCCESS != opal_dss.pack(relay_msg, &proct->name, 1, ORTE_NAME) || proct 1278 orte/orted/orted_comm.c OPAL_SUCCESS != opal_dss.pack(relay_msg, &proct->node->name, 1, OPAL_STRING) || proct 1279 orte/orted/orted_comm.c OPAL_SUCCESS != opal_dss.pack(relay_msg, &proct->pid, 1, OPAL_PID)) { proct 1289 orte/orted/orted_comm.c gstack_exec, (unsigned long) proct->pid); proct 1300 orte/orted/orted_comm.c proct->node->name); proct 1352 orte/orted/orted_comm.c if (NULL != (proct = (orte_proc_t*)opal_pointer_array_get_item(orte_local_children, i)) && proct 1353 orte/orted/orted_comm.c ORTE_FLAG_TEST(proct, ORTE_PROC_FLAG_ALIVE)) { proct 1356 orte/orted/orted_comm.c if (OPAL_SUCCESS == opal_pstat.query(proct->pid, &pstat, NULL)) { proct 136 orte/orted/pmix/pmix_server_fence.c orte_proc_t *proct, *dmn; proct 215 orte/orted/pmix/pmix_server_fence.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, req->target.vpid))) { proct 222 orte/orted/pmix/pmix_server_fence.c if (NULL == (dmn = proct->node->daemon)) { proct 490 orte/orted/pmix/pmix_server_gen.c orte_proc_t *proct; proct 623 orte/orted/pmix/pmix_server_gen.c if (NULL != (proct = (orte_proc_t*)opal_pointer_array_get_item(orte_local_children, i)) && proct 624 orte/orted/pmix/pmix_server_gen.c ORTE_FLAG_TEST(proct, ORTE_PROC_FLAG_ALIVE)) { proct 627 orte/orted/pmix/pmix_server_gen.c if (OPAL_SUCCESS == opal_pstat.query(proct->pid, &pstat, NULL)) { proct 738 orte/orted/pmix/pmix_server_gen.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, k))) { proct 744 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.name.vpid = proct->name.vpid; proct 745 orte/orted/pmix/pmix_server_gen.c if (NULL != proct->node && NULL != proct->node->name) { proct 746 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.hostname = strdup(proct->node->name); proct 748 orte/orted/pmix/pmix_server_gen.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, proct->app_idx); proct 752 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.pid = proct->pid; proct 753 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.exit_code = proct->exit_code; proct 754 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.state = proct->state; proct 787 orte/orted/pmix/pmix_server_gen.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, k))) { proct 790 orte/orted/pmix/pmix_server_gen.c if (ORTE_FLAG_TEST(proct, ORTE_PROC_FLAG_LOCAL)) { proct 794 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.name.vpid = proct->name.vpid; proct 795 orte/orted/pmix/pmix_server_gen.c if (NULL != proct->node && NULL != proct->node->name) { proct 796 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.hostname = strdup(proct->node->name); proct 798 orte/orted/pmix/pmix_server_gen.c app = (orte_app_context_t*)opal_pointer_array_get_item(jdata->apps, proct->app_idx); proct 802 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.pid = proct->pid; proct 803 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.exit_code = proct->exit_code; proct 804 orte/orted/pmix/pmix_server_gen.c kv->data.pinfo.state = proct->state; proct 426 orte/runtime/orte_globals.c orte_proc_t *proct; proct 431 orte/runtime/orte_globals.c proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid); proct 432 orte/runtime/orte_globals.c return proct; proct 438 orte/runtime/orte_globals.c orte_proc_t *proct; proct 443 orte/runtime/orte_globals.c if (NULL == (proct = (orte_proc_t*)opal_pointer_array_get_item(jdata->procs, proc->vpid))) { proct 446 orte/runtime/orte_globals.c if (NULL == proct->node || NULL == proct->node->daemon) { proct 449 orte/runtime/orte_globals.c return proct->node->daemon->name.vpid; proct 454 orte/runtime/orte_globals.c orte_proc_t *proct; proct 469 orte/runtime/orte_globals.c if (NULL == (proct = orte_get_proc_object(proc))) { proct 472 orte/runtime/orte_globals.c if (NULL == proct->node || NULL == proct->node->name) { proct 475 orte/runtime/orte_globals.c return proct->node->name; proct 489 orte/runtime/orte_globals.c orte_proc_t *proct; proct 495 orte/runtime/orte_globals.c if (NULL == (proct = orte_get_proc_object(proc))) { proct 499 orte/runtime/orte_globals.c return proct->node_rank;