Lines Matching defs:bufev_private
69 struct bufferevent_private *bufev_private =
72 if (!bufev_private->read_suspended)
74 bufev_private->read_suspended |= what;
81 struct bufferevent_private *bufev_private =
84 bufev_private->read_suspended &= ~what;
85 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ))
93 struct bufferevent_private *bufev_private =
96 if (!bufev_private->write_suspended)
98 bufev_private->write_suspended |= what;
105 struct bufferevent_private *bufev_private =
108 bufev_private->write_suspended &= ~what;
109 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE))
136 struct bufferevent_private *bufev_private = arg;
137 struct bufferevent *bufev = &bufev_private->bev;
140 if ((bufev_private->eventcb_pending & BEV_EVENT_CONNECTED) &&
144 bufev_private->eventcb_pending &= ~BEV_EVENT_CONNECTED;
147 if (bufev_private->readcb_pending && bufev->readcb) {
148 bufev_private->readcb_pending = 0;
151 if (bufev_private->writecb_pending && bufev->writecb) {
152 bufev_private->writecb_pending = 0;
155 if (bufev_private->eventcb_pending && bufev->errorcb) {
156 short what = bufev_private->eventcb_pending;
157 int err = bufev_private->errno_pending;
158 bufev_private->eventcb_pending = 0;
159 bufev_private->errno_pending = 0;
169 struct bufferevent_private *bufev_private = arg;
170 struct bufferevent *bufev = &bufev_private->bev;
176 if ((bufev_private->eventcb_pending & BEV_EVENT_CONNECTED) &&
182 bufev_private->eventcb_pending &= ~BEV_EVENT_CONNECTED;
185 if (bufev_private->readcb_pending && bufev->readcb) {
188 bufev_private->readcb_pending = 0;
191 if (bufev_private->writecb_pending && bufev->writecb) {
194 bufev_private->writecb_pending = 0;
197 if (bufev_private->eventcb_pending && bufev->errorcb) {
200 short what = bufev_private->eventcb_pending;
201 int err = bufev_private->errno_pending;
202 bufev_private->eventcb_pending = 0;
203 bufev_private->errno_pending = 0;
291 bufferevent_init_common_(struct bufferevent_private *bufev_private,
296 struct bufferevent *bufev = &bufev_private->bev;
310 bufev_private->refcnt = 1;
319 bufferevent_ratelim_init_(bufev_private);
347 &bufev_private->deferred,
350 bufev_private);
353 &bufev_private->deferred,
356 bufev_private);
358 bufev_private->options = options;
462 struct bufferevent_private *bufev_private =
468 if (bufev_private->read_suspended)
470 if (bufev_private->write_suspended)
536 struct bufferevent_private *bufev_private =
542 bufev_private->connecting = 0;
573 struct bufferevent_private *bufev_private =
591 if (bufev_private->read_watermarks_cb == NULL) {
592 bufev_private->read_watermarks_cb =
598 bufev_private->read_watermarks_cb,
607 if (bufev_private->read_watermarks_cb)
609 bufev_private->read_watermarks_cb,
659 struct bufferevent_private *bufev_private =
662 ++bufev_private->refcnt;
686 struct bufferevent_private *bufev_private =
692 EVUTIL_ASSERT(bufev_private->refcnt > 0);
694 if (--bufev_private->refcnt) {
706 cbs[2] = &bufev_private->deferred;
708 if (bufev_private->rate_limiting) {
709 struct event *e = &bufev_private->rate_limiting->refill_bucket_event;
730 struct bufferevent_private *bufev_private =
747 if (bufev_private->rate_limiting) {
748 if (bufev_private->rate_limiting->group)
750 mm_free(bufev_private->rate_limiting);
751 bufev_private->rate_limiting = NULL;
757 if (bufev_private->own_lock)
758 EVTHREAD_FREE_LOCK(bufev_private->lock,
797 struct bufferevent_private *bufev_private =
805 ++bufev_private->refcnt;