bufev 277 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what); bufev 280 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void bufferevent_unsuspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what); bufev 284 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void bufferevent_suspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what); bufev 287 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void bufferevent_unsuspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what); bufev 306 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int bufferevent_disable_hard(struct bufferevent *bufev, short event); bufev 310 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int bufferevent_enable_locking(struct bufferevent *bufev, void *lock); bufev 312 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void bufferevent_incref(struct bufferevent *bufev); bufev 315 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void _bufferevent_incref_and_lock(struct bufferevent *bufev); bufev 318 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int bufferevent_decref(struct bufferevent *bufev); bufev 321 opal/mca/event/libevent2022/libevent/bufferevent-internal.h int _bufferevent_decref_and_unlock(struct bufferevent *bufev); bufev 325 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void _bufferevent_run_readcb(struct bufferevent *bufev); bufev 328 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void _bufferevent_run_writecb(struct bufferevent *bufev); bufev 331 opal/mca/event/libevent2022/libevent/bufferevent-internal.h void _bufferevent_run_eventcb(struct bufferevent *bufev, short what); bufev 66 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what) bufev 69 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 70 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 72 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->be_ops->disable(bufev, EV_READ); bufev 74 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 78 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_unsuspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what) bufev 81 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 82 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 84 opal/mca/event/libevent2022/libevent/bufferevent.c if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) bufev 85 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->be_ops->enable(bufev, EV_READ); bufev 86 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 90 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_suspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what) bufev 93 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 94 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 96 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->be_ops->disable(bufev, EV_WRITE); bufev 98 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 102 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_unsuspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what) bufev 105 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 106 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 108 opal/mca/event/libevent2022/libevent/bufferevent.c if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE)) bufev 109 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->be_ops->enable(bufev, EV_WRITE); bufev 110 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 121 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = arg; bufev 126 opal/mca/event/libevent2022/libevent/bufferevent.c if (size >= bufev->wm_read.high) bufev 127 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_wm_suspend_read(bufev); bufev 129 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_wm_unsuspend_read(bufev); bufev 136 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bufev 138 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 140 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->errorcb) { bufev 144 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->errorcb(bufev, BEV_EVENT_CONNECTED, bufev->cbarg); bufev 146 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->readcb_pending && bufev->readcb) { bufev 148 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->readcb(bufev, bufev->cbarg); bufev 150 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->writecb_pending && bufev->writecb) { bufev 152 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->writecb(bufev, bufev->cbarg); bufev 154 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->eventcb_pending && bufev->errorcb) { bufev 160 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->errorcb(bufev, what, bufev->cbarg); bufev 162 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_decref_and_unlock(bufev); bufev 169 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bufev 171 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 173 opal/mca/event/libevent2022/libevent/bufferevent.c do { BEV_UNLOCK(bufev); stmt; BEV_LOCK(bufev); } while(0) bufev 176 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->errorcb) { bufev 179 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_event_cb errorcb = bufev->errorcb; bufev 180 opal/mca/event/libevent2022/libevent/bufferevent.c void *cbarg = bufev->cbarg; bufev 182 opal/mca/event/libevent2022/libevent/bufferevent.c UNLOCKED(errorcb(bufev, BEV_EVENT_CONNECTED, cbarg)); bufev 184 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->readcb_pending && bufev->readcb) { bufev 185 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_data_cb readcb = bufev->readcb; bufev 186 opal/mca/event/libevent2022/libevent/bufferevent.c void *cbarg = bufev->cbarg; bufev 188 opal/mca/event/libevent2022/libevent/bufferevent.c UNLOCKED(readcb(bufev, cbarg)); bufev 190 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->writecb_pending && bufev->writecb) { bufev 191 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_data_cb writecb = bufev->writecb; bufev 192 opal/mca/event/libevent2022/libevent/bufferevent.c void *cbarg = bufev->cbarg; bufev 194 opal/mca/event/libevent2022/libevent/bufferevent.c UNLOCKED(writecb(bufev, cbarg)); bufev 196 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->eventcb_pending && bufev->errorcb) { bufev 197 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_event_cb errorcb = bufev->errorcb; bufev 198 opal/mca/event/libevent2022/libevent/bufferevent.c void *cbarg = bufev->cbarg; bufev 204 opal/mca/event/libevent2022/libevent/bufferevent.c UNLOCKED(errorcb(bufev,what,cbarg)); bufev 206 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_decref_and_unlock(bufev); bufev 220 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_run_readcb(struct bufferevent *bufev) bufev 224 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 225 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->readcb == NULL) bufev 232 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->readcb(bufev, bufev->cbarg); bufev 237 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_run_writecb(struct bufferevent *bufev) bufev 241 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 242 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->writecb == NULL) bufev 249 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->writecb(bufev, bufev->cbarg); bufev 254 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_run_eventcb(struct bufferevent *bufev, short what) bufev 258 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 259 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->errorcb == NULL) bufev 267 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->errorcb(bufev, what, bufev->cbarg); bufev 277 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent *bufev = &bufev_private->bev; bufev 279 opal/mca/event/libevent2022/libevent/bufferevent.c if (!bufev->input) { bufev 280 opal/mca/event/libevent2022/libevent/bufferevent.c if ((bufev->input = evbuffer_new()) == NULL) bufev 284 opal/mca/event/libevent2022/libevent/bufferevent.c if (!bufev->output) { bufev 285 opal/mca/event/libevent2022/libevent/bufferevent.c if ((bufev->output = evbuffer_new()) == NULL) { bufev 286 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_free(bufev->input); bufev 292 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->ev_base = base; bufev 295 opal/mca/event/libevent2022/libevent/bufferevent.c evutil_timerclear(&bufev->timeout_read); bufev 296 opal/mca/event/libevent2022/libevent/bufferevent.c evutil_timerclear(&bufev->timeout_write); bufev 298 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->be_ops = ops; bufev 305 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->enabled = EV_WRITE; bufev 309 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufferevent_enable_locking(bufev, NULL) < 0) { bufev 311 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_free(bufev->input); bufev 312 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_free(bufev->output); bufev 313 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->input = NULL; bufev 314 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->output = NULL; bufev 337 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_set_parent(bufev->input, bufev); bufev 338 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_set_parent(bufev->output, bufev); bufev 344 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_setcb(struct bufferevent *bufev, bufev 348 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 350 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->readcb = readcb; bufev 351 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->writecb = writecb; bufev 352 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->errorcb = eventcb; bufev 354 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->cbarg = cbarg; bufev 355 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 359 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_get_input(struct bufferevent *bufev) bufev 361 opal/mca/event/libevent2022/libevent/bufferevent.c return bufev->input; bufev 365 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_get_output(struct bufferevent *bufev) bufev 367 opal/mca/event/libevent2022/libevent/bufferevent.c return bufev->output; bufev 371 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_get_base(struct bufferevent *bufev) bufev 373 opal/mca/event/libevent2022/libevent/bufferevent.c return bufev->ev_base; bufev 377 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_write(struct bufferevent *bufev, const void *data, size_t size) bufev 379 opal/mca/event/libevent2022/libevent/bufferevent.c if (evbuffer_add(bufev->output, data, size) == -1) bufev 386 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf) bufev 388 opal/mca/event/libevent2022/libevent/bufferevent.c if (evbuffer_add_buffer(bufev->output, buf) == -1) bufev 395 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_read(struct bufferevent *bufev, void *data, size_t size) bufev 397 opal/mca/event/libevent2022/libevent/bufferevent.c return (evbuffer_remove(bufev->input, data, size)); bufev 401 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf) bufev 403 opal/mca/event/libevent2022/libevent/bufferevent.c return (evbuffer_add_buffer(buf, bufev->input)); bufev 407 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_enable(struct bufferevent *bufev, short event) bufev 410 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 414 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_incref_and_lock(bufev); bufev 420 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->enabled |= event; bufev 422 opal/mca/event/libevent2022/libevent/bufferevent.c if (impl_events && bufev->be_ops->enable(bufev, impl_events) < 0) bufev 425 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_decref_and_unlock(bufev); bufev 430 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_set_timeouts(struct bufferevent *bufev, bufev 435 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 437 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->timeout_read = *tv_read; bufev 439 opal/mca/event/libevent2022/libevent/bufferevent.c evutil_timerclear(&bufev->timeout_read); bufev 442 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->timeout_write = *tv_write; bufev 444 opal/mca/event/libevent2022/libevent/bufferevent.c evutil_timerclear(&bufev->timeout_write); bufev 447 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->be_ops->adj_timeouts) bufev 448 opal/mca/event/libevent2022/libevent/bufferevent.c r = bufev->be_ops->adj_timeouts(bufev); bufev 449 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 457 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_settimeout(struct bufferevent *bufev, bufev 475 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_set_timeouts(bufev, ptv_read, ptv_write); bufev 480 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_disable_hard(struct bufferevent *bufev, short event) bufev 484 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 486 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 487 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->enabled &= ~event; bufev 490 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->be_ops->disable(bufev, event) < 0) bufev 493 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 498 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_disable(struct bufferevent *bufev, short event) bufev 502 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 503 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->enabled &= ~event; bufev 505 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->be_ops->disable(bufev, event) < 0) bufev 508 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 517 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_setwatermark(struct bufferevent *bufev, short events, bufev 521 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 523 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 525 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->wm_write.low = lowmark; bufev 526 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->wm_write.high = highmark; bufev 530 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->wm_read.low = lowmark; bufev 531 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->wm_read.high = highmark; bufev 540 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_add_cb(bufev->input, bufev 542 opal/mca/event/libevent2022/libevent/bufferevent.c bufev); bufev 544 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_cb_set_flags(bufev->input, bufev 548 opal/mca/event/libevent2022/libevent/bufferevent.c if (evbuffer_get_length(bufev->input) >= highmark) bufev 549 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_wm_suspend_read(bufev); bufev 550 opal/mca/event/libevent2022/libevent/bufferevent.c else if (evbuffer_get_length(bufev->input) < highmark) bufev 551 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_wm_unsuspend_read(bufev); bufev 555 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_cb_clear_flags(bufev->input, bufev 558 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_wm_unsuspend_read(bufev); bufev 561 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 565 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_flush(struct bufferevent *bufev, bufev 570 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 571 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->be_ops->flush) bufev 572 opal/mca/event/libevent2022/libevent/bufferevent.c r = bufev->be_ops->flush(bufev, iotype, mode); bufev 573 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 578 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_incref_and_lock(struct bufferevent *bufev) bufev 581 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UPCAST(bufev); bufev 582 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 605 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_decref_and_unlock(struct bufferevent *bufev) bufev 608 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 614 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 618 opal/mca/event/libevent2022/libevent/bufferevent.c underlying = bufferevent_get_underlying(bufev); bufev 621 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev->be_ops->destruct) bufev 622 opal/mca/event/libevent2022/libevent/bufferevent.c bufev->be_ops->destruct(bufev); bufev 628 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_free(bufev->input); bufev 629 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_free(bufev->output); bufev 633 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_remove_from_rate_limit_group_internal(bufev,0); bufev 641 opal/mca/event/libevent2022/libevent/bufferevent.c event_debug_unassign(&bufev->ev_read); bufev 642 opal/mca/event/libevent2022/libevent/bufferevent.c event_debug_unassign(&bufev->ev_write); bufev 644 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 650 opal/mca/event/libevent2022/libevent/bufferevent.c mm_free(((char*)bufev) - bufev->be_ops->mem_offset); bufev 669 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_decref(struct bufferevent *bufev) bufev 671 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 672 opal/mca/event/libevent2022/libevent/bufferevent.c return _bufferevent_decref_and_unlock(bufev); bufev 676 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_free(struct bufferevent *bufev) bufev 678 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 679 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_setcb(bufev, NULL, NULL, NULL, NULL); bufev 680 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_cancel_all(bufev); bufev 681 opal/mca/event/libevent2022/libevent/bufferevent.c _bufferevent_decref_and_unlock(bufev); bufev 685 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_incref(struct bufferevent *bufev) bufev 688 opal/mca/event/libevent2022/libevent/bufferevent.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 690 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 692 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 696 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_enable_locking(struct bufferevent *bufev, void *lock) bufev 703 opal/mca/event/libevent2022/libevent/bufferevent.c if (BEV_UPCAST(bufev)->lock) bufev 705 opal/mca/event/libevent2022/libevent/bufferevent.c underlying = bufferevent_get_underlying(bufev); bufev 709 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UPCAST(bufev)->lock = lock; bufev 710 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UPCAST(bufev)->own_lock = 0; bufev 715 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UPCAST(bufev)->lock = lock; bufev 716 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UPCAST(bufev)->own_lock = 1; bufev 718 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UPCAST(bufev)->lock = lock; bufev 719 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UPCAST(bufev)->own_lock = 0; bufev 721 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_enable_locking(bufev->input, lock); bufev 722 opal/mca/event/libevent2022/libevent/bufferevent.c evbuffer_enable_locking(bufev->output, lock); bufev 769 opal/mca/event/libevent2022/libevent/bufferevent.c bufferevent_get_enabled(struct bufferevent *bufev) bufev 772 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_LOCK(bufev); bufev 773 opal/mca/event/libevent2022/libevent/bufferevent.c r = bufev->enabled; bufev 774 opal/mca/event/libevent2022/libevent/bufferevent.c BEV_UNLOCK(bufev); bufev 67 opal/mca/event/libevent2022/libevent/bufferevent_filter.c static int be_filter_flush(struct bufferevent *bufev, bufev 141 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bufev = downcast(bevf); bufev 143 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bufev->wm_read.high && bufev 144 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_get_length(bufev->input) >= bufev->wm_read.high; bufev 322 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bufev = downcast(bevf); bufev 331 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (!(bufev->enabled & EV_WRITE) || bufev 333 opal/mca/event/libevent2022/libevent/bufferevent_filter.c !evbuffer_get_length(bufev->output)) bufev 339 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_cb_set_flags(bufev->output, bevf->outbuf_cb, 0); bufev 363 opal/mca/event/libevent2022/libevent/bufferevent_filter.c (bufev->enabled & EV_WRITE) && bufev 366 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_get_length(bufev->output) && bufev 371 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_get_length(bufev->output) <= bufev->wm_write.low) { bufev 373 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_run_writecb(bufev); bufev 376 opal/mca/event/libevent2022/libevent/bufferevent_filter.c (bufev->enabled & EV_WRITE) && bufev 377 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_get_length(bufev->output) && bufev 385 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_cb_set_flags(bufev->output,bevf->outbuf_cb, bufev 389 opal/mca/event/libevent2022/libevent/bufferevent_filter.c BEV_RESET_GENERIC_WRITE_TIMEOUT(bufev); bufev 419 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bufev = downcast(bevf); bufev 422 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_incref_and_lock(bufev); bufev 437 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_get_length(bufev->input) >= bufev->wm_read.low) bufev 438 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_run_readcb(bufev); bufev 440 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_decref_and_unlock(bufev); bufev 471 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_flush(struct bufferevent *bufev, bufev 474 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = upcast(bufev); bufev 478 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_incref_and_lock(bufev); bufev 490 opal/mca/event/libevent2022/libevent/bufferevent_filter.c _bufferevent_decref_and_unlock(bufev); bufev 159 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bufev = b->ptr; bufev 168 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c output = bufferevent_get_output(bufev); bufev 173 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { bufev 174 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (bufev->wm_write.high <= outlen) { bufev 179 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c inlen = bufev->wm_write.high - outlen; bufev 191 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent *bufev = b->ptr; bufev 202 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; bufev 205 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; bufev 330 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c static int be_openssl_flush(struct bufferevent *bufev, bufev 1234 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c be_openssl_flush(struct bufferevent *bufev, bufev 1280 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c bufferevent_openssl_get_ssl(struct bufferevent *bufev) bufev 1282 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c struct bufferevent_openssl *bev_ssl = upcast(bufev); bufev 94 opal/mca/event/libevent2022/libevent/bufferevent_pair.c struct bufferevent_pair *bufev; bufev 95 opal/mca/event/libevent2022/libevent/bufferevent_pair.c if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair)))) bufev 97 opal/mca/event/libevent2022/libevent/bufferevent_pair.c if (bufferevent_init_common(&bufev->bev, base, &bufferevent_ops_pair, bufev 99 opal/mca/event/libevent2022/libevent/bufferevent_pair.c mm_free(bufev); bufev 102 opal/mca/event/libevent2022/libevent/bufferevent_pair.c if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { bufev 103 opal/mca/event/libevent2022/libevent/bufferevent_pair.c bufferevent_free(downcast(bufev)); bufev 107 opal/mca/event/libevent2022/libevent/bufferevent_pair.c _bufferevent_init_generic_timeout_cbs(&bufev->bev.bev); bufev 109 opal/mca/event/libevent2022/libevent/bufferevent_pair.c return bufev; bufev 230 opal/mca/event/libevent2022/libevent/bufferevent_pair.c be_pair_enable(struct bufferevent *bufev, short events) bufev 232 opal/mca/event/libevent2022/libevent/bufferevent_pair.c struct bufferevent_pair *bev_p = upcast(bufev); bufev 235 opal/mca/event/libevent2022/libevent/bufferevent_pair.c incref_and_lock(bufev); bufev 238 opal/mca/event/libevent2022/libevent/bufferevent_pair.c BEV_RESET_GENERIC_READ_TIMEOUT(bufev); bufev 240 opal/mca/event/libevent2022/libevent/bufferevent_pair.c if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) bufev 241 opal/mca/event/libevent2022/libevent/bufferevent_pair.c BEV_RESET_GENERIC_WRITE_TIMEOUT(bufev); bufev 246 opal/mca/event/libevent2022/libevent/bufferevent_pair.c be_pair_transfer(downcast(partner), bufev, 0); bufev 251 opal/mca/event/libevent2022/libevent/bufferevent_pair.c be_pair_transfer(bufev, downcast(partner), 0); bufev 253 opal/mca/event/libevent2022/libevent/bufferevent_pair.c decref_and_unlock(bufev); bufev 106 opal/mca/event/libevent2022/libevent/bufferevent_sock.c struct bufferevent *bufev = arg; bufev 108 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 111 opal/mca/event/libevent2022/libevent/bufferevent_sock.c (bufev->enabled & EV_WRITE) && bufev 112 opal/mca/event/libevent2022/libevent/bufferevent_sock.c !event_pending(&bufev->ev_write, EV_WRITE, NULL) && bufev 116 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) == -1) { bufev 125 opal/mca/event/libevent2022/libevent/bufferevent_sock.c struct bufferevent *bufev = arg; bufev 127 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 133 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_incref_and_lock(bufev); bufev 143 opal/mca/event/libevent2022/libevent/bufferevent_sock.c input = bufev->input; bufev 149 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (bufev->wm_read.high != 0) { bufev 150 opal/mca/event/libevent2022/libevent/bufferevent_sock.c howmuch = bufev->wm_read.high - evbuffer_get_length(input); bufev 153 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_wm_suspend_read(bufev); bufev 185 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (evbuffer_get_length(input) >= bufev->wm_read.low) bufev 186 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_readcb(bufev); bufev 194 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_disable(bufev, EV_READ); bufev 195 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_eventcb(bufev, what); bufev 198 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_decref_and_unlock(bufev); bufev 204 opal/mca/event/libevent2022/libevent/bufferevent_sock.c struct bufferevent *bufev = arg; bufev 206 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 212 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_incref_and_lock(bufev); bufev 235 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_write); bufev 236 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_read); bufev 237 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_eventcb(bufev, BEV_EVENT_ERROR); bufev 242 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (BEV_IS_ASYNC(bufev)) { bufev 243 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_write); bufev 244 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_async_set_connected(bufev); bufev 245 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_eventcb(bufev, bufev 250 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_eventcb(bufev, bufev 252 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (!(bufev->enabled & EV_WRITE) || bufev 254 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_write); bufev 265 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (evbuffer_get_length(bufev->output)) { bufev 266 opal/mca/event/libevent2022/libevent/bufferevent_sock.c evbuffer_unfreeze(bufev->output, 1); bufev 267 opal/mca/event/libevent2022/libevent/bufferevent_sock.c res = evbuffer_write_atmost(bufev->output, fd, atmost); bufev 268 opal/mca/event/libevent2022/libevent/bufferevent_sock.c evbuffer_freeze(bufev->output, 1); bufev 287 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (evbuffer_get_length(bufev->output) == 0) { bufev 288 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_write); bufev 296 opal/mca/event/libevent2022/libevent/bufferevent_sock.c evbuffer_get_length(bufev->output) <= bufev->wm_write.low) { bufev 297 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_writecb(bufev); bufev 303 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (evbuffer_get_length(bufev->output) == 0) { bufev 304 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_write); bufev 309 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_disable(bufev, EV_WRITE); bufev 310 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_run_eventcb(bufev, what); bufev 313 opal/mca/event/libevent2022/libevent/bufferevent_sock.c _bufferevent_decref_and_unlock(bufev); bufev 321 opal/mca/event/libevent2022/libevent/bufferevent_sock.c struct bufferevent *bufev; bufev 336 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufev = &bufev_p->bev; bufev 337 opal/mca/event/libevent2022/libevent/bufferevent_sock.c evbuffer_set_flags(bufev->output, EVBUFFER_FLAG_DRAINS_TO_FD); bufev 339 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_assign(&bufev->ev_read, bufev->ev_base, fd, bufev 340 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EV_READ|EV_PERSIST, bufferevent_readcb, bufev); bufev 341 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_assign(&bufev->ev_write, bufev->ev_base, fd, bufev 342 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EV_WRITE|EV_PERSIST, bufferevent_writecb, bufev); bufev 344 opal/mca/event/libevent2022/libevent/bufferevent_sock.c evbuffer_add_cb(bufev->output, bufferevent_socket_outbuf_cb, bufev); bufev 346 opal/mca/event/libevent2022/libevent/bufferevent_sock.c evbuffer_freeze(bufev->input, 0); bufev 347 opal/mca/event/libevent2022/libevent/bufferevent_sock.c evbuffer_freeze(bufev->output, 1); bufev 349 opal/mca/event/libevent2022/libevent/bufferevent_sock.c return bufev; bufev 539 opal/mca/event/libevent2022/libevent/bufferevent_sock.c struct bufferevent *bufev; bufev 541 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (!(bufev = bufferevent_socket_new(NULL, fd, 0))) bufev 544 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_setcb(bufev, readcb, writecb, eventcb, cbarg); bufev 546 opal/mca/event/libevent2022/libevent/bufferevent_sock.c return bufev; bufev 551 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_enable(struct bufferevent *bufev, short event) bufev 554 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (be_socket_add(&bufev->ev_read,&bufev->timeout_read) == -1) bufev 558 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (be_socket_add(&bufev->ev_write,&bufev->timeout_write) == -1) bufev 565 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_disable(struct bufferevent *bufev, short event) bufev 568 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 570 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event_del(&bufev->ev_read) == -1) bufev 575 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event_del(&bufev->ev_write) == -1) bufev 582 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_destruct(struct bufferevent *bufev) bufev 585 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); bufev 587 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_ASSERT(bufev->be_ops == &bufferevent_ops_socket); bufev 589 opal/mca/event/libevent2022/libevent/bufferevent_sock.c fd = event_get_fd(&bufev->ev_read); bufev 591 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_read); bufev 592 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_write); bufev 599 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_adj_timeouts(struct bufferevent *bufev) bufev 602 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event_pending(&bufev->ev_read, EV_READ, NULL)) bufev 603 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (be_socket_add(&bufev->ev_read, &bufev->timeout_read) < 0) bufev 605 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event_pending(&bufev->ev_write, EV_WRITE, NULL)) { bufev 606 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) < 0) bufev 621 opal/mca/event/libevent2022/libevent/bufferevent_sock.c be_socket_setfd(struct bufferevent *bufev, evutil_socket_t fd) bufev 623 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_LOCK(bufev); bufev 624 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EVUTIL_ASSERT(bufev->be_ops == &bufferevent_ops_socket); bufev 626 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_read); bufev 627 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_del(&bufev->ev_write); bufev 629 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_assign(&bufev->ev_read, bufev->ev_base, fd, bufev 630 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EV_READ|EV_PERSIST, bufferevent_readcb, bufev); bufev 631 opal/mca/event/libevent2022/libevent/bufferevent_sock.c event_assign(&bufev->ev_write, bufev->ev_base, fd, bufev 632 opal/mca/event/libevent2022/libevent/bufferevent_sock.c EV_WRITE|EV_PERSIST, bufferevent_writecb, bufev); bufev 635 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_enable(bufev, bufev->enabled); bufev 637 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_UNLOCK(bufev); bufev 642 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_priority_set(struct bufferevent *bufev, int priority) bufev 646 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_LOCK(bufev); bufev 647 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (bufev->be_ops != &bufferevent_ops_socket) bufev 650 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event_priority_set(&bufev->ev_read, priority) == -1) bufev 652 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (event_priority_set(&bufev->ev_write, priority) == -1) bufev 657 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_UNLOCK(bufev); bufev 663 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufferevent_base_set(struct event_base *base, struct bufferevent *bufev) bufev 667 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_LOCK(bufev); bufev 668 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (bufev->be_ops != &bufferevent_ops_socket) bufev 671 opal/mca/event/libevent2022/libevent/bufferevent_sock.c bufev->ev_base = base; bufev 673 opal/mca/event/libevent2022/libevent/bufferevent_sock.c res = event_base_set(base, &bufev->ev_read); bufev 677 opal/mca/event/libevent2022/libevent/bufferevent_sock.c res = event_base_set(base, &bufev->ev_write); bufev 679 opal/mca/event/libevent2022/libevent/bufferevent_sock.c BEV_UNLOCK(bufev); bufev 68 opal/mca/event/libevent2022/libevent/http-internal.h struct bufferevent *bufev; bufev 195 opal/mca/event/libevent2022/libevent/http.c static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg); bufev 389 opal/mca/event/libevent2022/libevent/http.c bufferevent_setcb(evcon->bufev, bufev 395 opal/mca/event/libevent2022/libevent/http.c bufferevent_enable(evcon->bufev, EV_WRITE); bufev 401 opal/mca/event/libevent2022/libevent/http.c bufferevent_disable(evcon->bufev, EV_WRITE); bufev 408 opal/mca/event/libevent2022/libevent/http.c bufferevent_enable(evcon->bufev, EV_WRITE); bufev 409 opal/mca/event/libevent2022/libevent/http.c evbuffer_add_printf(bufferevent_get_output(evcon->bufev), bufev 414 opal/mca/event/libevent2022/libevent/http.c bufferevent_setcb(evcon->bufev, bufev 454 opal/mca/event/libevent2022/libevent/http.c evbuffer_add_printf(bufferevent_get_output(evcon->bufev), bufev 541 opal/mca/event/libevent2022/libevent/http.c evbuffer_add_printf(bufferevent_get_output(evcon->bufev), bufev 596 opal/mca/event/libevent2022/libevent/http.c struct evbuffer *output = bufferevent_get_output(evcon->bufev); bufev 706 opal/mca/event/libevent2022/libevent/http.c bufferevent_disable(evcon->bufev, EV_READ|EV_WRITE); bufev 754 opal/mca/event/libevent2022/libevent/http.c evhttp_write_cb(struct bufferevent *bufev, void *arg) bufev 935 opal/mca/event/libevent2022/libevent/http.c struct evbuffer *buf = bufferevent_get_input(evcon->bufev); bufev 943 opal/mca/event/libevent2022/libevent/http.c bufferevent_disable(evcon->bufev, EV_READ); bufev 949 opal/mca/event/libevent2022/libevent/http.c bufferevent_enable(evcon->bufev, EV_READ); bufev 957 opal/mca/event/libevent2022/libevent/http.c struct evbuffer *buf = bufferevent_get_input(evcon->bufev); bufev 1026 opal/mca/event/libevent2022/libevent/http.c bufferevent_disable(evcon->bufev, EV_READ); bufev 1033 opal/mca/event/libevent2022/libevent/http.c bufferevent_enable(evcon->bufev, EV_READ); bufev 1044 opal/mca/event/libevent2022/libevent/http.c evhttp_read_cb(struct bufferevent *bufev, void *arg) bufev 1078 opal/mca/event/libevent2022/libevent/http.c input = bufferevent_get_input(evcon->bufev); bufev 1102 opal/mca/event/libevent2022/libevent/http.c evhttp_read_cb(evcon->bufev, evcon); bufev 1155 opal/mca/event/libevent2022/libevent/http.c if (evcon->bufev != NULL) bufev 1156 opal/mca/event/libevent2022/libevent/http.c bufferevent_free(evcon->bufev); bufev 1235 opal/mca/event/libevent2022/libevent/http.c bufferevent_disable_hard(evcon->bufev, EV_READ|EV_WRITE); bufev 1248 opal/mca/event/libevent2022/libevent/http.c tmp = bufferevent_get_output(evcon->bufev); bufev 1250 opal/mca/event/libevent2022/libevent/http.c tmp = bufferevent_get_input(evcon->bufev); bufev 1261 opal/mca/event/libevent2022/libevent/http.c bufferevent_enable(evcon->bufev, EV_READ); bufev 1269 opal/mca/event/libevent2022/libevent/http.c bufferevent_disable(evcon->bufev, EV_READ); bufev 1323 opal/mca/event/libevent2022/libevent/http.c evhttp_error_cb(struct bufferevent *bufev, short what, void *arg) bufev 1387 opal/mca/event/libevent2022/libevent/http.c evhttp_connection_cb(struct bufferevent *bufev, short what, void *arg) bufev 1402 opal/mca/event/libevent2022/libevent/http.c evhttp_error_cb(bufev, what, arg); bufev 1434 opal/mca/event/libevent2022/libevent/http.c bufferevent_setcb(evcon->bufev, bufev 1441 opal/mca/event/libevent2022/libevent/http.c bufferevent_settimeout(evcon->bufev, bufev 1447 opal/mca/event/libevent2022/libevent/http.c bufferevent_set_timeouts(evcon->bufev, &tv, &tv); bufev 1882 opal/mca/event/libevent2022/libevent/http.c EV_SIZE_ARG(evbuffer_get_length(bufferevent_get_input(req->evcon->bufev))))); bufev 1959 opal/mca/event/libevent2022/libevent/http.c if (!evbuffer_get_length(bufferevent_get_input(evcon->bufev))) bufev 1979 opal/mca/event/libevent2022/libevent/http.c res = evhttp_parse_firstline(req, bufferevent_get_input(evcon->bufev)); bufev 2002 opal/mca/event/libevent2022/libevent/http.c res = evhttp_parse_headers(req, bufferevent_get_input(evcon->bufev)); bufev 2015 opal/mca/event/libevent2022/libevent/http.c bufferevent_disable(evcon->bufev, EV_READ); bufev 2098 opal/mca/event/libevent2022/libevent/http.c if ((evcon->bufev = bufferevent_new(-1, bufev 2111 opal/mca/event/libevent2022/libevent/http.c bufferevent_base_set(base, evcon->bufev); bufev 2131 opal/mca/event/libevent2022/libevent/http.c return evcon->bufev; bufev 2141 opal/mca/event/libevent2022/libevent/http.c bufferevent_base_set(base, evcon->bufev); bufev 2151 opal/mca/event/libevent2022/libevent/http.c bufferevent_settimeout(evcon->bufev, bufev 2154 opal/mca/event/libevent2022/libevent/http.c bufferevent_settimeout(evcon->bufev, bufev 2203 opal/mca/event/libevent2022/libevent/http.c bufferevent_setfd(evcon->bufev, evcon->fd); bufev 2204 opal/mca/event/libevent2022/libevent/http.c bufferevent_setcb(evcon->bufev, bufev 2209 opal/mca/event/libevent2022/libevent/http.c bufferevent_settimeout(evcon->bufev, 0, bufev 2212 opal/mca/event/libevent2022/libevent/http.c bufferevent_enable(evcon->bufev, EV_WRITE); bufev 2216 opal/mca/event/libevent2022/libevent/http.c if (bufferevent_socket_connect_hostname(evcon->bufev, evcon->dns_base, bufev 2325 opal/mca/event/libevent2022/libevent/http.c bufferevent_disable(evcon->bufev, EV_WRITE); bufev 2326 opal/mca/event/libevent2022/libevent/http.c bufferevent_enable(evcon->bufev, EV_READ); bufev 2329 opal/mca/event/libevent2022/libevent/http.c bufferevent_setcb(evcon->bufev, bufev 2337 opal/mca/event/libevent2022/libevent/http.c if (evbuffer_get_length(bufferevent_get_input(evcon->bufev))) { bufev 2472 opal/mca/event/libevent2022/libevent/http.c output = bufferevent_get_output(evcon->bufev); bufev 2500 opal/mca/event/libevent2022/libevent/http.c output = bufferevent_get_output(evcon->bufev); bufev 3708 opal/mca/event/libevent2022/libevent/http.c bufferevent_setfd(evcon->bufev, fd); bufev 258 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev); bufev 274 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_priority_set(struct bufferevent *bufev, int pri); bufev 282 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h void bufferevent_free(struct bufferevent *bufev); bufev 299 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h void bufferevent_setcb(struct bufferevent *bufev, bufev 310 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_setfd(struct bufferevent *bufev, evutil_socket_t fd); bufev 316 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h evutil_socket_t bufferevent_getfd(struct bufferevent *bufev); bufev 322 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h struct bufferevent *bufferevent_get_underlying(struct bufferevent *bufev); bufev 337 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_write(struct bufferevent *bufev, bufev 350 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf); bufev 363 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h size_t bufferevent_read(struct bufferevent *bufev, void *data, size_t size); bufev 373 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf); bufev 384 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h struct evbuffer *bufferevent_get_input(struct bufferevent *bufev); bufev 398 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h struct evbuffer *bufferevent_get_output(struct bufferevent *bufev); bufev 408 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_enable(struct bufferevent *bufev, short event); bufev 418 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_disable(struct bufferevent *bufev, short event); bufev 426 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h short bufferevent_get_enabled(struct bufferevent *bufev); bufev 454 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_set_timeouts(struct bufferevent *bufev, bufev 475 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h void bufferevent_setwatermark(struct bufferevent *bufev, short events, bufev 482 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h void bufferevent_lock(struct bufferevent *bufev); bufev 488 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h void bufferevent_unlock(struct bufferevent *bufev); bufev 513 opal/mca/event/libevent2022/libevent/include/event2/bufferevent.h int bufferevent_flush(struct bufferevent *bufev, bufev 86 opal/mca/event/libevent2022/libevent/include/event2/bufferevent_compat.h void bufferevent_settimeout(struct bufferevent *bufev, bufev 93 opal/mca/event/libevent2022/libevent/include/event2/bufferevent_ssl.h bufferevent_openssl_get_ssl(struct bufferevent *bufev);