Lines Matching refs:bufev_p

134 	struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);  in bufferevent_socket_outbuf_cb()  local
139 !bufev_p->write_suspended) { in bufferevent_socket_outbuf_cb()
152 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev); in bufferevent_readcb() local
182 readmax = bufferevent_get_read_max_(bufev_p); in bufferevent_readcb()
186 if (bufev_p->read_suspended) in bufferevent_readcb()
198 bufev_p->connection_refused = 1; in bufferevent_readcb()
211 bufferevent_decrement_read_buckets_(bufev_p, res); in bufferevent_readcb()
233 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev); in bufferevent_writecb() local
248 if (bufev_p->connecting) { in bufferevent_writecb()
252 if (bufev_p->connection_refused) { in bufferevent_writecb()
253 bufev_p->connection_refused = 0; in bufferevent_writecb()
260 bufev_p->connecting = 0; in bufferevent_writecb()
281 bufev_p->write_suspended) { in bufferevent_writecb()
288 atmost = bufferevent_get_write_max_(bufev_p); in bufferevent_writecb()
290 if (bufev_p->write_suspended) in bufferevent_writecb()
312 bufferevent_decrement_write_buckets_(bufev_p, res); in bufferevent_writecb()
347 struct bufferevent_private *bufev_p; in bufferevent_socket_new() local
355 if ((bufev_p = mm_calloc(1, sizeof(struct bufferevent_private)))== NULL) in bufferevent_socket_new()
358 if (bufferevent_init_common_(bufev_p, base, &bufferevent_ops_socket, in bufferevent_socket_new()
360 mm_free(bufev_p); in bufferevent_socket_new()
363 bufev = &bufev_p->bev; in bufferevent_socket_new()
383 struct bufferevent_private *bufev_p = BEV_UPCAST(bev); in bufferevent_socket_connect() local
409 bufev_p->connecting = 1; in bufferevent_socket_connect()
430 bufev_p->connecting = 1; in bufferevent_socket_connect()
437 bufev_p->connecting = 1; in bufferevent_socket_connect()
582 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev); in be_socket_disable() local
588 if ((event & EV_WRITE) && ! bufev_p->connecting) { in be_socket_disable()
598 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev); in be_socket_destruct() local
604 if ((bufev_p->options & BEV_OPT_CLOSE_ON_FREE) && fd >= 0) in be_socket_destruct()
607 evutil_getaddrinfo_cancel_async_(bufev_p->dns_request); in be_socket_destruct()
621 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev); in be_socket_setfd() local
640 evutil_getaddrinfo_cancel_async_(bufev_p->dns_request); in be_socket_setfd()
650 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev); in bufferevent_priority_set() local
661 event_deferred_cb_set_priority_(&bufev_p->deferred, priority); in bufferevent_priority_set()