bufev_private 68 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 71 opal/mca/event/libevent2022/libevent/bufferevent.c if (!bufev_private->read_suspended) bufev_private 73 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->read_suspended |= what; bufev_private 80 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 83 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->read_suspended &= ~what; bufev_private 84 opal/mca/event/libevent2022/libevent/bufferevent.c if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) bufev_private 92 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 95 opal/mca/event/libevent2022/libevent/bufferevent.c if (!bufev_private->write_suspended) bufev_private 97 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->write_suspended |= what; bufev_private 104 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 107 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->write_suspended &= ~what; bufev_private 108 opal/mca/event/libevent2022/libevent/bufferevent.c if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE)) bufev_private 135 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = arg; bufev_private 136 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bufev_private 139 opal/mca/event/libevent2022/libevent/bufferevent.c if ((bufev_private->eventcb_pending & BEV_EVENT_CONNECTED) && bufev_private 143 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->eventcb_pending &= ~BEV_EVENT_CONNECTED; bufev_private 146 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->readcb_pending && bufev->readcb) { bufev_private 147 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->readcb_pending = 0; bufev_private 150 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->writecb_pending && bufev->writecb) { bufev_private 151 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->writecb_pending = 0; bufev_private 154 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->eventcb_pending && bufev->errorcb) { bufev_private 155 opal/mca/event/libevent2022/libevent/bufferevent.c short what = bufev_private->eventcb_pending; bufev_private 156 opal/mca/event/libevent2022/libevent/bufferevent.c int err = bufev_private->errno_pending; bufev_private 157 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->eventcb_pending = 0; bufev_private 158 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->errno_pending = 0; bufev_private 168 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = arg; bufev_private 169 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bufev_private 175 opal/mca/event/libevent2022/libevent/bufferevent.c if ((bufev_private->eventcb_pending & BEV_EVENT_CONNECTED) && bufev_private 181 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->eventcb_pending &= ~BEV_EVENT_CONNECTED; bufev_private 184 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->readcb_pending && bufev->readcb) { bufev_private 187 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->readcb_pending = 0; bufev_private 190 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->writecb_pending && bufev->writecb) { bufev_private 193 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->writecb_pending = 0; bufev_private 196 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->eventcb_pending && bufev->errorcb) { bufev_private 199 opal/mca/event/libevent2022/libevent/bufferevent.c short what = bufev_private->eventcb_pending; bufev_private 200 opal/mca/event/libevent2022/libevent/bufferevent.c int err = bufev_private->errno_pending; bufev_private 201 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->eventcb_pending = 0; bufev_private 202 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->errno_pending = 0; bufev_private 272 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_init_common(struct bufferevent_private *bufev_private, bufev_private 277 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bufev_private 291 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->refcnt = 1; bufev_private 326 opal/mca/event/libevent2022/libevent/bufferevent.c event_deferred_cb_init(&bufev_private->deferred, bufev_private 328 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private); bufev_private 330 opal/mca/event/libevent2022/libevent/bufferevent.c event_deferred_cb_init(&bufev_private->deferred, bufev_private 332 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private); bufev_private 335 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->options = options; bufev_private 409 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 415 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->read_suspended) bufev_private 417 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->write_suspended) bufev_private 483 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 489 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->connecting = 0; bufev_private 520 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 538 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->read_watermarks_cb == NULL) { bufev_private 539 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->read_watermarks_cb = bufev_private 545 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->read_watermarks_cb, bufev_private 554 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->read_watermarks_cb) bufev_private 556 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->read_watermarks_cb, bufev_private 580 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 583 opal/mca/event/libevent2022/libevent/bufferevent.c ++bufev_private->refcnt; bufev_private 607 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 611 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_ASSERT(bufev_private->refcnt > 0); bufev_private 613 opal/mca/event/libevent2022/libevent/bufferevent.c if (--bufev_private->refcnt) { bufev_private 631 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->rate_limiting) { bufev_private 632 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->rate_limiting->group) bufev_private 634 opal/mca/event/libevent2022/libevent/bufferevent.c if (event_initialized(&bufev_private->rate_limiting->refill_bucket_event)) bufev_private 635 opal/mca/event/libevent2022/libevent/bufferevent.c event_del(&bufev_private->rate_limiting->refill_bucket_event); bufev_private 636 opal/mca/event/libevent2022/libevent/bufferevent.c event_debug_unassign(&bufev_private->rate_limiting->refill_bucket_event); bufev_private 637 opal/mca/event/libevent2022/libevent/bufferevent.c mm_free(bufev_private->rate_limiting); bufev_private 638 opal/mca/event/libevent2022/libevent/bufferevent.c bufev_private->rate_limiting = NULL; bufev_private 645 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->own_lock) bufev_private 646 opal/mca/event/libevent2022/libevent/bufferevent.c EVTHREAD_FREE_LOCK(bufev_private->lock, bufev_private 687 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *bufev_private = bufev_private 691 opal/mca/event/libevent2022/libevent/bufferevent.c ++bufev_private->refcnt;