Lines Matching defs:bev
79 struct bufferevent_private bev;
92 evutil_offsetof(struct bufferevent_async, bev.bev),
102 upcast(struct bufferevent *bev)
105 if (bev->be_ops != &bufferevent_ops_async)
107 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev);
116 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
125 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
134 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
141 struct bufferevent *bev = &beva->bev.bev;
145 event_base_del_virtual(bev->ev_base);
152 struct bufferevent *bev = &beva->bev.bev;
156 event_base_del_virtual(bev->ev_base);
163 struct bufferevent *bev = &beva->bev.bev;
167 event_base_add_virtual(bev->ev_base);
174 struct bufferevent *bev = &beva->bev.bev;
178 event_base_add_virtual(bev->ev_base);
187 struct bufferevent *bev = &beva->bev.bev;
191 if (beva->write_in_progress || beva->bev.connecting)
193 if (!beva->ok || !(bev->enabled&EV_WRITE) ||
194 !evbuffer_get_length(bev->output)) {
199 at_most = evbuffer_get_length(bev->output);
203 limit = (int)_bufferevent_get_write_max(&beva->bev);
207 if (beva->bev.write_suspended) {
213 bufferevent_incref(bev);
214 if (evbuffer_launch_write(bev->output, at_most,
216 bufferevent_decref(bev);
218 _bufferevent_run_eventcb(bev, BEV_EVENT_ERROR);
221 _bufferevent_decrement_write_buckets(&beva->bev, at_most);
233 struct bufferevent *bev = &beva->bev.bev;
237 if (beva->read_in_progress || beva->bev.connecting)
239 if (!beva->ok || !(bev->enabled&EV_READ)) {
245 cur_size = evbuffer_get_length(bev->input);
246 read_high = bev->wm_read.high;
259 limit = (int)_bufferevent_get_read_max(&beva->bev);
263 if (beva->bev.read_suspended) {
268 bufferevent_incref(bev);
269 if (evbuffer_launch_read(bev->input, at_most, &beva->read_overlapped)) {
271 _bufferevent_run_eventcb(bev, BEV_EVENT_ERROR);
272 bufferevent_decref(bev);
275 _bufferevent_decrement_read_buckets(&beva->bev, at_most);
287 struct bufferevent *bev = arg;
288 struct bufferevent_async *bev_async = upcast(bev);
293 _bufferevent_incref_and_lock(bev);
298 _bufferevent_decref_and_unlock(bev);
306 struct bufferevent *bev = arg;
307 struct bufferevent_async *bev_async = upcast(bev);
312 _bufferevent_incref_and_lock(bev);
317 _bufferevent_decref_and_unlock(bev);
328 if (bev_async->bev.connecting) {
349 be_async_disable(struct bufferevent *bev, short what)
351 struct bufferevent_async *bev_async = upcast(bev);
357 BEV_DEL_GENERIC_READ_TIMEOUT(bev);
361 BEV_DEL_GENERIC_WRITE_TIMEOUT(bev);
369 be_async_destruct(struct bufferevent *bev)
371 struct bufferevent_async *bev_async = upcast(bev);
372 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
375 EVUTIL_ASSERT(!upcast(bev)->write_in_progress &&
376 !upcast(bev)->read_in_progress);
381 fd = _evbuffer_overlapped_get_fd(bev->input);
387 if (event_initialized(&bev->ev_write)) {
388 event_del(&bev->ev_write);
389 _bufferevent_del_generic_timeout_cbs(bev);
396 bev_async_set_wsa_error(struct bufferevent *bev, struct event_overlapped *eo)
401 fd = _evbuffer_overlapped_get_fd(bev->input);
406 be_async_flush(struct bufferevent *bev, short what,
417 struct bufferevent *bev = &bev_a->bev.bev;
420 BEV_LOCK(bev);
422 EVUTIL_ASSERT(bev_a->bev.connecting);
423 bev_a->bev.connecting = 0;
424 sock = _evbuffer_overlapped_get_fd(bev_a->bev.bev.input);
429 bufferevent_async_set_connected(bev);
431 bev_async_set_wsa_error(bev, eo);
433 _bufferevent_run_eventcb(bev,
436 event_base_del_virtual(bev->ev_base);
438 _bufferevent_decref_and_unlock(bev);
446 struct bufferevent *bev = &bev_a->bev.bev;
449 BEV_LOCK(bev);
453 evbuffer_commit_read(bev->input, nbytes);
456 _bufferevent_decrement_read_buckets(&bev_a->bev, -amount_unread);
459 bev_async_set_wsa_error(bev, eo);
463 BEV_RESET_GENERIC_READ_TIMEOUT(bev);
464 if (evbuffer_get_length(bev->input) >= bev->wm_read.low)
465 _bufferevent_run_readcb(bev);
470 _bufferevent_run_eventcb(bev, what);
474 _bufferevent_run_eventcb(bev, what);
478 _bufferevent_decref_and_unlock(bev);
486 struct bufferevent *bev = &bev_a->bev.bev;
490 BEV_LOCK(bev);
494 evbuffer_commit_write(bev->output, nbytes);
498 _bufferevent_decrement_write_buckets(&bev_a->bev,
503 bev_async_set_wsa_error(bev, eo);
507 BEV_RESET_GENERIC_WRITE_TIMEOUT(bev);
508 if (evbuffer_get_length(bev->output) <=
509 bev->wm_write.low)
510 _bufferevent_run_writecb(bev);
515 _bufferevent_run_eventcb(bev, what);
519 _bufferevent_run_eventcb(bev, what);
523 _bufferevent_decref_and_unlock(bev);
531 struct bufferevent *bev;
551 bev = &bev_a->bev.bev;
552 if (!(bev->input = evbuffer_overlapped_new(fd))) {
556 if (!(bev->output = evbuffer_overlapped_new(fd))) {
557 evbuffer_free(bev->input);
562 if (bufferevent_init_common(&bev_a->bev, base, &bufferevent_ops_async,
566 evbuffer_add_cb(bev->input, be_async_inbuf_callback, bev);
567 evbuffer_add_cb(bev->output, be_async_outbuf_callback, bev);
575 _bufferevent_init_generic_timeout_cbs(bev);
577 return bev;
579 bufferevent_free(&bev_a->bev.bev);
584 bufferevent_async_set_connected(struct bufferevent *bev)
586 struct bufferevent_async *bev_async = upcast(bev);
588 _bufferevent_init_generic_timeout_cbs(bev);
590 be_async_enable(bev, bev->enabled);
594 bufferevent_async_can_connect(struct bufferevent *bev)
599 if (BEV_IS_ASYNC(bev) &&
600 event_base_get_iocp(bev->ev_base) &&
608 bufferevent_async_connect(struct bufferevent *bev, evutil_socket_t fd,
612 struct bufferevent_async *bev_async = upcast(bev);
640 event_base_add_virtual(bev->ev_base);
641 bufferevent_incref(bev);
647 event_base_del_virtual(bev->ev_base);
648 bufferevent_decref(bev);
654 be_async_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op,
659 data->fd = _evbuffer_overlapped_get_fd(bev->input);
664 if (data->fd == _evbuffer_overlapped_get_fd(bev->input))
666 if (!(iocp = event_base_get_iocp(bev->ev_base)))
670 _evbuffer_overlapped_set_fd(bev->input, data->fd);
671 _evbuffer_overlapped_set_fd(bev->output, data->fd);
675 struct bufferevent_async *bev_a = upcast(bev);
676 evutil_socket_t fd = _evbuffer_overlapped_get_fd(bev->input);
678 (bev_a->bev.options & BEV_OPT_CLOSE_ON_FREE)) {