Lines Matching defs:bufev_private
70 struct bufferevent_private *bufev_private =
73 if (!bufev_private->read_suspended)
75 bufev_private->read_suspended |= what;
82 struct bufferevent_private *bufev_private =
85 bufev_private->read_suspended &= ~what;
86 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ))
94 struct bufferevent_private *bufev_private =
97 if (!bufev_private->write_suspended)
99 bufev_private->write_suspended |= what;
106 struct bufferevent_private *bufev_private =
109 bufev_private->write_suspended &= ~what;
110 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE))
137 struct bufferevent_private *bufev_private = arg;
138 struct bufferevent *bufev = &bufev_private->bev;
141 if ((bufev_private->eventcb_pending & BEV_EVENT_CONNECTED) &&
145 bufev_private->eventcb_pending &= ~BEV_EVENT_CONNECTED;
148 if (bufev_private->readcb_pending && bufev->readcb) {
149 bufev_private->readcb_pending = 0;
152 if (bufev_private->writecb_pending && bufev->writecb) {
153 bufev_private->writecb_pending = 0;
156 if (bufev_private->eventcb_pending && bufev->errorcb) {
157 short what = bufev_private->eventcb_pending;
158 int err = bufev_private->errno_pending;
159 bufev_private->eventcb_pending = 0;
160 bufev_private->errno_pending = 0;
170 struct bufferevent_private *bufev_private = arg;
171 struct bufferevent *bufev = &bufev_private->bev;
177 if ((bufev_private->eventcb_pending & BEV_EVENT_CONNECTED) &&
183 bufev_private->eventcb_pending &= ~BEV_EVENT_CONNECTED;
186 if (bufev_private->readcb_pending && bufev->readcb) {
189 bufev_private->readcb_pending = 0;
192 if (bufev_private->writecb_pending && bufev->writecb) {
195 bufev_private->writecb_pending = 0;
198 if (bufev_private->eventcb_pending && bufev->errorcb) {
201 short what = bufev_private->eventcb_pending;
202 int err = bufev_private->errno_pending;
203 bufev_private->eventcb_pending = 0;
204 bufev_private->errno_pending = 0;
292 bufferevent_init_common_(struct bufferevent_private *bufev_private,
297 struct bufferevent *bufev = &bufev_private->bev;
311 bufev_private->refcnt = 1;
320 bufferevent_ratelim_init_(bufev_private);
348 &bufev_private->deferred,
351 bufev_private);
354 &bufev_private->deferred,
357 bufev_private);
359 bufev_private->options = options;
463 struct bufferevent_private *bufev_private =
469 if (bufev_private->read_suspended)
471 if (bufev_private->write_suspended)
537 struct bufferevent_private *bufev_private =
543 bufev_private->connecting = 0;
574 struct bufferevent_private *bufev_private =
592 if (bufev_private->read_watermarks_cb == NULL) {
593 bufev_private->read_watermarks_cb =
599 bufev_private->read_watermarks_cb,
608 if (bufev_private->read_watermarks_cb)
610 bufev_private->read_watermarks_cb,
660 struct bufferevent_private *bufev_private =
663 ++bufev_private->refcnt;
687 struct bufferevent_private *bufev_private =
693 EVUTIL_ASSERT(bufev_private->refcnt > 0);
695 if (--bufev_private->refcnt) {
707 cbs[2] = &bufev_private->deferred;
709 if (bufev_private->rate_limiting) {
710 struct event *e = &bufev_private->rate_limiting->refill_bucket_event;
731 struct bufferevent_private *bufev_private =
748 if (bufev_private->rate_limiting) {
749 if (bufev_private->rate_limiting->group)
751 mm_free(bufev_private->rate_limiting);
752 bufev_private->rate_limiting = NULL;
758 if (bufev_private->own_lock)
759 EVTHREAD_FREE_LOCK(bufev_private->lock,
798 struct bufferevent_private *bufev_private =
802 ++bufev_private->refcnt;