rev               412 opal/mca/event/libevent2022/libevent/test/regress.c 	struct event *rev=NULL, *wev=NULL, *closeev=NULL;
rev               447 opal/mca/event/libevent2022/libevent/test/regress.c 	rev = event_new(base, pair1[1], EV_READ, record_event_cb,
rev               457 opal/mca/event/libevent2022/libevent/test/regress.c 	event_add(rev, NULL);
rev               478 opal/mca/event/libevent2022/libevent/test/regress.c 	if (rev)
rev               479 opal/mca/event/libevent2022/libevent/test/regress.c 		event_free(rev);
rev               851 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     pmix_iof_read_event_t *rev = (pmix_iof_read_event_t*)cbdata;
rev               860 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     PMIX_ACQUIRE_OBJECT(rev);
rev               876 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c             PMIX_IOF_READ_ACTIVATE(rev);
rev               892 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->active = false;
rev               910 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c                      msg, &rev->ntargets, 1, PMIX_SIZE);
rev               917 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     if (0 < rev->ntargets) {
rev               919 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c                          msg, rev->targets, rev->ntargets, PMIX_PROC);
rev               928 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c                      msg, &rev->ndirs, 1, PMIX_SIZE);
rev               935 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     if (0 < rev->ndirs) {
rev               937 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c                          msg, rev->directives, rev->ndirs, PMIX_INFO);
rev               958 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c                        msg, iof_stdin_cbfunc, rev);
rev               991 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c static void iof_read_event_construct(pmix_iof_read_event_t* rev)
rev               993 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->fd = -1;
rev               994 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->active = false;
rev               995 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->tv.tv_sec = 0;
rev               996 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->tv.tv_usec = 0;
rev               997 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->targets = NULL;
rev               998 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->ntargets = 0;
rev               999 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->directives = NULL;
rev              1000 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     rev->ndirs = 0;
rev              1002 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c static void iof_read_event_destruct(pmix_iof_read_event_t* rev)
rev              1004 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     pmix_event_del(&rev->ev);
rev              1005 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     if (0 <= rev->fd) {
rev              1008 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c                              PMIX_NAME_PRINT(&pmix_globals.myid), rev->fd));
rev              1009 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c         close(rev->fd);
rev              1010 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c         rev->fd = -1;
rev              1012 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     if (NULL != rev->targets) {
rev              1013 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c         PMIX_PROC_FREE(rev->targets, rev->ntargets);
rev              1015 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c     if (NULL != rev->directives) {
rev              1016 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c         PMIX_INFO_FREE(rev->directives, rev->ndirs);
rev               174 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h #define PMIX_IOF_READ_ADDEV(rev)                                \
rev               177 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         if ((rev)->always_readable) {                           \
rev               178 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h             tv = &(rev)->tv;                                    \
rev               180 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         if (pmix_event_add(&(rev)->ev, tv)) {                   \
rev               185 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h #define PMIX_IOF_READ_ACTIVATE(rev)                             \
rev               187 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         (rev)->active = true;                                   \
rev               188 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         PMIX_POST_OBJECT(rev);                                  \
rev               189 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         PMIX_IOF_READ_ADDEV(rev);                               \
rev               196 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         pmix_iof_read_event_t *rev;                                     \
rev               200 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         rev = PMIX_NEW(pmix_iof_read_event_t);                          \
rev               201 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         (rev)->ntargets = (np);                                         \
rev               202 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         PMIX_PROC_CREATE((rev)->targets, (rev)->ntargets);              \
rev               203 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         memcpy((rev)->targets, (p), (np) * sizeof(pmix_proc_t));        \
rev               205 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h             PMIX_INFO_CREATE((rev)->directives, (nd));                  \
rev               206 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h             (rev)->ndirs = (nd);                                        \
rev               208 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h                 PMIX_INFO_XFER(&((rev)->directives[_ii]), &((d)[_ii])); \
rev               211 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         rev->fd = (fid);                                                \
rev               212 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         rev->always_readable = pmix_iof_fd_always_ready(fid);           \
rev               213 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         *(rv) = rev;                                                    \
rev               214 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h         if(rev->always_readable) {                                      \
rev               216 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h                                    &rev->ev, (cbfunc), rev);            \
rev               219 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h                            &rev->ev, (fid),                             \
rev               221 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h                            (cbfunc), rev);                              \
rev               224 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h             PMIX_IOF_READ_ACTIVATE(rev)                                 \
rev               754 orte/mca/filem/raw/filem_raw_module.c     orte_filem_raw_xfer_t *rev = (orte_filem_raw_xfer_t*)cbdata;
rev               761 orte/mca/filem/raw/filem_raw_module.c     ORTE_ACQUIRE_OBJECT(rev);
rev               764 orte/mca/filem/raw/filem_raw_module.c     rev->pending = false;
rev               774 orte/mca/filem/raw/filem_raw_module.c             ORTE_POST_OBJECT(rev);
rev               775 orte/mca/filem/raw/filem_raw_module.c             opal_event_add(&rev->ev, 0);
rev               781 orte/mca/filem/raw/filem_raw_module.c                              ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), rev->file));
rev               794 orte/mca/filem/raw/filem_raw_module.c         OBJ_RELEASE(rev);
rev               801 orte/mca/filem/raw/filem_raw_module.c                          rev->nchunk, numbytes, rev->file));
rev               805 orte/mca/filem/raw/filem_raw_module.c     if (OPAL_SUCCESS != (rc = opal_dss.pack(&chunk, &rev->file, 1, OPAL_STRING))) {
rev               810 orte/mca/filem/raw/filem_raw_module.c     if (OPAL_SUCCESS != (rc = opal_dss.pack(&chunk, &rev->nchunk, 1, OPAL_INT32))) {
rev               821 orte/mca/filem/raw/filem_raw_module.c     if (0 == rev->nchunk) {
rev               822 orte/mca/filem/raw/filem_raw_module.c         if (OPAL_SUCCESS != (rc = opal_dss.pack(&chunk, &rev->type, 1, OPAL_INT32))) {
rev               841 orte/mca/filem/raw/filem_raw_module.c     rev->nchunk++;
rev               851 orte/mca/filem/raw/filem_raw_module.c         rev->pending = true;
rev               852 orte/mca/filem/raw/filem_raw_module.c         ORTE_POST_OBJECT(rev);
rev               853 orte/mca/filem/raw/filem_raw_module.c         opal_event_add(&rev->ev, 0);
rev               216 orte/mca/iof/base/base.h #define ORTE_IOF_READ_ADDEV(rev)                                \
rev               219 orte/mca/iof/base/base.h         if (rev->always_readable) {                             \
rev               220 orte/mca/iof/base/base.h             tv = &rev->tv;                                      \
rev               222 orte/mca/iof/base/base.h         if (opal_event_add(rev->ev, tv)) {                      \
rev               227 orte/mca/iof/base/base.h #define ORTE_IOF_READ_ACTIVATE(rev)                             \
rev               229 orte/mca/iof/base/base.h         rev->active = true;                                     \
rev               230 orte/mca/iof/base/base.h         ORTE_POST_OBJECT(rev);                                  \
rev               231 orte/mca/iof/base/base.h         ORTE_IOF_READ_ADDEV(rev);                               \
rev               243 orte/mca/iof/base/base.h         orte_iof_read_event_t *rev;                                     \
rev               250 orte/mca/iof/base/base.h         rev = OBJ_NEW(orte_iof_read_event_t);                           \
rev               252 orte/mca/iof/base/base.h         rev->proc = (struct orte_iof_proc_t*)(p);                       \
rev               253 orte/mca/iof/base/base.h         rev->tag = (tg);                                                \
rev               254 orte/mca/iof/base/base.h         rev->fd = (fid);                                                \
rev               255 orte/mca/iof/base/base.h         rev->always_readable = orte_iof_base_fd_always_ready(fid);      \
rev               256 orte/mca/iof/base/base.h         *(rv) = rev;                                                    \
rev               257 orte/mca/iof/base/base.h         if(rev->always_readable) {                                      \
rev               259 orte/mca/iof/base/base.h                                    rev->ev, (cbfunc), rev);             \
rev               262 orte/mca/iof/base/base.h                            rev->ev, (fid),                              \
rev               264 orte/mca/iof/base/base.h                            (cbfunc), rev);                              \
rev               266 orte/mca/iof/base/base.h         opal_event_set_priority(rev->ev, ORTE_MSG_PRI);                 \
rev               268 orte/mca/iof/base/base.h             ORTE_IOF_READ_ACTIVATE(rev)                                 \
rev               281 orte/mca/iof/base/base.h ORTE_DECLSPEC void orte_iof_base_static_dump_output(orte_iof_read_event_t *rev);
rev               239 orte/mca/iof/base/iof_base_frame.c static void orte_iof_base_read_event_construct(orte_iof_read_event_t* rev)
rev               241 orte/mca/iof/base/iof_base_frame.c     rev->proc = NULL;
rev               242 orte/mca/iof/base/iof_base_frame.c     rev->fd = -1;
rev               243 orte/mca/iof/base/iof_base_frame.c     rev->active = false;
rev               244 orte/mca/iof/base/iof_base_frame.c     rev->ev = opal_event_alloc();
rev               245 orte/mca/iof/base/iof_base_frame.c     rev->sink = NULL;
rev               246 orte/mca/iof/base/iof_base_frame.c     rev->tv.tv_sec = 0;
rev               247 orte/mca/iof/base/iof_base_frame.c     rev->tv.tv_usec = 0;
rev               249 orte/mca/iof/base/iof_base_frame.c static void orte_iof_base_read_event_destruct(orte_iof_read_event_t* rev)
rev               251 orte/mca/iof/base/iof_base_frame.c     orte_iof_proc_t *proct = (orte_iof_proc_t*)rev->proc;
rev               253 orte/mca/iof/base/iof_base_frame.c     opal_event_free(rev->ev);
rev               254 orte/mca/iof/base/iof_base_frame.c     if (0 <= rev->fd) {
rev               257 orte/mca/iof/base/iof_base_frame.c                              ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), rev->fd,
rev               259 orte/mca/iof/base/iof_base_frame.c         close(rev->fd);
rev               260 orte/mca/iof/base/iof_base_frame.c         rev->fd = -1;
rev               262 orte/mca/iof/base/iof_base_frame.c     if (NULL != rev->sink) {
rev               263 orte/mca/iof/base/iof_base_frame.c         OBJ_RELEASE(rev->sink);
rev               273 orte/mca/iof/base/iof_base_output.c void orte_iof_base_static_dump_output(orte_iof_read_event_t *rev)
rev               280 orte/mca/iof/base/iof_base_output.c     if (NULL != rev->sink) {
rev               281 orte/mca/iof/base/iof_base_output.c         wev = rev->sink->wev;
rev               103 orte/mca/iof/hnp/iof_hnp_read.c     orte_iof_read_event_t *rev = (orte_iof_read_event_t*)cbdata;
rev               106 orte/mca/iof/hnp/iof_hnp_read.c     orte_iof_proc_t *proct = (orte_iof_proc_t*)rev->proc;
rev               112 orte/mca/iof/hnp/iof_hnp_read.c     ORTE_ACQUIRE_OBJECT(rev);
rev               117 orte/mca/iof/hnp/iof_hnp_read.c     fd = rev->fd;
rev               134 orte/mca/iof/hnp/iof_hnp_read.c             ORTE_IOF_READ_ACTIVATE(rev);
rev               150 orte/mca/iof/hnp/iof_hnp_read.c     if (ORTE_IOF_STDIN & rev->tag) {
rev               153 orte/mca/iof/hnp/iof_hnp_read.c         rev->active = false;
rev               163 orte/mca/iof/hnp/iof_hnp_read.c             OBJ_RELEASE(rev);
rev               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)) {
rev               202 orte/mca/iof/hnp/iof_hnp_read.c                     OBJ_RELEASE(rev->sink);
rev               242 orte/mca/iof/hnp/iof_hnp_read.c             if ((sink->tag & rev->tag) &&
rev               258 orte/mca/iof/hnp/iof_hnp_read.c                         rc = opal_pmix.server_iof_push(&proct->name, rev->tag, data, numbytes);
rev               268 orte/mca/iof/hnp/iof_hnp_read.c                     orte_iof_hnp_send_data_to_endpoint(&sink->daemon, &proct->name, rev->tag, data, numbytes));
rev               280 orte/mca/iof/hnp/iof_hnp_read.c                          (ORTE_IOF_STDOUT & rev->tag) ? "stdout" : ((ORTE_IOF_STDERR & rev->tag) ? "stderr" : "stddiag"),
rev               289 orte/mca/iof/hnp/iof_hnp_read.c         if (rev->tag & ORTE_IOF_STDOUT) {
rev               292 orte/mca/iof/hnp/iof_hnp_read.c         } else if (rev->tag & ORTE_IOF_STDERR) {
rev               296 orte/mca/iof/hnp/iof_hnp_read.c         } else if (rev->tag & ORTE_IOF_STDDIAG) {
rev               318 orte/mca/iof/hnp/iof_hnp_read.c                 if (ORTE_IOF_STDOUT & rev->tag || orte_xml_output) {
rev               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);
rev               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);
rev               326 orte/mca/iof/hnp/iof_hnp_read.c             if (ORTE_IOF_STDOUT & rev->tag || orte_xml_output) {
rev               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);
rev               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);
rev               334 orte/mca/iof/hnp/iof_hnp_read.c     if (NULL != rev->sink && !(ORTE_IOF_STDIN & rev->sink->tag)) {
rev               336 orte/mca/iof/hnp/iof_hnp_read.c         orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev);
rev               340 orte/mca/iof/hnp/iof_hnp_read.c     ORTE_IOF_READ_ACTIVATE(rev);
rev                49 orte/mca/iof/orted/iof_orted_read.c     orte_iof_read_event_t *rev = (orte_iof_read_event_t*)cbdata;
rev                54 orte/mca/iof/orted/iof_orted_read.c     orte_iof_proc_t *proct = (orte_iof_proc_t*)rev->proc;
rev                56 orte/mca/iof/orted/iof_orted_read.c     ORTE_ACQUIRE_OBJECT(rev);
rev                61 orte/mca/iof/orted/iof_orted_read.c     fd = rev->fd;
rev                91 orte/mca/iof/orted/iof_orted_read.c                 ORTE_IOF_READ_ACTIVATE(rev);
rev               105 orte/mca/iof/orted/iof_orted_read.c     if (NULL != rev->sink) {
rev               107 orte/mca/iof/orted/iof_orted_read.c         orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev);
rev               111 orte/mca/iof/orted/iof_orted_read.c         ORTE_IOF_READ_ACTIVATE(rev);
rev               121 orte/mca/iof/orted/iof_orted_read.c     if (ORTE_SUCCESS != (rc = opal_dss.pack(buf, &rev->tag, 1, ORTE_IOF_TAG))) {
rev               147 orte/mca/iof/orted/iof_orted_read.c     ORTE_IOF_READ_ACTIVATE(rev);
rev               156 orte/mca/iof/orted/iof_orted_read.c     if (rev->tag & ORTE_IOF_STDOUT) {
rev               161 orte/mca/iof/orted/iof_orted_read.c     } else if (rev->tag & ORTE_IOF_STDERR) {
rev               167 orte/mca/iof/orted/iof_orted_read.c     } else if (rev->tag & ORTE_IOF_STDDIAG) {