wev 412 opal/mca/event/libevent2022/libevent/test/regress.c struct event *rev=NULL, *wev=NULL, *closeev=NULL; wev 450 opal/mca/event/libevent2022/libevent/test/regress.c wev = event_new(base, pair2[1], EV_WRITE, record_event_cb, wev 458 opal/mca/event/libevent2022/libevent/test/regress.c event_add(wev, NULL); wev 480 opal/mca/event/libevent2022/libevent/test/regress.c if (wev) wev 481 opal/mca/event/libevent2022/libevent/test/regress.c event_free(wev); wev 452 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c channel = &pmix_client_globals.iof_stdout.wev; wev 454 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c channel = &pmix_client_globals.iof_stderr.wev; wev 685 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_iof_write_event_t *wev = &sink->wev; wev 688 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (!pmix_list_is_empty(&wev->outputs)) { wev 691 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c while (NULL != (output = (pmix_iof_write_output_t*)pmix_list_remove_first(&wev->outputs))) { wev 693 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c num_written = write(wev->fd, output->data, output->numbytes); wev 707 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_iof_write_event_t *wev = &sink->wev; wev 717 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->fd)); wev 719 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c while (NULL != (item = pmix_list_remove_first(&wev->outputs))) { wev 726 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c num_written = write(wev->fd, output->data, output->numbytes); wev 730 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_list_prepend(&wev->outputs, item); wev 732 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (pmix_globals.output_limit < pmix_list_get_size(&wev->outputs)) { wev 752 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_list_prepend(&wev->outputs, item); wev 754 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (pmix_globals.output_limit < pmix_list_get_size(&wev->outputs)) { wev 766 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if(wev->always_writable && (PMIX_IOF_SINK_BLOCKSIZE <= total_written)){ wev 775 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->pending = false; wev 776 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_POST_OBJECT(wev); wev 779 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_IOF_SINK_ACTIVATE(wev); wev 970 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_CONSTRUCT(&ptr->wev, pmix_iof_write_event_t); wev 977 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (0 <= ptr->wev.fd) { wev 981 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_NAME_PRINT(&ptr->name), ptr->wev.fd)); wev 982 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_DESTRUCT(&ptr->wev); wev 1024 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c static void iof_write_event_construct(pmix_iof_write_event_t* wev) wev 1026 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->pending = false; wev 1027 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->always_writable = false; wev 1028 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->fd = -1; wev 1029 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_CONSTRUCT(&wev->outputs, pmix_list_t); wev 1030 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->tv.tv_sec = 0; wev 1031 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c wev->tv.tv_usec = 0; wev 1033 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c static void iof_write_event_destruct(pmix_iof_write_event_t* wev) wev 1035 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c pmix_event_del(&wev->ev); wev 1036 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (2 < wev->fd) { wev 1039 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_NAME_PRINT(&pmix_globals.myid), wev->fd)); wev 1040 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c close(wev->fd); wev 1042 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c PMIX_DESTRUCT(&wev->outputs); wev 80 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h pmix_iof_write_event_t wev; wev 130 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h #define PMIX_IOF_SINK_ACTIVATE(wev) \ wev 133 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h wev->pending = true; \ wev 134 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h PMIX_POST_OBJECT(wev); \ wev 135 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h if (wev->always_writable) { \ wev 137 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h tv = &wev->tv; \ wev 139 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h if (pmix_event_add(&wev->ev, tv)) { \ wev 157 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h (snk)->wev.fd = (fid); \ wev 158 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h (snk)->wev.always_writable = \ wev 160 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h if ((snk)->wev.always_writable) { \ wev 162 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h &(snk)->wev.ev, wrthndlr, (snk)); \ wev 165 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h &(snk)->wev.ev, (snk)->wev.fd, \ wev 105 orte/mca/iof/base/base.h orte_iof_write_event_t *wev; wev 168 orte/mca/iof/base/base.h #define ORTE_IOF_SINK_ACTIVATE(wev) \ wev 171 orte/mca/iof/base/base.h wev->pending = true; \ wev 172 orte/mca/iof/base/base.h ORTE_POST_OBJECT(wev); \ wev 173 orte/mca/iof/base/base.h if (wev->always_writable) { \ wev 175 orte/mca/iof/base/base.h tv = &wev->tv; \ wev 177 orte/mca/iof/base/base.h if (opal_event_add(wev->ev, tv)) { \ wev 197 orte/mca/iof/base/base.h ep->wev->fd = (fid); \ wev 198 orte/mca/iof/base/base.h ep->wev->always_writable = \ wev 200 orte/mca/iof/base/base.h if(ep->wev->always_writable) { \ wev 202 orte/mca/iof/base/base.h ep->wev->ev, wrthndlr, ep); \ wev 205 orte/mca/iof/base/base.h ep->wev->ev, ep->wev->fd, \ wev 209 orte/mca/iof/base/base.h opal_event_set_priority(ep->wev->ev, ORTE_MSG_PRI); \ wev 218 orte/mca/iof/base/iof_base_frame.c ptr->wev = OBJ_NEW(orte_iof_write_event_t); wev 225 orte/mca/iof/base/iof_base_frame.c if (NULL != ptr->wev && 0 <= ptr->wev->fd) { wev 229 orte/mca/iof/base/iof_base_frame.c ORTE_NAME_PRINT(&ptr->name), ptr->wev->fd)); wev 230 orte/mca/iof/base/iof_base_frame.c OBJ_RELEASE(ptr->wev); wev 274 orte/mca/iof/base/iof_base_frame.c static void orte_iof_base_write_event_construct(orte_iof_write_event_t* wev) wev 276 orte/mca/iof/base/iof_base_frame.c wev->pending = false; wev 277 orte/mca/iof/base/iof_base_frame.c wev->always_writable = false; wev 278 orte/mca/iof/base/iof_base_frame.c wev->fd = -1; wev 279 orte/mca/iof/base/iof_base_frame.c OBJ_CONSTRUCT(&wev->outputs, opal_list_t); wev 280 orte/mca/iof/base/iof_base_frame.c wev->ev = opal_event_alloc(); wev 281 orte/mca/iof/base/iof_base_frame.c wev->tv.tv_sec = 0; wev 282 orte/mca/iof/base/iof_base_frame.c wev->tv.tv_usec = 0; wev 284 orte/mca/iof/base/iof_base_frame.c static void orte_iof_base_write_event_destruct(orte_iof_write_event_t* wev) wev 286 orte/mca/iof/base/iof_base_frame.c opal_event_free(wev->ev); wev 289 orte/mca/iof/base/iof_base_frame.c if (xmlfd == wev->fd) { wev 291 orte/mca/iof/base/iof_base_frame.c OBJ_DESTRUCT(&wev->outputs); wev 295 orte/mca/iof/base/iof_base_frame.c if (2 < wev->fd) { wev 298 orte/mca/iof/base/iof_base_frame.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), wev->fd)); wev 299 orte/mca/iof/base/iof_base_frame.c close(wev->fd); wev 301 orte/mca/iof/base/iof_base_frame.c OBJ_DESTRUCT(&wev->outputs); wev 277 orte/mca/iof/base/iof_base_output.c orte_iof_write_event_t *wev; wev 281 orte/mca/iof/base/iof_base_output.c wev = rev->sink->wev; wev 282 orte/mca/iof/base/iof_base_output.c if (NULL != wev && !opal_list_is_empty(&wev->outputs)) { wev 285 orte/mca/iof/base/iof_base_output.c while (NULL != (output = (orte_iof_write_output_t*)opal_list_remove_first(&wev->outputs))) { wev 287 orte/mca/iof/base/iof_base_output.c num_written = write(wev->fd, output->data, output->numbytes); wev 302 orte/mca/iof/base/iof_base_output.c orte_iof_write_event_t *wev = sink->wev; wev 312 orte/mca/iof/base/iof_base_output.c wev->fd)); wev 314 orte/mca/iof/base/iof_base_output.c while (NULL != (item = opal_list_remove_first(&wev->outputs))) { wev 321 orte/mca/iof/base/iof_base_output.c num_written = write(wev->fd, output->data, output->numbytes); wev 325 orte/mca/iof/base/iof_base_output.c opal_list_prepend(&wev->outputs, item); wev 327 orte/mca/iof/base/iof_base_output.c if (orte_iof_base.output_limit < opal_list_get_size(&wev->outputs)) { wev 348 orte/mca/iof/base/iof_base_output.c opal_list_prepend(&wev->outputs, item); wev 350 orte/mca/iof/base/iof_base_output.c if (orte_iof_base.output_limit < opal_list_get_size(&wev->outputs)) { wev 363 orte/mca/iof/base/iof_base_output.c if(wev->always_writable && (ORTE_IOF_SINK_BLOCKSIZE <= total_written)){ wev 372 orte/mca/iof/base/iof_base_output.c wev->pending = false; wev 373 orte/mca/iof/base/iof_base_output.c ORTE_POST_OBJECT(wev); wev 376 orte/mca/iof/base/iof_base_output.c ORTE_IOF_SINK_ACTIVATE(wev); wev 456 orte/mca/iof/hnp/iof_hnp.c orte_iof_write_event_t *wev; wev 463 orte/mca/iof/hnp/iof_hnp.c wev = orte_iof_base.iof_write_stdout->wev; wev 464 orte/mca/iof/hnp/iof_hnp.c if (!opal_list_is_empty(&wev->outputs)) { wev 467 orte/mca/iof/hnp/iof_hnp.c while (NULL != (output = (orte_iof_write_output_t*)opal_list_remove_first(&wev->outputs))) { wev 469 orte/mca/iof/hnp/iof_hnp.c num_written = write(wev->fd, output->data, output->numbytes); wev 480 orte/mca/iof/hnp/iof_hnp.c wev = orte_iof_base.iof_write_stderr->wev; wev 481 orte/mca/iof/hnp/iof_hnp.c if (!opal_list_is_empty(&wev->outputs)) { wev 484 orte/mca/iof/hnp/iof_hnp.c while (NULL != (output = (orte_iof_write_output_t*)opal_list_remove_first(&wev->outputs))) { wev 486 orte/mca/iof/hnp/iof_hnp.c num_written = write(wev->fd, output->data, output->numbytes); wev 532 orte/mca/iof/hnp/iof_hnp.c orte_iof_write_event_t *wev = sink->wev; wev 542 orte/mca/iof/hnp/iof_hnp.c wev->fd)); wev 544 orte/mca/iof/hnp/iof_hnp.c wev->pending = false; wev 546 orte/mca/iof/hnp/iof_hnp.c while (NULL != (item = opal_list_remove_first(&wev->outputs))) { wev 561 orte/mca/iof/hnp/iof_hnp.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), wev->fd)); wev 564 orte/mca/iof/hnp/iof_hnp.c num_written = write(wev->fd, output->data, output->numbytes); wev 572 orte/mca/iof/hnp/iof_hnp.c opal_list_prepend(&wev->outputs, item); wev 584 orte/mca/iof/hnp/iof_hnp.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), wev->fd)); wev 593 orte/mca/iof/hnp/iof_hnp.c opal_list_prepend(&wev->outputs, item); wev 602 orte/mca/iof/hnp/iof_hnp.c if ((ORTE_IOF_SINK_BLOCKSIZE <= total_written) && wev->always_writable) { wev 608 orte/mca/iof/hnp/iof_hnp.c ORTE_IOF_SINK_ACTIVATE(wev); wev 625 orte/mca/iof/hnp/iof_hnp.c if (opal_list_get_size(&wev->outputs) < ORTE_IOF_MAX_INPUT_BUFFERS) { wev 632 orte/mca/iof/hnp/iof_hnp.c if (sink->closed && 0 == opal_list_get_size(&wev->outputs)) { wev 638 orte/mca/iof/hnp/iof_hnp.c OBJ_RELEASE(wev); wev 639 orte/mca/iof/hnp/iof_hnp.c sink->wev = NULL; wev 649 orte/mca/iof/hnp/iof_hnp.c orte_iof_base_write_output(peer, source_tag, (const unsigned char*)msg, strlen(msg), orte_iof_base.iof_write_stdout->wev); wev 651 orte/mca/iof/hnp/iof_hnp.c orte_iof_base_write_output(peer, source_tag, (const unsigned char*)msg, strlen(msg), orte_iof_base.iof_write_stderr->wev); wev 176 orte/mca/iof/hnp/iof_hnp_read.c if (NULL != proct->stdinev->wev) { wev 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)) { wev 209 orte/mca/iof/hnp/iof_hnp_read.c if (0 != opal_list_get_size(&proct->stdinev->wev->outputs)) { wev 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); wev 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); wev 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); wev 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); wev 336 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev); wev 277 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_base_write_output(&origin, stream, data, numbytes, orte_iof_base.iof_write_stdout->wev); wev 279 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_base_write_output(&origin, stream, data, numbytes, orte_iof_base.iof_write_stderr->wev); wev 387 orte/mca/iof/orted/iof_orted.c orte_iof_write_event_t *wev = sink->wev; wev 397 orte/mca/iof/orted/iof_orted.c wev->fd)); wev 399 orte/mca/iof/orted/iof_orted.c wev->pending = false; wev 401 orte/mca/iof/orted/iof_orted.c while (NULL != (item = opal_list_remove_first(&wev->outputs))) { wev 409 orte/mca/iof/orted/iof_orted.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), wev->fd)); wev 410 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(wev); wev 411 orte/mca/iof/orted/iof_orted.c sink->wev = NULL; wev 414 orte/mca/iof/orted/iof_orted.c num_written = write(wev->fd, output->data, output->numbytes); wev 422 orte/mca/iof/orted/iof_orted.c opal_list_prepend(&wev->outputs, item); wev 426 orte/mca/iof/orted/iof_orted.c ORTE_IOF_SINK_ACTIVATE(wev); wev 435 orte/mca/iof/orted/iof_orted.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), wev->fd)); wev 436 orte/mca/iof/orted/iof_orted.c OBJ_RELEASE(wev); wev 437 orte/mca/iof/orted/iof_orted.c sink->wev = NULL; wev 451 orte/mca/iof/orted/iof_orted.c opal_list_prepend(&wev->outputs, item); wev 455 orte/mca/iof/orted/iof_orted.c ORTE_IOF_SINK_ACTIVATE(wev); wev 472 orte/mca/iof/orted/iof_orted.c if (opal_list_get_size(&wev->outputs) < ORTE_IOF_MAX_INPUT_BUFFERS) { wev 107 orte/mca/iof/orted/iof_orted_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev); wev 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)) { wev 232 orte/mca/iof/tool/iof_tool.c orte_iof_write_event_t *wev; wev 237 orte/mca/iof/tool/iof_tool.c wev = orte_iof_base.iof_write_stdout->wev; wev 238 orte/mca/iof/tool/iof_tool.c if (!opal_list_is_empty(&wev->outputs)) { wev 241 orte/mca/iof/tool/iof_tool.c while (NULL != (item = opal_list_remove_first(&wev->outputs))) { wev 244 orte/mca/iof/tool/iof_tool.c num_written = write(wev->fd, output->data, output->numbytes); wev 256 orte/mca/iof/tool/iof_tool.c wev = orte_iof_base.iof_write_stderr->wev; wev 257 orte/mca/iof/tool/iof_tool.c if (!opal_list_is_empty(&wev->outputs)) { wev 260 orte/mca/iof/tool/iof_tool.c while (NULL != (item = opal_list_remove_first(&wev->outputs))) { wev 263 orte/mca/iof/tool/iof_tool.c num_written = write(wev->fd, output->data, output->numbytes); wev 287 orte/mca/iof/tool/iof_tool.c orte_iof_base_write_output(peer, source_tag, (const unsigned char*)msg, strlen(msg), orte_iof_base.iof_write_stdout->wev); wev 289 orte/mca/iof/tool/iof_tool.c orte_iof_base_write_output(peer, source_tag, (const unsigned char*)msg, strlen(msg), orte_iof_base.iof_write_stderr->wev); wev 102 orte/mca/iof/tool/iof_tool_receive.c orte_iof_base_write_output(&origin, stream, data, numbytes, orte_iof_base.iof_write_stdout->wev); wev 104 orte/mca/iof/tool/iof_tool_receive.c orte_iof_base_write_output(&origin, stream, data, numbytes, orte_iof_base.iof_write_stderr->wev);