bev 433 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_set_parent(struct evbuffer *buf, struct bufferevent *bev) bev 436 opal/mca/event/libevent2022/libevent/buffer.c buf->parent = bev; bev 139 opal/mca/event/libevent2022/libevent/bufferevent-internal.h struct bufferevent bev; bev 344 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void _bufferevent_init_generic_timeout_cbs(struct bufferevent *bev); bev 347 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int _bufferevent_del_generic_timeout_cbs(struct bufferevent *bev); bev 352 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int _bufferevent_generic_adj_timeouts(struct bufferevent *bev); bev 356 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \ bev 358 opal/mca/event/libevent2022/libevent/bufferevent-internal.h if (evutil_timerisset(&(bev)->timeout_read)) \ bev 359 opal/mca/event/libevent2022/libevent/bufferevent-internal.h event_add(&(bev)->ev_read, &(bev)->timeout_read); \ bev 363 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_RESET_GENERIC_WRITE_TIMEOUT(bev) \ bev 365 opal/mca/event/libevent2022/libevent/bufferevent-internal.h if (evutil_timerisset(&(bev)->timeout_write)) \ bev 366 opal/mca/event/libevent2022/libevent/bufferevent-internal.h event_add(&(bev)->ev_write, &(bev)->timeout_write); \ bev 368 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_DEL_GENERIC_READ_TIMEOUT(bev) \ bev 369 opal/mca/event/libevent2022/libevent/bufferevent-internal.h event_del(&(bev)->ev_read) bev 370 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_DEL_GENERIC_WRITE_TIMEOUT(bev) \ bev 371 opal/mca/event/libevent2022/libevent/bufferevent-internal.h event_del(&(bev)->ev_write) bev 376 opal/mca/event/libevent2022/libevent/bufferevent-internal.h #define BEV_UPCAST(b) EVUTIL_UPCAST((b), struct bufferevent_private, bev) bev 398 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int _bufferevent_decrement_write_buckets(struct bufferevent_private *bev, bev 400 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int _bufferevent_decrement_read_buckets(struct bufferevent_private *bev, bev 402 opal/mca/event/libevent2022/libevent/bufferevent-internal.h ev_ssize_t _bufferevent_get_read_max(struct bufferevent_private *bev); bev 403 opal/mca/event/libevent2022/libevent/bufferevent-internal.h ev_ssize_t _bufferevent_get_write_max(struct bufferevent_private *bev); bev 62 opal/mca/event/libevent2022/libevent/bufferevent.c static void _bufferevent_cancel_all(struct bufferevent *bev); bev 69 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 81 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 93 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 105 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 136 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bev 169 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bev 212 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_incref(&(bevp)->bev); \ bev 214 opal/mca/event/libevent2022/libevent/bufferevent.c event_base_get_deferred_cb_queue((bevp)->bev.ev_base), \ bev 224 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 241 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 258 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 277 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bev 410 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 484 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 521 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 608 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 688 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 732 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_setfd(struct bufferevent *bev, evutil_socket_t fd) bev 737 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bev); bev 738 opal/mca/event/libevent2022/libevent/bufferevent.c if (bev->be_ops->ctrl) bev 739 opal/mca/event/libevent2022/libevent/bufferevent.c res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d); bev 740 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bev); bev 745 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_getfd(struct bufferevent *bev) bev 750 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bev); bev 751 opal/mca/event/libevent2022/libevent/bufferevent.c if (bev->be_ops->ctrl) bev 752 opal/mca/event/libevent2022/libevent/bufferevent.c res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d); bev 753 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bev); bev 758 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_cancel_all(struct bufferevent *bev) bev 762 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bev); bev 763 opal/mca/event/libevent2022/libevent/bufferevent.c if (bev->be_ops->ctrl) bev 764 opal/mca/event/libevent2022/libevent/bufferevent.c bev->be_ops->ctrl(bev, BEV_CTRL_CANCEL_ALL, &d); bev 765 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bev); bev 779 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_get_underlying(struct bufferevent *bev) bev 784 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bev); bev 785 opal/mca/event/libevent2022/libevent/bufferevent.c if (bev->be_ops->ctrl) bev 786 opal/mca/event/libevent2022/libevent/bufferevent.c res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_UNDERLYING, &d); bev 787 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bev); bev 794 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bev = ctx; bev 795 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_incref_and_lock(bev); bev 796 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_disable(bev, EV_READ); bev 797 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_run_eventcb(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_READING); bev 798 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_decref_and_unlock(bev); bev 803 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bev = ctx; bev 804 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_incref_and_lock(bev); bev 805 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_disable(bev, EV_WRITE); bev 806 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_run_eventcb(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_WRITING); bev 807 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_decref_and_unlock(bev); bev 811 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_init_generic_timeout_cbs(struct bufferevent *bev) bev 813 opal/mca/event/libevent2022/libevent/bufferevent.c evtimer_assign(&bev->ev_read, bev->ev_base, bev 814 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_generic_read_timeout_cb, bev); bev 815 opal/mca/event/libevent2022/libevent/bufferevent.c evtimer_assign(&bev->ev_write, bev->ev_base, bev 816 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_generic_write_timeout_cb, bev); bev 820 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_del_generic_timeout_cbs(struct bufferevent *bev) bev 823 opal/mca/event/libevent2022/libevent/bufferevent.c r1 = event_del(&bev->ev_read); bev 824 opal/mca/event/libevent2022/libevent/bufferevent.c r2 = event_del(&bev->ev_write); bev 831 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_generic_adj_timeouts(struct bufferevent *bev) bev 833 opal/mca/event/libevent2022/libevent/bufferevent.c const short enabled = bev->enabled; bev 835 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bev, struct bufferevent_private, bev); bev 838 opal/mca/event/libevent2022/libevent/bufferevent.c evutil_timerisset(&bev->timeout_read)) bev 839 opal/mca/event/libevent2022/libevent/bufferevent.c r1 = event_add(&bev->ev_read, &bev->timeout_read); bev 841 opal/mca/event/libevent2022/libevent/bufferevent.c r1 = event_del(&bev->ev_read); bev 844 opal/mca/event/libevent2022/libevent/bufferevent.c evutil_timerisset(&bev->timeout_write) && bev 845 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_get_length(bev->output)) bev 846 opal/mca/event/libevent2022/libevent/bufferevent.c r2 = event_add(&bev->ev_write, &bev->timeout_write); bev 848 opal/mca/event/libevent2022/libevent/bufferevent.c r2 = event_del(&bev->ev_write); bev 866 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_lock(struct bufferevent *bev) bev 868 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_incref_and_lock(bev); bev 872 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_unlock(struct bufferevent *bev) bev 874 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_decref_and_unlock(bev); bev 79 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_private bev; bev 92 opal/mca/event/libevent2022/libevent/bufferevent_async.c evutil_offsetof(struct bufferevent_async, bev.bev), bev 102 opal/mca/event/libevent2022/libevent/bufferevent_async.c upcast(struct bufferevent *bev) bev 105 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (bev->be_ops != &bufferevent_ops_async) bev 107 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev); bev 116 opal/mca/event/libevent2022/libevent/bufferevent_async.c EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); bev 125 opal/mca/event/libevent2022/libevent/bufferevent_async.c EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); bev 134 opal/mca/event/libevent2022/libevent/bufferevent_async.c EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); bev 141 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &beva->bev.bev; bev 145 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_base_del_virtual(bev->ev_base); bev 152 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &beva->bev.bev; bev 156 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_base_del_virtual(bev->ev_base); bev 163 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &beva->bev.bev; bev 167 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_base_add_virtual(bev->ev_base); bev 174 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &beva->bev.bev; bev 178 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_base_add_virtual(bev->ev_base); bev 187 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &beva->bev.bev; bev 191 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (beva->write_in_progress || beva->bev.connecting) bev 193 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (!beva->ok || !(bev->enabled&EV_WRITE) || bev 194 opal/mca/event/libevent2022/libevent/bufferevent_async.c !evbuffer_get_length(bev->output)) { bev 199 opal/mca/event/libevent2022/libevent/bufferevent_async.c at_most = evbuffer_get_length(bev->output); bev 203 opal/mca/event/libevent2022/libevent/bufferevent_async.c limit = (int)_bufferevent_get_write_max(&beva->bev); bev 207 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (beva->bev.write_suspended) { bev 213 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_incref(bev); bev 214 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (evbuffer_launch_write(bev->output, at_most, bev 216 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_decref(bev); bev 218 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_eventcb(bev, BEV_EVENT_ERROR); bev 221 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decrement_write_buckets(&beva->bev, at_most); bev 233 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &beva->bev.bev; bev 237 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (beva->read_in_progress || beva->bev.connecting) bev 239 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (!beva->ok || !(bev->enabled&EV_READ)) { bev 245 opal/mca/event/libevent2022/libevent/bufferevent_async.c cur_size = evbuffer_get_length(bev->input); bev 246 opal/mca/event/libevent2022/libevent/bufferevent_async.c read_high = bev->wm_read.high; bev 259 opal/mca/event/libevent2022/libevent/bufferevent_async.c limit = (int)_bufferevent_get_read_max(&beva->bev); bev 263 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (beva->bev.read_suspended) { bev 268 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_incref(bev); bev 269 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (evbuffer_launch_read(bev->input, at_most, &beva->read_overlapped)) { bev 271 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_eventcb(bev, BEV_EVENT_ERROR); bev 272 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_decref(bev); bev 275 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decrement_read_buckets(&beva->bev, at_most); bev 287 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = arg; bev 288 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_async *bev_async = upcast(bev); bev 293 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_incref_and_lock(bev); bev 298 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decref_and_unlock(bev); bev 306 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = arg; bev 307 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_async *bev_async = upcast(bev); bev 312 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_incref_and_lock(bev); bev 317 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decref_and_unlock(bev); bev 328 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (bev_async->bev.connecting) { bev 349 opal/mca/event/libevent2022/libevent/bufferevent_async.c be_async_disable(struct bufferevent *bev, short what) bev 351 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_async *bev_async = upcast(bev); bev 357 opal/mca/event/libevent2022/libevent/bufferevent_async.c BEV_DEL_GENERIC_READ_TIMEOUT(bev); bev 361 opal/mca/event/libevent2022/libevent/bufferevent_async.c BEV_DEL_GENERIC_WRITE_TIMEOUT(bev); bev 369 opal/mca/event/libevent2022/libevent/bufferevent_async.c be_async_destruct(struct bufferevent *bev) bev 371 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_async *bev_async = upcast(bev); bev 372 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_private *bev_p = BEV_UPCAST(bev); bev 375 opal/mca/event/libevent2022/libevent/bufferevent_async.c EVUTIL_ASSERT(!upcast(bev)->write_in_progress && bev 376 opal/mca/event/libevent2022/libevent/bufferevent_async.c !upcast(bev)->read_in_progress); bev 381 opal/mca/event/libevent2022/libevent/bufferevent_async.c fd = _evbuffer_overlapped_get_fd(bev->input); bev 387 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (event_initialized(&bev->ev_write)) { bev 388 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_del(&bev->ev_write); bev 389 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_del_generic_timeout_cbs(bev); bev 396 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_set_wsa_error(struct bufferevent *bev, struct event_overlapped *eo) bev 401 opal/mca/event/libevent2022/libevent/bufferevent_async.c fd = _evbuffer_overlapped_get_fd(bev->input); bev 406 opal/mca/event/libevent2022/libevent/bufferevent_async.c be_async_flush(struct bufferevent *bev, short what, bev 417 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &bev_a->bev.bev; bev 420 opal/mca/event/libevent2022/libevent/bufferevent_async.c BEV_LOCK(bev); bev 422 opal/mca/event/libevent2022/libevent/bufferevent_async.c EVUTIL_ASSERT(bev_a->bev.connecting); bev 423 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_a->bev.connecting = 0; bev 424 opal/mca/event/libevent2022/libevent/bufferevent_async.c sock = _evbuffer_overlapped_get_fd(bev_a->bev.bev.input); bev 429 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_async_set_connected(bev); bev 431 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_set_wsa_error(bev, eo); bev 433 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_eventcb(bev, bev 436 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_base_del_virtual(bev->ev_base); bev 438 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decref_and_unlock(bev); bev 446 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &bev_a->bev.bev; bev 449 opal/mca/event/libevent2022/libevent/bufferevent_async.c BEV_LOCK(bev); bev 453 opal/mca/event/libevent2022/libevent/bufferevent_async.c evbuffer_commit_read(bev->input, nbytes); bev 456 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decrement_read_buckets(&bev_a->bev, -amount_unread); bev 459 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_set_wsa_error(bev, eo); bev 463 opal/mca/event/libevent2022/libevent/bufferevent_async.c BEV_RESET_GENERIC_READ_TIMEOUT(bev); bev 464 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (evbuffer_get_length(bev->input) >= bev->wm_read.low) bev 465 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_readcb(bev); bev 470 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_eventcb(bev, what); bev 474 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_eventcb(bev, what); bev 478 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decref_and_unlock(bev); bev 486 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev = &bev_a->bev.bev; bev 490 opal/mca/event/libevent2022/libevent/bufferevent_async.c BEV_LOCK(bev); bev 494 opal/mca/event/libevent2022/libevent/bufferevent_async.c evbuffer_commit_write(bev->output, nbytes); bev 498 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decrement_write_buckets(&bev_a->bev, bev 503 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_set_wsa_error(bev, eo); bev 507 opal/mca/event/libevent2022/libevent/bufferevent_async.c BEV_RESET_GENERIC_WRITE_TIMEOUT(bev); bev 508 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (evbuffer_get_length(bev->output) <= bev 509 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev->wm_write.low) bev 510 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_writecb(bev); bev 515 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_eventcb(bev, what); bev 519 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_run_eventcb(bev, what); bev 523 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_decref_and_unlock(bev); bev 531 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent *bev; bev 551 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev = &bev_a->bev.bev; bev 552 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (!(bev->input = evbuffer_overlapped_new(fd))) { bev 556 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (!(bev->output = evbuffer_overlapped_new(fd))) { bev 557 opal/mca/event/libevent2022/libevent/bufferevent_async.c evbuffer_free(bev->input); bev 562 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (bufferevent_init_common(&bev_a->bev, base, &bufferevent_ops_async, bev 566 opal/mca/event/libevent2022/libevent/bufferevent_async.c evbuffer_add_cb(bev->input, be_async_inbuf_callback, bev); bev 567 opal/mca/event/libevent2022/libevent/bufferevent_async.c evbuffer_add_cb(bev->output, be_async_outbuf_callback, bev); bev 575 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_init_generic_timeout_cbs(bev); bev 577 opal/mca/event/libevent2022/libevent/bufferevent_async.c return bev; bev 579 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_free(&bev_a->bev.bev); bev 584 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_async_set_connected(struct bufferevent *bev) bev 586 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_async *bev_async = upcast(bev); bev 588 opal/mca/event/libevent2022/libevent/bufferevent_async.c _bufferevent_init_generic_timeout_cbs(bev); bev 590 opal/mca/event/libevent2022/libevent/bufferevent_async.c be_async_enable(bev, bev->enabled); bev 594 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_async_can_connect(struct bufferevent *bev) bev 599 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (BEV_IS_ASYNC(bev) && bev 600 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_base_get_iocp(bev->ev_base) && bev 608 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_async_connect(struct bufferevent *bev, evutil_socket_t fd, bev 612 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_async *bev_async = upcast(bev); bev 640 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_base_add_virtual(bev->ev_base); bev 641 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_incref(bev); bev 647 opal/mca/event/libevent2022/libevent/bufferevent_async.c event_base_del_virtual(bev->ev_base); bev 648 opal/mca/event/libevent2022/libevent/bufferevent_async.c bufferevent_decref(bev); bev 654 opal/mca/event/libevent2022/libevent/bufferevent_async.c be_async_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, bev 659 opal/mca/event/libevent2022/libevent/bufferevent_async.c data->fd = _evbuffer_overlapped_get_fd(bev->input); bev 664 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (data->fd == _evbuffer_overlapped_get_fd(bev->input)) bev 666 opal/mca/event/libevent2022/libevent/bufferevent_async.c if (!(iocp = event_base_get_iocp(bev->ev_base))) bev 670 opal/mca/event/libevent2022/libevent/bufferevent_async.c _evbuffer_overlapped_set_fd(bev->input, data->fd); bev 671 opal/mca/event/libevent2022/libevent/bufferevent_async.c _evbuffer_overlapped_set_fd(bev->output, data->fd); bev 675 opal/mca/event/libevent2022/libevent/bufferevent_async.c struct bufferevent_async *bev_a = upcast(bev); bev 676 opal/mca/event/libevent2022/libevent/bufferevent_async.c evutil_socket_t fd = _evbuffer_overlapped_get_fd(bev->input); bev 678 opal/mca/event/libevent2022/libevent/bufferevent_async.c (bev_a->bev.options & BEV_OPT_CLOSE_ON_FREE)) { bev 75 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_private bev; bev 97 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evutil_offsetof(struct bufferevent_filtered, bev.bev), bev 109 opal/mca/event/libevent2022/libevent/bufferevent_filter.c upcast(struct bufferevent *bev) bev 112 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (bev->be_ops != &bufferevent_ops_filter) bev 114 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bev_f = (void*)( ((char*)bev) - bev 115 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evutil_offsetof(struct bufferevent_filtered, bev.bev)); bev 116 opal/mca/event/libevent2022/libevent/bufferevent_filter.c EVUTIL_ASSERT(bev_f->bev.bev.be_ops == &bufferevent_ops_filter); bev 120 opal/mca/event/libevent2022/libevent/bufferevent_filter.c #define downcast(bev_f) (&(bev_f)->bev.bev) bev 183 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (bufferevent_init_common(&bufev_f->bev, underlying->ev_base, bev 215 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_destruct(struct bufferevent *bev) bev 217 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = upcast(bev); bev 222 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (bevf->bev.options & BEV_OPT_CLOSE_ON_FREE) { bev 244 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_del_generic_timeout_cbs(bev); bev 248 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_enable(struct bufferevent *bev, short event) bev 250 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = upcast(bev); bev 252 opal/mca/event/libevent2022/libevent/bufferevent_filter.c BEV_RESET_GENERIC_WRITE_TIMEOUT(bev); bev 255 opal/mca/event/libevent2022/libevent/bufferevent_filter.c BEV_RESET_GENERIC_READ_TIMEOUT(bev); bev 263 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_disable(struct bufferevent *bev, short event) bev 265 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = upcast(bev); bev 267 opal/mca/event/libevent2022/libevent/bufferevent_filter.c BEV_DEL_GENERIC_WRITE_TIMEOUT(bev); bev 269 opal/mca/event/libevent2022/libevent/bufferevent_filter.c BEV_DEL_GENERIC_READ_TIMEOUT(bev); bev 282 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bev = downcast(bevf); bev 287 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (!(bev->enabled & EV_READ) || bev 294 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (state == BEV_NORMAL && bev->wm_read.high) bev 295 opal/mca/event/libevent2022/libevent/bufferevent_filter.c limit = bev->wm_read.high - bev 296 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_get_length(bev->input); bev 299 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bev->input, limit, state, bevf->context); bev 304 opal/mca/event/libevent2022/libevent/bufferevent_filter.c (bev->enabled & EV_READ) && bev 309 opal/mca/event/libevent2022/libevent/bufferevent_filter.c BEV_RESET_GENERIC_READ_TIMEOUT(bev); bev 400 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bev = downcast(bevf); bev 406 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_incref_and_lock(bev); bev 408 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_decref_and_unlock(bev); bev 449 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bev = downcast(bevf); bev 452 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_incref_and_lock(bev); bev 454 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_decref_and_unlock(bev); bev 462 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bev = downcast(bevf); bev 464 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_incref_and_lock(bev); bev 466 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_run_eventcb(bev, what); bev 467 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_decref_and_unlock(bev); bev 496 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, bev 502 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bevf = upcast(bev); bev 287 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_private bev; bev 336 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c evutil_offsetof(struct bufferevent_openssl, bev.bev), bev 348 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c upcast(struct bufferevent *bev) bev 351 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev->be_ops != &bufferevent_ops_openssl) bev 353 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_o = (void*)( ((char*)bev) - bev 354 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c evutil_offsetof(struct bufferevent_openssl, bev.bev)); bev 355 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c EVUTIL_ASSERT(bev_o->bev.bev.be_ops == &bufferevent_ops_openssl); bev 383 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 385 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read); bev 387 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev->ev_write, bev 388 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c &bev->timeout_write); bev 403 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 404 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write); bev 406 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev->ev_read, bev 407 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c &bev->timeout_read); bev 421 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 422 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev->ev_read); bev 434 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 435 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev->ev_write); bev 460 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 463 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!(bev->enabled & EV_WRITE)) bev 465 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev->enabled & EV_READ) bev 474 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 477 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!(bev->enabled & EV_READ)) bev 479 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev->enabled & EV_WRITE) bev 531 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, event); bev 552 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decrement_write_buckets(&bev_ssl->bev, w); bev 554 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decrement_read_buckets(&bev_ssl->bev, r); bev 568 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 569 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct evbuffer *input = bev->input; bev 574 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.read_suspended) bev 577 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c atmost = _bufferevent_get_read_max(&bev_ssl->bev); bev 586 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.read_suspended) bev 626 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BEV_RESET_GENERIC_READ_TIMEOUT(bev); bev 638 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 639 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct evbuffer *output = bev->output; bev 646 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c atmost = _bufferevent_get_write_max(&bev_ssl->bev); bev 655 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.write_suspended) bev 705 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BEV_RESET_GENERIC_WRITE_TIMEOUT(bev); bev 707 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (evbuffer_get_length(output) <= bev->wm_write.low) bev 708 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_writecb(bev); bev 720 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bytes_to_read(struct bufferevent_openssl *bev) bev 722 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct evbuffer *input = bev->bev.bev.input; bev 723 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct event_watermark *wm = &bev->bev.bev.wm_read; bev 729 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev->write_blocked_on_read) { bev 733 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (! (bev->bev.bev.enabled & EV_READ)) { bev 737 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev->bev.read_suspended) { bev 752 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c limit = _bufferevent_get_read_max(&bev->bev); bev 789 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.read_suspended) bev 821 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 822 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct evbuffer *input = bev->input; bev 824 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (evbuffer_get_length(input) >= bev->wm_read.low) { bev 825 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_readcb(bev); bev 831 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.read_suspended || bev 832 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c !(bev_ssl->bev.bev.enabled & EV_READ)) { bev 833 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev_ssl->bev.bev.ev_read); bev 842 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct evbuffer *output = bev_ssl->bev.bev.output; bev 849 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 850 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct evbuffer *input = bev->input; bev 852 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (evbuffer_get_length(input) >= bev->wm_read.low) { bev 853 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_readcb(bev); bev 865 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c while ((bev_ssl->bev.bev.enabled & EV_WRITE) && bev 866 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c (! bev_ssl->bev.write_suspended) && bev 881 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev_ssl->bev.bev.ev_write); bev 882 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c } else if (bev_ssl->bev.write_suspended || bev 883 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c !(bev_ssl->bev.bev.enabled & EV_WRITE)) { bev 885 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev_ssl->bev.bev.ev_write); bev 926 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, event); bev 933 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_incref_and_lock(&bev_ssl->bev.bev); bev 935 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, bev 940 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decref_and_unlock(&bev_ssl->bev.bev); bev 947 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_incref_and_lock(&bev_ssl->bev.bev); bev 949 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, bev 954 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decref_and_unlock(&bev_ssl->bev.bev); bev 966 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 969 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c fd = event_get_fd(&bev->ev_read); bev 971 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c rpending = event_pending(&bev->ev_read, EV_READ, NULL); bev 972 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c wpending = event_pending(&bev->ev_write, EV_WRITE, NULL); bev 973 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev->ev_read); bev 974 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev->ev_write); bev 976 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_assign(&bev->ev_read, bev->ev_base, fd, bev 978 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_assign(&bev->ev_write, bev->ev_base, fd, bev 981 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r1 = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read); bev 983 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r2 = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write); bev 1013 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_enable(&bev_ssl->bev.bev, bev_ssl->bev.bev.enabled); bev 1014 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, bev 1052 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_incref_and_lock(&bev_ssl->bev.bev); bev 1054 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_run_eventcb(&bev_ssl->bev.bev, BEV_EVENT_TIMEOUT); bev 1057 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decref_and_unlock(&bev_ssl->bev.bev); bev 1070 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bev = &bev_ssl->bev.bev; bev 1073 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c fd = event_get_fd(&bev->ev_read); bev 1075 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev->ev_read); bev 1076 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev->ev_write); bev 1078 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_assign(&bev->ev_read, bev->ev_base, fd, bev 1080 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_assign(&bev->ev_write, bev->ev_base, fd, bev 1083 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r1 = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read); bev 1084 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r2 = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write); bev 1092 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_ssl_renegotiate(struct bufferevent *bev) bev 1094 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev 1117 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev_ssl->bev.bev.ev_write, bev 1118 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c &bev_ssl->bev.bev.timeout_write); bev 1127 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c be_openssl_enable(struct bufferevent *bev, short events) bev 1129 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev 1142 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BEV_RESET_GENERIC_READ_TIMEOUT(bev); bev 1144 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BEV_RESET_GENERIC_WRITE_TIMEOUT(bev); bev 1155 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c be_openssl_disable(struct bufferevent *bev, short events) bev 1157 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev 1168 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BEV_DEL_GENERIC_READ_TIMEOUT(bev); bev 1170 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BEV_DEL_GENERIC_WRITE_TIMEOUT(bev); bev 1176 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c be_openssl_destruct(struct bufferevent *bev) bev 1178 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev 1181 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_del_generic_timeout_cbs(bev); bev 1183 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev->ev_read); bev 1184 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c event_del(&bev->ev_write); bev 1187 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bev_ssl->bev.options & BEV_OPT_CLOSE_ON_FREE) { bev 1217 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c be_openssl_adj_timeouts(struct bufferevent *bev) bev 1219 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev 1222 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return _bufferevent_generic_adj_timeouts(bev); bev 1225 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (event_pending(&bev->ev_read, EV_READ, NULL)) bev 1226 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r1 = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read); bev 1227 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (event_pending(&bev->ev_write, EV_WRITE, NULL)) bev 1228 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r2 = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write); bev 1242 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c be_openssl_ctrl(struct bufferevent *bev, bev 1245 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bev); bev 1266 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c data->fd = event_get_fd(&bev->ev_read); bev 1306 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_p = &bev_ssl->bev; bev 1319 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->outbuf_cb = evbuffer_add_cb(bev_p->bev.output, bev 1323 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_enable_locking(&bev_ssl->bev.bev, NULL); bev 1326 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_init_generic_timeout_cbs(&bev_ssl->bev.bev); bev 1361 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl->bev.bev.enabled = EV_READ|EV_WRITE; bev 1364 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (event_add(&bev_ssl->bev.bev.ev_read, NULL) < 0) bev 1366 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (event_add(&bev_ssl->bev.bev.ev_write, NULL) < 0) bev 1371 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return &bev_ssl->bev.bev; bev 1374 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_free(&bev_ssl->bev.bev); bev 1443 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_get_openssl_error(struct bufferevent *bev) bev 1447 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BEV_LOCK(bev); bev 1448 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bev_ssl = upcast(bev); bev 1452 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c BEV_UNLOCK(bev); bev 46 opal/mca/event/libevent2022/libevent/bufferevent_pair.c struct bufferevent_private bev; bev 54 opal/mca/event/libevent2022/libevent/bufferevent_pair.c upcast(struct bufferevent *bev) bev 57 opal/mca/event/libevent2022/libevent/bufferevent_pair.c if (bev->be_ops != &bufferevent_ops_pair) bev 59 opal/mca/event/libevent2022/libevent/bufferevent_pair.c bev_p = EVUTIL_UPCAST(bev, struct bufferevent_pair, bev.bev); bev 60 opal/mca/event/libevent2022/libevent/bufferevent_pair.c EVUTIL_ASSERT(bev_p->bev.bev.be_ops == &bufferevent_ops_pair); bev 64 opal/mca/event/libevent2022/libevent/bufferevent_pair.c #define downcast(bev_pair) (&(bev_pair)->bev.bev) bev 97 opal/mca/event/libevent2022/libevent/bufferevent_pair.c if (bufferevent_init_common(&bufev->bev, base, &bufferevent_ops_pair, bev 102 opal/mca/event/libevent2022/libevent/bufferevent_pair.c if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { bev 107 opal/mca/event/libevent2022/libevent/bufferevent_pair.c _bufferevent_init_generic_timeout_cbs(&bufev->bev.bev); bev 133 opal/mca/event/libevent2022/libevent/bufferevent_pair.c bufferevent_enable_locking(downcast(bufev2), bufev1->bev.lock); bev 205 opal/mca/event/libevent2022/libevent/bufferevent_pair.c !dst->bev.read_suspended && bev 258 opal/mca/event/libevent2022/libevent/bufferevent_pair.c be_pair_disable(struct bufferevent *bev, short events) bev 261 opal/mca/event/libevent2022/libevent/bufferevent_pair.c BEV_DEL_GENERIC_READ_TIMEOUT(bev); bev 264 opal/mca/event/libevent2022/libevent/bufferevent_pair.c BEV_DEL_GENERIC_WRITE_TIMEOUT(bev); bev 269 opal/mca/event/libevent2022/libevent/bufferevent_pair.c be_pair_destruct(struct bufferevent *bev) bev 271 opal/mca/event/libevent2022/libevent/bufferevent_pair.c struct bufferevent_pair *bev_p = upcast(bev); bev 278 opal/mca/event/libevent2022/libevent/bufferevent_pair.c _bufferevent_del_generic_timeout_cbs(bev); bev 282 opal/mca/event/libevent2022/libevent/bufferevent_pair.c be_pair_flush(struct bufferevent *bev, short iotype, bev 285 opal/mca/event/libevent2022/libevent/bufferevent_pair.c struct bufferevent_pair *bev_p = upcast(bev); bev 287 opal/mca/event/libevent2022/libevent/bufferevent_pair.c incref_and_lock(bev); bev 297 opal/mca/event/libevent2022/libevent/bufferevent_pair.c be_pair_transfer(partner, bev, 1); bev 300 opal/mca/event/libevent2022/libevent/bufferevent_pair.c be_pair_transfer(bev, partner, 1); bev 305 opal/mca/event/libevent2022/libevent/bufferevent_pair.c decref_and_unlock(bev); bev 310 opal/mca/event/libevent2022/libevent/bufferevent_pair.c bufferevent_pair_get_partner(struct bufferevent *bev) bev 314 opal/mca/event/libevent2022/libevent/bufferevent_pair.c bev_p = upcast(bev); bev 318 opal/mca/event/libevent2022/libevent/bufferevent_pair.c incref_and_lock(bev); bev 321 opal/mca/event/libevent2022/libevent/bufferevent_pair.c decref_and_unlock(bev); bev 327 opal/mca/event/libevent2022/libevent/bufferevent_pair.c evutil_offsetof(struct bufferevent_pair, bev.bev), bev 113 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_update_buckets(struct bufferevent_private *bev) bev 118 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_base_gettimeofday_cached(bev->bev.ev_base, &now); bev 119 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c tick = ev_token_bucket_get_tick(&now, bev->rate_limiting->cfg); bev 120 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (tick != bev->rate_limiting->limit.last_updated) bev 121 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_token_bucket_update(&bev->rate_limiting->limit, bev 122 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->cfg, tick); bev 200 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bufferevent_get_rlim_max(struct bufferevent_private *bev, int is_write) bev 218 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!bev->rate_limiting) bev 226 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->cfg) { bev 227 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_update_buckets(bev); bev 228 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c max_so_far = LIM(bev->rate_limiting->limit); bev 230 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group) { bev 232 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group; bev 240 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_write(&bev->bev, bev 243 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_read(&bev->bev, bev 263 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bufferevent_get_read_max(struct bufferevent_private *bev) bev 265 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return _bufferevent_get_rlim_max(bev, 0); bev 269 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bufferevent_get_write_max(struct bufferevent_private *bev) bev 271 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return _bufferevent_get_rlim_max(bev, 1); bev 275 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bufferevent_decrement_read_buckets(struct bufferevent_private *bev, ev_ssize_t bytes) bev 280 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!bev->rate_limiting) bev 283 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->cfg) { bev 284 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->limit.read_limit -= bytes; bev 285 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->limit.read_limit <= 0) { bev 286 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_read(&bev->bev, BEV_SUSPEND_BW); bev 287 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (event_add(&bev->rate_limiting->refill_bucket_event, bev 288 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &bev->rate_limiting->cfg->tick_timeout) < 0) bev 290 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c } else if (bev->read_suspended & BEV_SUSPEND_BW) { bev 291 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!(bev->write_suspended & BEV_SUSPEND_BW)) bev 292 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_del(&bev->rate_limiting->refill_bucket_event); bev 293 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_read(&bev->bev, BEV_SUSPEND_BW); bev 297 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group) { bev 298 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c LOCK_GROUP(bev->rate_limiting->group); bev 299 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->rate_limit.read_limit -= bytes; bev 300 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->total_read += bytes; bev 301 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group->rate_limit.read_limit <= 0) { bev 302 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_suspend_reading(bev->rate_limiting->group); bev 303 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c } else if (bev->rate_limiting->group->read_suspended) { bev 304 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_unsuspend_reading(bev->rate_limiting->group); bev 306 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c UNLOCK_GROUP(bev->rate_limiting->group); bev 313 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bufferevent_decrement_write_buckets(struct bufferevent_private *bev, ev_ssize_t bytes) bev 318 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!bev->rate_limiting) bev 321 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->cfg) { bev 322 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->limit.write_limit -= bytes; bev 323 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->limit.write_limit <= 0) { bev 324 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_write(&bev->bev, BEV_SUSPEND_BW); bev 325 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (event_add(&bev->rate_limiting->refill_bucket_event, bev 326 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &bev->rate_limiting->cfg->tick_timeout) < 0) bev 328 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c } else if (bev->write_suspended & BEV_SUSPEND_BW) { bev 329 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!(bev->read_suspended & BEV_SUSPEND_BW)) bev 330 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_del(&bev->rate_limiting->refill_bucket_event); bev 331 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_write(&bev->bev, BEV_SUSPEND_BW); bev 335 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group) { bev 336 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c LOCK_GROUP(bev->rate_limiting->group); bev 337 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->rate_limit.write_limit -= bytes; bev 338 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->total_written += bytes; bev 339 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group->rate_limit.write_limit <= 0) { bev 340 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_suspend_writing(bev->rate_limiting->group); bev 341 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c } else if (bev->rate_limiting->group->write_suspended) { bev 342 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_unsuspend_writing(bev->rate_limiting->group); bev 344 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c UNLOCK_GROUP(bev->rate_limiting->group); bev 355 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_private *bev; bev 365 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c TAILQ_FOREACH(bev, &g->members, rate_limiting->next_in_group) { bev 366 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (EVLOCK_TRY_LOCK(bev->lock)) { bev 367 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_read(&bev->bev, bev 369 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVLOCK_UNLOCK(bev->lock, 0); bev 380 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_private *bev; bev 383 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c TAILQ_FOREACH(bev, &g->members, rate_limiting->next_in_group) { bev 384 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (EVLOCK_TRY_LOCK(bev->lock)) { bev 385 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_write(&bev->bev, bev 387 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVLOCK_UNLOCK(bev->lock, 0); bev 400 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_private *bev = arg; bev 402 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(&bev->bev); bev 403 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!bev->rate_limiting || !bev->rate_limiting->cfg) { bev 404 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(&bev->bev); bev 409 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_base_gettimeofday_cached(bev->bev.ev_base, &now); bev 411 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->cfg); bev 412 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_token_bucket_update(&bev->rate_limiting->limit, bev 413 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->cfg, bev 417 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if ((bev->read_suspended & BEV_SUSPEND_BW)) { bev 418 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->limit.read_limit > 0) bev 419 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_read(&bev->bev, BEV_SUSPEND_BW); bev 423 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if ((bev->write_suspended & BEV_SUSPEND_BW)) { bev 424 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->limit.write_limit > 0) bev 425 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_write(&bev->bev, BEV_SUSPEND_BW); bev 437 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_add(&bev->rate_limiting->refill_bucket_event, bev 438 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &bev->rate_limiting->cfg->tick_timeout); bev 440 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(&bev->bev); bev 448 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_private *bev; bev 459 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev = TAILQ_FIRST(&group->members); bev 461 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev = TAILQ_NEXT(bev, rate_limiting->next_in_group); bev 463 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return bev; bev 476 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c for (bev = first; bev != TAILQ_END(&g->members); \ bev 477 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev = TAILQ_NEXT(bev, rate_limiting->next_in_group)) { \ bev 480 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c for (bev = TAILQ_FIRST(&g->members); bev && bev != first; \ bev 481 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev = TAILQ_NEXT(bev, rate_limiting->next_in_group)) { \ bev 490 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_private *bev, *first; bev 494 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (EVLOCK_TRY_LOCK(bev->lock)) { bev 495 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_read(&bev->bev, bev 497 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVLOCK_UNLOCK(bev->lock, 0); bev 509 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_private *bev, *first; bev 513 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (EVLOCK_TRY_LOCK(bev->lock)) { bev 514 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_write(&bev->bev, bev 516 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVLOCK_UNLOCK(bev->lock, 0); bev 559 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_set_rate_limit(struct bufferevent *bev, bev 563 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVUTIL_UPCAST(bev, struct bufferevent_private, bev); bev 571 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 577 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_read(bev, BEV_SUSPEND_BW); bev 578 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_write(bev, BEV_SUSPEND_BW); bev 586 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_base_gettimeofday_cached(bev->ev_base, &now); bev 611 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c evtimer_assign(&rlim->refill_bucket_event, bev->ev_base, bev 615 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_read(bev, BEV_SUSPEND_BW); bev 617 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_read(bev, BEV_SUSPEND_BW); bev 621 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_write(bev, BEV_SUSPEND_BW); bev 623 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_write(bev, BEV_SUSPEND_BW); bev 633 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 732 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_add_to_rate_limit_group(struct bufferevent *bev, bev 737 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVUTIL_UPCAST(bev, struct bufferevent_private, bev); bev 738 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 744 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 747 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c evtimer_assign(&rlim->refill_bucket_event, bev->ev_base, bev 753 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 757 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_remove_from_rate_limit_group(bev); bev 770 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_read(bev, BEV_SUSPEND_BW_GROUP); bev 772 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_write(bev, BEV_SUSPEND_BW_GROUP); bev 774 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 779 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_remove_from_rate_limit_group(struct bufferevent *bev) bev 781 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return bufferevent_remove_from_rate_limit_group_internal(bev, 1); bev 785 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_remove_from_rate_limit_group_internal(struct bufferevent *bev, bev 789 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVUTIL_UPCAST(bev, struct bufferevent_private, bev); bev 790 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 801 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_read(bev, BEV_SUSPEND_BW_GROUP); bev 802 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_write(bev, BEV_SUSPEND_BW_GROUP); bev 804 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 818 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_get_read_limit(struct bufferevent *bev) bev 822 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 823 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bevp = BEV_UPCAST(bev); bev 830 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 837 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_get_write_limit(struct bufferevent *bev) bev 841 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 842 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bevp = BEV_UPCAST(bev); bev 849 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 854 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_get_max_to_read(struct bufferevent *bev) bev 857 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 858 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = _bufferevent_get_read_max(BEV_UPCAST(bev)); bev 859 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 864 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_get_max_to_write(struct bufferevent *bev) bev 867 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 868 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = _bufferevent_get_write_max(BEV_UPCAST(bev)); bev 869 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 901 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_decrement_read_limit(struct bufferevent *bev, ev_ssize_t decr) bev 906 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 907 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bevp = BEV_UPCAST(bev); bev 913 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_read(bev, BEV_SUSPEND_BW); bev 920 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_read(bev, BEV_SUSPEND_BW); bev 923 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 928 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_decrement_write_limit(struct bufferevent *bev, ev_ssize_t decr) bev 935 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_LOCK(bev); bev 936 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bevp = BEV_UPCAST(bev); bev 942 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_suspend_write(bev, BEV_SUSPEND_BW); bev 949 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_unsuspend_write(bev, BEV_SUSPEND_BW); bev 952 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c BEV_UNLOCK(bev); bev 89 opal/mca/event/libevent2022/libevent/bufferevent_sock.c evutil_offsetof(struct bufferevent_private, bev), bev 108 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 127 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 206 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 336 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufev = &bufev_p->bev; bev 353 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_socket_connect(struct bufferevent *bev, bev 357 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bev, struct bufferevent_private, bev); bev 364 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_incref_and_lock(bev); bev 369 opal/mca/event/libevent2022/libevent/bufferevent_sock.c fd = bufferevent_getfd(bev); bev 382 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (bufferevent_async_can_connect(bev)) { bev 383 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_setfd(bev, fd); bev 384 opal/mca/event/libevent2022/libevent/bufferevent_sock.c r = bufferevent_async_connect(bev, fd, sa, socklen); bev 400 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (BEV_IS_ASYNC(bev)) { bev 401 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_assign(&bev->ev_write, bev->ev_base, fd, bev 402 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EV_WRITE|EV_PERSIST, bufferevent_writecb, bev); bev 405 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_setfd(bev, fd); bev 407 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (! be_socket_enable(bev, EV_WRITE)) { bev 416 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_active(&bev->ev_write, EV_WRITE, 1); bev 422 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_active(&bev->ev_write, EV_WRITE, 1); bev 428 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_eventcb(bev, BEV_EVENT_ERROR); bev 433 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_decref_and_unlock(bev); bev 441 opal/mca/event/libevent2022/libevent/bufferevent_sock.c struct bufferevent *bev = arg; bev 443 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bev, struct bufferevent_private, bev); bev 445 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_LOCK(bev); bev 447 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_unsuspend_write(bev, BEV_SUSPEND_LOOKUP); bev 448 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_unsuspend_read(bev, BEV_SUSPEND_LOOKUP); bev 452 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_eventcb(bev, BEV_EVENT_ERROR); bev 453 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_decref_and_unlock(bev); bev 461 opal/mca/event/libevent2022/libevent/bufferevent_sock.c r = bufferevent_socket_connect(bev, ai->ai_addr, (int)ai->ai_addrlen); bev 463 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_decref_and_unlock(bev); bev 468 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_socket_connect_hostname(struct bufferevent *bev, bev 475 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bev, struct bufferevent_private, bev); bev 482 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_LOCK(bev); bev 484 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_UNLOCK(bev); bev 493 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_suspend_write(bev, BEV_SUSPEND_LOOKUP); bev 494 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_suspend_read(bev, BEV_SUSPEND_LOOKUP); bev 496 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_incref(bev); bev 498 opal/mca/event/libevent2022/libevent/bufferevent_sock.c &hint, bufferevent_connect_getaddrinfo_cb, bev); bev 503 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_unsuspend_write(bev, BEV_SUSPEND_LOOKUP); bev 504 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_unsuspend_read(bev, BEV_SUSPEND_LOOKUP); bev 510 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_socket_get_dns_error(struct bufferevent *bev) bev 514 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bev, struct bufferevent_private, bev); bev 516 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_LOCK(bev); bev 518 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_UNLOCK(bev); bev 568 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 585 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bev 613 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_flush(struct bufferevent *bev, short iotype, bev 684 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, bev 689 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_setfd(bev, data->fd); bev 692 opal/mca/event/libevent2022/libevent/bufferevent_sock.c data->fd = event_get_fd(&bev->ev_read); bev 285 opal/mca/event/libevent2022/libevent/evbuffer-internal.h void evbuffer_set_parent(struct evbuffer *buf, struct bufferevent *bev); bev 133 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx); bev 149 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short what, void *ctx); bev 245 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_socket_get_dns_error(struct bufferevent *bev); bev 263 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h struct event_base *bufferevent_get_base(struct bufferevent *bev); bev 96 opal/mca/event/libevent2022/libevent/include/event2/bufferevent_ssl.h int bufferevent_ssl_renegotiate(struct bufferevent *bev); bev 99 opal/mca/event/libevent2022/libevent/include/event2/bufferevent_ssl.h unsigned long bufferevent_get_openssl_error(struct bufferevent *bev); bev 192 opal/mca/event/libevent2022/libevent/iocp-internal.h void bufferevent_async_set_connected(struct bufferevent *bev); bev 193 opal/mca/event/libevent2022/libevent/iocp-internal.h int bufferevent_async_can_connect(struct bufferevent *bev); bev 194 opal/mca/event/libevent2022/libevent/iocp-internal.h int bufferevent_async_connect(struct bufferevent *bev, evutil_socket_t fd, bev 87 opal/mca/event/libevent2022/libevent/ratelim-internal.h int bufferevent_remove_from_rate_limit_group_internal(struct bufferevent *bev, bev 93 opal/mca/event/libevent2022/libevent/sample/hello-world.c struct bufferevent *bev; bev 95 opal/mca/event/libevent2022/libevent/sample/hello-world.c bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE); bev 96 opal/mca/event/libevent2022/libevent/sample/hello-world.c if (!bev) { bev 101 opal/mca/event/libevent2022/libevent/sample/hello-world.c bufferevent_setcb(bev, NULL, conn_writecb, conn_eventcb, NULL); bev 102 opal/mca/event/libevent2022/libevent/sample/hello-world.c bufferevent_enable(bev, EV_WRITE); bev 103 opal/mca/event/libevent2022/libevent/sample/hello-world.c bufferevent_disable(bev, EV_READ); bev 105 opal/mca/event/libevent2022/libevent/sample/hello-world.c bufferevent_write(bev, MESSAGE, strlen(MESSAGE)); bev 109 opal/mca/event/libevent2022/libevent/sample/hello-world.c conn_writecb(struct bufferevent *bev, void *user_data) bev 111 opal/mca/event/libevent2022/libevent/sample/hello-world.c struct evbuffer *output = bufferevent_get_output(bev); bev 114 opal/mca/event/libevent2022/libevent/sample/hello-world.c bufferevent_free(bev); bev 119 opal/mca/event/libevent2022/libevent/sample/hello-world.c conn_eventcb(struct bufferevent *bev, short events, void *user_data) bev 129 opal/mca/event/libevent2022/libevent/sample/hello-world.c bufferevent_free(bev); bev 42 opal/mca/event/libevent2022/libevent/sample/le-proxy.c static void drained_writecb(struct bufferevent *bev, void *ctx); bev 43 opal/mca/event/libevent2022/libevent/sample/le-proxy.c static void eventcb(struct bufferevent *bev, short what, void *ctx); bev 46 opal/mca/event/libevent2022/libevent/sample/le-proxy.c readcb(struct bufferevent *bev, void *ctx) bev 51 opal/mca/event/libevent2022/libevent/sample/le-proxy.c src = bufferevent_get_input(bev); bev 65 opal/mca/event/libevent2022/libevent/sample/le-proxy.c eventcb, bev); bev 68 opal/mca/event/libevent2022/libevent/sample/le-proxy.c bufferevent_disable(bev, EV_READ); bev 73 opal/mca/event/libevent2022/libevent/sample/le-proxy.c drained_writecb(struct bufferevent *bev, void *ctx) bev 79 opal/mca/event/libevent2022/libevent/sample/le-proxy.c bufferevent_setcb(bev, readcb, NULL, eventcb, partner); bev 80 opal/mca/event/libevent2022/libevent/sample/le-proxy.c bufferevent_setwatermark(bev, EV_WRITE, 0, 0); bev 86 opal/mca/event/libevent2022/libevent/sample/le-proxy.c close_on_finished_writecb(struct bufferevent *bev, void *ctx) bev 88 opal/mca/event/libevent2022/libevent/sample/le-proxy.c struct evbuffer *b = bufferevent_get_output(bev); bev 91 opal/mca/event/libevent2022/libevent/sample/le-proxy.c bufferevent_free(bev); bev 96 opal/mca/event/libevent2022/libevent/sample/le-proxy.c eventcb(struct bufferevent *bev, short what, void *ctx) bev 103 opal/mca/event/libevent2022/libevent/sample/le-proxy.c while ((err = (bufferevent_get_openssl_error(bev)))) { bev 119 opal/mca/event/libevent2022/libevent/sample/le-proxy.c readcb(bev, ctx); bev 136 opal/mca/event/libevent2022/libevent/sample/le-proxy.c bufferevent_free(bev); bev 90 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c readcb(struct bufferevent *bev, void *arg) bev 92 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c if (evbuffer_get_length(bev->input) == 8333) { bev 97 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_read_buffer(bev, evbuf); bev 99 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_disable(bev, EV_READ); bev 110 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c writecb(struct bufferevent *bev, void *arg) bev 112 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c if (evbuffer_get_length(bev->output) == 0) { bev 118 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c errorcb(struct bufferevent *bev, short what, void *arg) bev 190 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c wm_readcb(struct bufferevent *bev, void *arg) bev 193 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c int len = (int)evbuffer_get_length(bev->input); bev 201 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_read_buffer(bev, evbuf); bev 205 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_disable(bev, EV_READ); bev 213 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c wm_writecb(struct bufferevent *bev, void *arg) bev 215 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c assert(evbuffer_get_length(bev->output) <= 100); bev 216 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c if (evbuffer_get_length(bev->output) == 0) { bev 217 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c evbuffer_drain(bev->output, evbuffer_get_length(bev->output)); bev 223 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c wm_errorcb(struct bufferevent *bev, short what, void *arg) bev 406 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c sender_writecb(struct bufferevent *bev, void *ctx) bev 408 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { bev 409 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_disable(bev,EV_READ|EV_WRITE); bev 410 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_free(bev); bev 415 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c sender_errorcb(struct bufferevent *bev, short what, void *ctx) bev 431 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c struct bufferevent *bev; bev 434 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bev = bufferevent_socket_new(base, fd, bufferevent_connect_test_flags); bev 435 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c tt_assert(bev); bev 436 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_setcb(bev, NULL, sender_writecb, sender_errorcb, NULL); bev 437 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_write(bev, s, sizeof(s)); bev 443 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c reader_eventcb(struct bufferevent *bev, short what, void *ctx) bev 452 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_enable(bev, EV_READ); bev 457 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c n = bufferevent_read(bev, buf, sizeof(buf)-1); bev 468 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c reader_readcb(struct bufferevent *bev, void *ctx) bev 552 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c want_fail_eventcb(struct bufferevent *bev, short what, void *ctx) bev 559 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c s = bufferevent_getfd(bev); bev 585 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c struct bufferevent *bev=NULL; bev 608 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bev = bufferevent_socket_new(data->base, -1, bev 610 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c tt_assert(bev); bev 611 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_setcb(bev, NULL, NULL, want_fail_eventcb, data->base); bev 613 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c r = bufferevent_socket_connect(bev, sa, slen); bev 633 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c if (bev) bev 634 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bufferevent_free(bev); bev 650 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bev_timeout_write_cb(struct bufferevent *bev, void *arg) bev 657 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c bev_timeout_event_cb(struct bufferevent *bev, short what, void *arg) bev 1014 opal/mca/event/libevent2022/libevent/test/regress_dns.c be_connect_hostname_event_cb(struct bufferevent *bev, short what, void *ctx) bev 1023 opal/mca/event/libevent2022/libevent/test/regress_dns.c if ((r = bufferevent_socket_get_dns_error(bev))) { bev 205 opal/mca/event/libevent2022/libevent/test/regress_http.c http_readcb(struct bufferevent *bev, void *arg) bev 210 opal/mca/event/libevent2022/libevent/test/regress_http.c if (evbuffer_contains(bufferevent_get_input(bev), what)) { bev 215 opal/mca/event/libevent2022/libevent/test/regress_http.c done = evhttp_parse_firstline(req, bufferevent_get_input(bev)); bev 219 opal/mca/event/libevent2022/libevent/test/regress_http.c done = evhttp_parse_headers(req, bufferevent_get_input(bev)); bev 230 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_disable(bev, EV_READ); bev 243 opal/mca/event/libevent2022/libevent/test/regress_http.c http_writecb(struct bufferevent *bev, void *arg) bev 245 opal/mca/event/libevent2022/libevent/test/regress_http.c if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { bev 247 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_enable(bev, EV_READ); bev 253 opal/mca/event/libevent2022/libevent/test/regress_http.c http_errorcb(struct bufferevent *bev, short what, void *arg) bev 349 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev = arg; bev 353 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 361 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev; bev 379 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 380 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_readcb, http_writecb, bev 388 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 392 opal/mca/event/libevent2022/libevent/test/regress_http.c -1, EV_TIMEOUT, http_complete_write, bev, &tv); bev 399 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 405 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 406 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_readcb, http_writecb, bev 415 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 422 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 428 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 429 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_readcb, http_writecb, bev 438 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 483 opal/mca/event/libevent2022/libevent/test/regress_http.c http_badreq_errorcb(struct bufferevent *bev, short what, void *arg) bev 498 opal/mca/event/libevent2022/libevent/test/regress_http.c http_badreq_readcb(struct bufferevent *bev, void *arg) bev 503 opal/mca/event/libevent2022/libevent/test/regress_http.c if (evbuffer_contains(bufferevent_get_input(bev), bad_request)) { bev 505 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_disable(bev, EV_READ); bev 510 opal/mca/event/libevent2022/libevent/test/regress_http.c if (evbuffer_contains(bufferevent_get_input(bev), what)) { bev 515 opal/mca/event/libevent2022/libevent/test/regress_http.c done = evhttp_parse_firstline(req, bufferevent_get_input(bev)); bev 519 opal/mca/event/libevent2022/libevent/test/regress_http.c done = evhttp_parse_headers(req, bufferevent_get_input(bev)); bev 530 opal/mca/event/libevent2022/libevent/test/regress_http.c evbuffer_drain(bufferevent_get_input(bev), evbuffer_get_length(bufferevent_get_input(bev))); bev 533 opal/mca/event/libevent2022/libevent/test/regress_http.c shutdown(bufferevent_getfd(bev), SHUT_WR); bev 548 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev = NULL; bev 566 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 567 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_badreq_readcb, http_writecb, bev 569 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_enable(bev, EV_READ); bev 574 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 579 opal/mca/event/libevent2022/libevent/test/regress_http.c event_base_once(data->base, -1, EV_TIMEOUT, http_badreq_successcb, bev, &tv); bev 583 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 597 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 598 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_badreq_readcb, http_writecb, bev 600 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_enable(bev, EV_READ); bev 608 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 612 opal/mca/event/libevent2022/libevent/test/regress_http.c event_base_once(data->base, -1, EV_TIMEOUT, http_badreq_successcb, bev, &tv); bev 620 opal/mca/event/libevent2022/libevent/test/regress_http.c if (bev) bev 621 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 667 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev; bev 679 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 680 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_readcb, http_writecb, bev 689 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 693 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 704 opal/mca/event/libevent2022/libevent/test/regress_http.c http_allowed_methods_eventcb(struct bufferevent *bev, short what, void *arg) bev 710 opal/mca/event/libevent2022/libevent/test/regress_http.c n = evbuffer_remove(bufferevent_get_input(bev), buf, bev 1172 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev; bev 1295 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 1296 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_readcb, http_writecb, bev 1306 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 1312 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 1710 opal/mca/event/libevent2022/libevent/test/regress_http.c http_failure_readcb(struct bufferevent *bev, void *arg) bev 1713 opal/mca/event/libevent2022/libevent/test/regress_http.c if (evbuffer_contains(bufferevent_get_input(bev), what)) { bev 1715 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_disable(bev, EV_READ); bev 1727 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev; bev 1739 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 1740 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_failure_readcb, http_writecb, bev 1745 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 1749 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 2477 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev; bev 2489 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(base, fd, 0); bev 2490 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_readcb, http_writecb, bev 2492 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_base_set(base, bev); bev 2500 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 2504 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 2522 opal/mca/event/libevent2022/libevent/test/regress_http.c http_incomplete_readcb(struct bufferevent *bev, void *arg) bev 2529 opal/mca/event/libevent2022/libevent/test/regress_http.c http_incomplete_errorcb(struct bufferevent *bev, short what, void *arg) bev 2539 opal/mca/event/libevent2022/libevent/test/regress_http.c http_incomplete_writecb(struct bufferevent *bev, void *arg) bev 2546 opal/mca/event/libevent2022/libevent/test/regress_http.c if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { bev 2548 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_enable(bev, EV_READ); bev 2556 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev; bev 2572 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 2573 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, bev 2581 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 2590 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 2624 opal/mca/event/libevent2022/libevent/test/regress_http.c http_chunked_readcb(struct bufferevent *bev, void *arg) bev 2630 opal/mca/event/libevent2022/libevent/test/regress_http.c http_chunked_errorcb(struct bufferevent *bev, short what, void *arg) bev 2643 opal/mca/event/libevent2022/libevent/test/regress_http.c done = evhttp_parse_firstline(req, bufferevent_get_input(bev)); bev 2647 opal/mca/event/libevent2022/libevent/test/regress_http.c done = evhttp_parse_headers(req, bufferevent_get_input(bev)); bev 2659 opal/mca/event/libevent2022/libevent/test/regress_http.c header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF); bev 2669 opal/mca/event/libevent2022/libevent/test/regress_http.c if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 13), bev 2673 opal/mca/event/libevent2022/libevent/test/regress_http.c evbuffer_drain(bufferevent_get_input(bev), 13 + 2); bev 2675 opal/mca/event/libevent2022/libevent/test/regress_http.c header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF); bev 2683 opal/mca/event/libevent2022/libevent/test/regress_http.c if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 18), bev 2687 opal/mca/event/libevent2022/libevent/test/regress_http.c evbuffer_drain(bufferevent_get_input(bev), 18 + 2); bev 2689 opal/mca/event/libevent2022/libevent/test/regress_http.c header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF); bev 2699 opal/mca/event/libevent2022/libevent/test/regress_http.c if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 8), bev 2703 opal/mca/event/libevent2022/libevent/test/regress_http.c evbuffer_drain(bufferevent_get_input(bev), 8 + 2); bev 2705 opal/mca/event/libevent2022/libevent/test/regress_http.c header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF); bev 2725 opal/mca/event/libevent2022/libevent/test/regress_http.c http_chunked_writecb(struct bufferevent *bev, void *arg) bev 2727 opal/mca/event/libevent2022/libevent/test/regress_http.c if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { bev 2729 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_enable(bev, EV_READ); bev 2768 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev; bev 2785 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 2786 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, bev 2796 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 2802 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 3256 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev= NULL; bev 3268 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 3269 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, http_readcb, http_writecb, bev 3282 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_start_request, strlen(http_start_request)); bev 3288 opal/mca/event/libevent2022/libevent/test/regress_http.c if (bev) bev 3289 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(bev); bev 3448 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev; bev 3510 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_free(state->bev); bev 3515 opal/mca/event/libevent2022/libevent/test/regress_http.c terminate_readcb(struct bufferevent *bev, void *arg) bev 3518 opal/mca/event/libevent2022/libevent/test/regress_http.c evbuffer_drain(bufferevent_get_input(bev), -1); bev 3526 opal/mca/event/libevent2022/libevent/test/regress_http.c struct bufferevent *bev = NULL; bev 3543 opal/mca/event/libevent2022/libevent/test/regress_http.c bev = bufferevent_socket_new(data->base, fd, 0); bev 3544 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_setcb(bev, terminate_readcb, http_writecb, bev 3550 opal/mca/event/libevent2022/libevent/test/regress_http.c terminate_state.bev = bev; bev 3558 opal/mca/event/libevent2022/libevent/test/regress_http.c bufferevent_write(bev, http_request, strlen(http_request)); bev 297 opal/mca/event/libevent2022/libevent/test/regress_iocp.c async_readcb(struct bufferevent *bev, void *arg) bev 300 opal/mca/event/libevent2022/libevent/test/regress_iocp.c bufferevent_disable(bev, EV_READ); bev 181 opal/mca/event/libevent2022/libevent/test/regress_ssl.c respond_to_number(struct bufferevent *bev, void *ctx) bev 183 opal/mca/event/libevent2022/libevent/test/regress_ssl.c struct evbuffer *b = bufferevent_get_input(bev); bev 195 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_free(bev); /* Should trigger close on other side. */ bev 199 opal/mca/event/libevent2022/libevent/test/regress_ssl.c SSL_renegotiate(bufferevent_openssl_get_ssl(bev)); bev 202 opal/mca/event/libevent2022/libevent/test/regress_ssl.c evbuffer_add_printf(bufferevent_get_output(bev), bev 205 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_enable(bev, EV_WRITE); bev 206 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_disable(bev, EV_READ); bev 210 opal/mca/event/libevent2022/libevent/test/regress_ssl.c done_writing_cb(struct bufferevent *bev, void *ctx) bev 212 opal/mca/event/libevent2022/libevent/test/regress_ssl.c struct evbuffer *b = bufferevent_get_output(bev); bev 216 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_disable(bev, EV_WRITE); bev 217 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_enable(bev, EV_READ); bev 221 opal/mca/event/libevent2022/libevent/test/regress_ssl.c eventcb(struct bufferevent *bev, short what, void *ctx) bev 228 opal/mca/event/libevent2022/libevent/test/regress_ssl.c ssl = bufferevent_openssl_get_ssl(bev); bev 243 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_free(bev); bev 247 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_free(bev); bev 374 opal/mca/event/libevent2022/libevent/test/regress_ssl.c struct bufferevent *bev; bev 380 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bev = bufferevent_openssl_socket_new( bev 387 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_setcb(bev, respond_to_number, NULL, eventcb, bev 390 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_enable(bev, EV_READ|EV_WRITE); bev 404 opal/mca/event/libevent2022/libevent/test/regress_ssl.c struct bufferevent *bev; bev 425 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bev = bufferevent_openssl_socket_new( bev 429 opal/mca/event/libevent2022/libevent/test/regress_ssl.c tt_assert(bev); bev 431 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_setcb(bev, respond_to_number, NULL, eventcb, bev 441 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_socket_connect(bev, (struct sockaddr*)&ss, slen)); bev 442 opal/mca/event/libevent2022/libevent/test/regress_ssl.c evbuffer_add_printf(bufferevent_get_output(bev), "1\n"); bev 443 opal/mca/event/libevent2022/libevent/test/regress_ssl.c bufferevent_enable(bev, EV_READ|EV_WRITE); bev 240 opal/mca/event/libevent2022/libevent/test/regress_zlib.c readcb(struct bufferevent *bev, void *arg) bev 242 opal/mca/event/libevent2022/libevent/test/regress_zlib.c if (evbuffer_get_length(bufferevent_get_input(bev)) == 8333) { bev 247 opal/mca/event/libevent2022/libevent/test/regress_zlib.c bufferevent_read_buffer(bev, evbuf); bev 249 opal/mca/event/libevent2022/libevent/test/regress_zlib.c bufferevent_disable(bev, EV_READ); bev 260 opal/mca/event/libevent2022/libevent/test/regress_zlib.c writecb(struct bufferevent *bev, void *arg) bev 262 opal/mca/event/libevent2022/libevent/test/regress_zlib.c if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { bev 268 opal/mca/event/libevent2022/libevent/test/regress_zlib.c errorcb(struct bufferevent *bev, short what, void *arg) bev 87 opal/mca/event/libevent2022/libevent/test/test-ratelim.c loud_writecb(struct bufferevent *bev, void *ctx) bev 90 opal/mca/event/libevent2022/libevent/test/test-ratelim.c struct evbuffer *output = bufferevent_get_output(bev); bev 105 opal/mca/event/libevent2022/libevent/test/test-ratelim.c discard_readcb(struct bufferevent *bev, void *ctx) bev 108 opal/mca/event/libevent2022/libevent/test/test-ratelim.c struct evbuffer *input = bufferevent_get_input(bev); bev 115 opal/mca/event/libevent2022/libevent/test/test-ratelim.c write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) bev 118 opal/mca/event/libevent2022/libevent/test/test-ratelim.c loud_writecb(bev, ctx); bev 120 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_enable(bev, EV_READ|EV_WRITE); bev 125 opal/mca/event/libevent2022/libevent/test/test-ratelim.c echo_readcb(struct bufferevent *bev, void *ctx) bev 127 opal/mca/event/libevent2022/libevent/test/test-ratelim.c struct evbuffer *input = bufferevent_get_input(bev); bev 128 opal/mca/event/libevent2022/libevent/test/test-ratelim.c struct evbuffer *output = bufferevent_get_output(bev); bev 132 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_disable(bev, EV_READ); bev 136 opal/mca/event/libevent2022/libevent/test/test-ratelim.c echo_writecb(struct bufferevent *bev, void *ctx) bev 138 opal/mca/event/libevent2022/libevent/test/test-ratelim.c struct evbuffer *output = bufferevent_get_output(bev); bev 140 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_enable(bev, EV_READ); bev 144 opal/mca/event/libevent2022/libevent/test/test-ratelim.c echo_eventcb(struct bufferevent *bev, short what, void *ctx) bev 148 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_free(bev); bev 158 opal/mca/event/libevent2022/libevent/test/test-ratelim.c struct bufferevent *bev; bev 160 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bev = bufferevent_socket_new(base, newsock, flags); bev 161 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_setcb(bev, echo_readcb, echo_writecb, echo_eventcb, NULL); bev 163 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_set_rate_limit(bev, conn_bucket_cfg); bev 165 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_add_to_rate_limit_group(bev, ratelim_group); bev 167 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_enable(bev, EV_READ|EV_WRITE);