Lines Matching refs:bufev_p
130 struct bufferevent_private *bufev_p = in bufferevent_socket_outbuf_cb() local
136 !bufev_p->write_suspended) { in bufferevent_socket_outbuf_cb()
149 struct bufferevent_private *bufev_p = in bufferevent_readcb() local
180 readmax = bufferevent_get_read_max_(bufev_p); in bufferevent_readcb()
184 if (bufev_p->read_suspended) in bufferevent_readcb()
196 bufev_p->connection_refused = 1; in bufferevent_readcb()
209 bufferevent_decrement_read_buckets_(bufev_p, res); in bufferevent_readcb()
231 struct bufferevent_private *bufev_p = in bufferevent_writecb() local
247 if (bufev_p->connecting) { in bufferevent_writecb()
251 if (bufev_p->connection_refused) { in bufferevent_writecb()
252 bufev_p->connection_refused = 0; in bufferevent_writecb()
259 bufev_p->connecting = 0; in bufferevent_writecb()
267 bufferevent_socket_set_conn_address_fd(bufev_p, fd); in bufferevent_writecb()
280 bufev_p->write_suspended) { in bufferevent_writecb()
287 atmost = bufferevent_get_write_max_(bufev_p); in bufferevent_writecb()
289 if (bufev_p->write_suspended) in bufferevent_writecb()
311 bufferevent_decrement_write_buckets_(bufev_p, res); in bufferevent_writecb()
346 struct bufferevent_private *bufev_p; in bufferevent_socket_new() local
354 if ((bufev_p = mm_calloc(1, sizeof(struct bufferevent_private)))== NULL) in bufferevent_socket_new()
357 if (bufferevent_init_common_(bufev_p, base, &bufferevent_ops_socket, in bufferevent_socket_new()
359 mm_free(bufev_p); in bufferevent_socket_new()
362 bufev = &bufev_p->bev; in bufferevent_socket_new()
382 struct bufferevent_private *bufev_p = in bufferevent_socket_connect() local
392 if (!bufev_p) in bufferevent_socket_connect()
412 bufev_p->connecting = 1; in bufferevent_socket_connect()
433 bufev_p->connecting = 1; in bufferevent_socket_connect()
440 bufev_p->connecting = 1; in bufferevent_socket_connect()
590 struct bufferevent_private *bufev_p = in be_socket_disable() local
597 if ((event & EV_WRITE) && ! bufev_p->connecting) { in be_socket_disable()
607 struct bufferevent_private *bufev_p = in be_socket_destruct() local
614 if ((bufev_p->options & BEV_OPT_CLOSE_ON_FREE) && fd >= 0) in be_socket_destruct()
617 evutil_getaddrinfo_cancel_async_(bufev_p->dns_request); in be_socket_destruct()
631 struct bufferevent_private *bufev_p = in be_socket_setfd() local
651 evutil_getaddrinfo_cancel_async_(bufev_p->dns_request); in be_socket_setfd()
661 struct bufferevent_private *bufev_p = in bufferevent_priority_set() local
673 event_deferred_cb_set_priority_(&bufev_p->deferred, priority); in bufferevent_priority_set()