bevf 126 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_underlying_writebuf_full(struct bufferevent_filtered *bevf, bevf 129 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *u = bevf->underlying; bevf 138 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_readbuf_full(struct bufferevent_filtered *bevf, bevf 141 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bufev = downcast(bevf); bevf 217 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = upcast(bev); bevf 218 opal/mca/event/libevent2022/libevent/bufferevent_filter.c EVUTIL_ASSERT(bevf); bevf 219 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (bevf->free_context) bevf 220 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bevf->free_context(bevf->context); bevf 222 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (bevf->bev.options & BEV_OPT_CLOSE_ON_FREE) { bevf 228 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (BEV_UPCAST(bevf->underlying)->refcnt < 2) { bevf 232 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bufferevent_free(bevf->underlying); bevf 235 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (bevf->underlying) { bevf 236 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (bevf->underlying->errorcb == be_filter_eventcb) bevf 237 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bufferevent_setcb(bevf->underlying, bevf 239 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bufferevent_unsuspend_read(bevf->underlying, bevf 250 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = upcast(bev); bevf 256 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bufferevent_unsuspend_read(bevf->underlying, bevf 265 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = upcast(bev); bevf 270 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bufferevent_suspend_read(bevf->underlying, bevf 277 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_process_input(struct bufferevent_filtered *bevf, bevf 282 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bev = downcast(bevf); bevf 288 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_readbuf_full(bevf, state)) bevf 298 opal/mca/event/libevent2022/libevent/bufferevent_filter.c res = bevf->process_in(bevf->underlying->input, bevf 299 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bev->input, limit, state, bevf->context); bevf 305 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_get_length(bevf->underlying->input) && bevf 306 opal/mca/event/libevent2022/libevent/bufferevent_filter.c !be_readbuf_full(bevf, state)); bevf 316 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_process_output(struct bufferevent_filtered *bevf, bevf 322 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bufev = downcast(bevf); bevf 332 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_underlying_writebuf_full(bevf, state) || bevf 339 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_cb_set_flags(bufev->output, bevf->outbuf_cb, 0); bevf 348 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bevf->underlying->wm_write.high) bevf 349 opal/mca/event/libevent2022/libevent/bufferevent_filter.c limit = bevf->underlying->wm_write.high - bevf 350 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_get_length(bevf->underlying->output); bevf 352 opal/mca/event/libevent2022/libevent/bufferevent_filter.c res = bevf->process_out(downcast(bevf)->output, bevf 353 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bevf->underlying->output, bevf 356 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bevf->context); bevf 368 opal/mca/event/libevent2022/libevent/bufferevent_filter.c !be_underlying_writebuf_full(bevf,state)); bevf 378 opal/mca/event/libevent2022/libevent/bufferevent_filter.c !be_underlying_writebuf_full(bevf, state)) { bevf 385 opal/mca/event/libevent2022/libevent/bufferevent_filter.c evbuffer_cb_set_flags(bufev->output,bevf->outbuf_cb, bevf 399 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = arg; bevf 400 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bev = downcast(bevf); bevf 407 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_process_output(bevf, BEV_NORMAL, &processed_any); bevf 416 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = _me; bevf 419 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bufev = downcast(bevf); bevf 424 opal/mca/event/libevent2022/libevent/bufferevent_filter.c if (bevf->got_eof) bevf 430 opal/mca/event/libevent2022/libevent/bufferevent_filter.c res = be_filter_process_input(bevf, state, &processed_any); bevf 448 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = _me; bevf 449 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bev = downcast(bevf); bevf 453 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_process_output(bevf, BEV_NORMAL, &processed_any); bevf 461 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = _me; bevf 462 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent *bev = downcast(bevf); bevf 474 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf = upcast(bufev); bevf 476 opal/mca/event/libevent2022/libevent/bufferevent_filter.c EVUTIL_ASSERT(bevf); bevf 481 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_process_input(bevf, mode, &processed_any); bevf 484 opal/mca/event/libevent2022/libevent/bufferevent_filter.c be_filter_process_output(bevf, mode, &processed_any); bevf 488 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bufferevent_flush(bevf->underlying, iotype, mode); bevf 499 opal/mca/event/libevent2022/libevent/bufferevent_filter.c struct bufferevent_filtered *bevf; bevf 502 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bevf = upcast(bev); bevf 503 opal/mca/event/libevent2022/libevent/bufferevent_filter.c data->ptr = bevf->underlying;