stdinev 200 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c static pmix_iof_read_event_t *stdinev = NULL; stdinev 302 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_IOF_READ_EVENT(&stdinev, stdinev 312 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_IOF_READ_ACTIVATE(stdinev); stdinev 318 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_IOF_READ_EVENT(&stdinev, targets, ntargets, stdinev 796 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_iof_read_event_t *stdinev = (pmix_iof_read_event_t*)cbdata; stdinev 798 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_ACQUIRE_OBJECT(stdinev); stdinev 803 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_IOF_READ_ACTIVATE(stdinev); stdinev 805 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&stdinev->ev); stdinev 806 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c stdinev->active = false; stdinev 807 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_POST_OBJECT(stdinev); stdinev 815 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_iof_read_event_t *stdinev = (pmix_iof_read_event_t*)cbdata; stdinev 819 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_ACQUIRE_OBJECT(stdinev); stdinev 826 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&stdinev->ev); stdinev 827 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c stdinev->active = false; stdinev 828 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_POST_OBJECT(stdinev); stdinev 833 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&stdinev->ev); stdinev 834 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c stdinev->active = false; stdinev 835 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_POST_OBJECT(stdinev); stdinev 845 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_iof_stdin_cb(0, 0, stdinev); stdinev 74 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static pmix_iof_read_event_t stdinev; stdinev 653 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev); stdinev 660 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_CONSTRUCT(&stdinev, pmix_iof_read_event_t); stdinev 661 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c stdinev.fd = fd; stdinev 662 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c stdinev.always_readable = pmix_iof_fd_always_ready(fd); stdinev 663 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c if (stdinev.always_readable) { stdinev 665 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev.ev, stdinev 667 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev); stdinev 670 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev.ev, fd, stdinev 672 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_iof_read_local_handler, &stdinev); stdinev 679 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_IOF_READ_ACTIVATE(&stdinev); stdinev 685 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_CONSTRUCT(&stdinev, pmix_iof_read_event_t); stdinev 686 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c stdinev.fd = fd; stdinev 687 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c stdinev.always_readable = pmix_iof_fd_always_ready(fd); stdinev 688 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c if (stdinev.always_readable) { stdinev 690 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev.ev, stdinev 692 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev); stdinev 695 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c &stdinev.ev, fd, stdinev 697 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_iof_read_local_handler, &stdinev); stdinev 699 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_IOF_READ_ACTIVATE(&stdinev); stdinev 129 orte/mca/iof/base/base.h orte_iof_sink_t *stdinev; stdinev 179 orte/mca/iof/base/iof_base_frame.c ptr->stdinev = NULL; stdinev 190 orte/mca/iof/base/iof_base_frame.c if (NULL != ptr->stdinev) { stdinev 191 orte/mca/iof/base/iof_base_frame.c OBJ_RELEASE(ptr->stdinev); stdinev 113 orte/mca/iof/hnp/iof_hnp.c mca_iof_hnp_component.stdinev = NULL; stdinev 242 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_SINK_DEFINE(&proct->stdinev, dst_name, -1, ORTE_IOF_STDIN, stdinev 244 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.jobid = ORTE_PROC_MY_NAME->jobid; stdinev 245 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.vpid = ORTE_VPID_WILDCARD; stdinev 258 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_SINK_DEFINE(&proct->stdinev, dst_name, -1, ORTE_IOF_STDIN, stdinev 260 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.jobid = ORTE_PROC_MY_NAME->jobid; stdinev 261 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.vpid = proc->node->daemon->name.vpid; stdinev 266 orte/mca/iof/hnp/iof_hnp.c if (NULL == mca_iof_hnp_component.stdinev) { stdinev 303 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_EVENT(&mca_iof_hnp_component.stdinev, stdinev 312 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_ACTIVATE(mca_iof_hnp_component.stdinev); stdinev 318 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_EVENT(&mca_iof_hnp_component.stdinev, stdinev 375 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_SINK_DEFINE(&proct->stdinev, dst_name, fd, ORTE_IOF_STDIN, stdinev 377 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.jobid = ORTE_PROC_MY_NAME->jobid; stdinev 378 orte/mca/iof/hnp/iof_hnp.c proct->stdinev->daemon.vpid = ORTE_PROC_MY_NAME->vpid; stdinev 396 orte/mca/iof/hnp/iof_hnp.c if (NULL != proct->stdinev) { stdinev 397 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(proct->stdinev); stdinev 399 orte/mca/iof/hnp/iof_hnp.c proct->stdinev = NULL; stdinev 426 orte/mca/iof/hnp/iof_hnp.c if (NULL == proct->stdinev && stdinev 610 orte/mca/iof/hnp/iof_hnp.c if (NULL != mca_iof_hnp_component.stdinev && stdinev 612 orte/mca/iof/hnp/iof_hnp.c !mca_iof_hnp_component.stdinev->active) { stdinev 629 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_READ_ACTIVATE(mca_iof_hnp_component.stdinev); stdinev 65 orte/mca/iof/hnp/iof_hnp.h orte_iof_read_event_t *stdinev; stdinev 58 orte/mca/iof/hnp/iof_hnp_read.c if (NULL != mca_iof_hnp_component.stdinev && stdinev 60 orte/mca/iof/hnp/iof_hnp_read.c !mca_iof_hnp_component.stdinev->active) { stdinev 61 orte/mca/iof/hnp/iof_hnp_read.c ORTE_IOF_READ_ACTIVATE(mca_iof_hnp_component.stdinev); stdinev 85 orte/mca/iof/hnp/iof_hnp_read.c ORTE_ACQUIRE_OBJECT(mca_iof_hnp_component.stdinev); stdinev 90 orte/mca/iof/hnp/iof_hnp_read.c ORTE_IOF_READ_ACTIVATE(mca_iof_hnp_component.stdinev); stdinev 93 orte/mca/iof/hnp/iof_hnp_read.c opal_event_del(mca_iof_hnp_component.stdinev->ev); stdinev 94 orte/mca/iof/hnp/iof_hnp_read.c mca_iof_hnp_component.stdinev->active = false; stdinev 154 orte/mca/iof/hnp/iof_hnp_read.c if (NULL == proct->stdinev) { stdinev 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)) { stdinev 176 orte/mca/iof/hnp/iof_hnp_read.c if (NULL != proct->stdinev->wev) { stdinev 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)) { stdinev 189 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(&proct->stdinev->daemon))); stdinev 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))) { stdinev 209 orte/mca/iof/hnp/iof_hnp_read.c if (0 != opal_list_get_size(&proct->stdinev->wev->outputs)) { stdinev 211 orte/mca/iof/hnp/iof_hnp_read.c proct->stdinev->closed = true; stdinev 214 orte/mca/iof/hnp/iof_hnp_read.c OBJ_RELEASE(proct->stdinev); stdinev 83 orte/mca/iof/hnp/iof_hnp_receive.c if (NULL != mca_iof_hnp_component.stdinev && stdinev 85 orte/mca/iof/hnp/iof_hnp_receive.c !mca_iof_hnp_component.stdinev->active) { stdinev 86 orte/mca/iof/hnp/iof_hnp_receive.c ORTE_IOF_READ_ACTIVATE(mca_iof_hnp_component.stdinev); stdinev 91 orte/mca/iof/hnp/iof_hnp_receive.c if (NULL != mca_iof_hnp_component.stdinev && stdinev 92 orte/mca/iof/hnp/iof_hnp_receive.c !mca_iof_hnp_component.stdinev->active) { stdinev 93 orte/mca/iof/hnp/iof_hnp_receive.c opal_event_del(mca_iof_hnp_component.stdinev->ev); stdinev 94 orte/mca/iof/hnp/iof_hnp_receive.c mca_iof_hnp_component.stdinev->active = false; stdinev 268 orte/mca/iof/orted/iof_orted.c ORTE_IOF_SINK_DEFINE(&proct->stdinev, dst_name, fd, ORTE_IOF_STDIN, stdinev 289 orte/mca/iof/orted/iof_orted.c if (NULL != proct->stdinev) { stdinev 290 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(proct->stdinev); stdinev 292 orte/mca/iof/orted/iof_orted.c proct->stdinev = NULL; stdinev 319 orte/mca/iof/orted/iof_orted.c if (NULL == proct->stdinev && stdinev 144 orte/mca/iof/orted/iof_orted_receive.c if (NULL == proct->stdinev) { stdinev 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)) {