Lines Matching defs:bev
89 evutil_offsetof(struct bufferevent_private, bev),
108 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
127 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
203 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
330 bufev = &bufev_p->bev;
347 bufferevent_socket_connect(struct bufferevent *bev,
351 EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
358 _bufferevent_incref_and_lock(bev);
363 fd = bufferevent_getfd(bev);
376 if (bufferevent_async_can_connect(bev)) {
377 bufferevent_setfd(bev, fd);
378 r = bufferevent_async_connect(bev, fd, sa, socklen);
394 if (BEV_IS_ASYNC(bev)) {
395 event_assign(&bev->ev_write, bev->ev_base, fd,
396 EV_WRITE|EV_PERSIST, bufferevent_writecb, bev);
399 bufferevent_setfd(bev, fd);
401 if (! be_socket_enable(bev, EV_WRITE)) {
410 event_active(&bev->ev_write, EV_WRITE, 1);
416 event_active(&bev->ev_write, EV_WRITE, 1);
422 _bufferevent_run_eventcb(bev, BEV_EVENT_ERROR);
427 _bufferevent_decref_and_unlock(bev);
435 struct bufferevent *bev = arg;
437 EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
439 BEV_LOCK(bev);
441 bufferevent_unsuspend_write(bev, BEV_SUSPEND_LOOKUP);
442 bufferevent_unsuspend_read(bev, BEV_SUSPEND_LOOKUP);
446 _bufferevent_run_eventcb(bev, BEV_EVENT_ERROR);
447 _bufferevent_decref_and_unlock(bev);
455 r = bufferevent_socket_connect(bev, ai->ai_addr, (int)ai->ai_addrlen);
457 _bufferevent_decref_and_unlock(bev);
462 bufferevent_socket_connect_hostname(struct bufferevent *bev,
469 EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
476 BEV_LOCK(bev);
478 BEV_UNLOCK(bev);
487 bufferevent_suspend_write(bev, BEV_SUSPEND_LOOKUP);
488 bufferevent_suspend_read(bev, BEV_SUSPEND_LOOKUP);
490 bufferevent_incref(bev);
492 &hint, bufferevent_connect_getaddrinfo_cb, bev);
497 bufferevent_unsuspend_write(bev, BEV_SUSPEND_LOOKUP);
498 bufferevent_unsuspend_read(bev, BEV_SUSPEND_LOOKUP);
504 bufferevent_socket_get_dns_error(struct bufferevent *bev)
508 EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
510 BEV_LOCK(bev);
512 BEV_LOCK(bev);
562 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
579 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
607 be_socket_flush(struct bufferevent *bev, short iotype,
678 be_socket_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op,
683 be_socket_setfd(bev, data->fd);
686 data->fd = event_get_fd(&bev->ev_read);