Lines Matching refs:bufev_p
107 struct bufferevent_private *bufev_p = in bufferevent_socket_outbuf_cb() local
113 !bufev_p->write_suspended) { in bufferevent_socket_outbuf_cb()
126 struct bufferevent_private *bufev_p = in bufferevent_readcb() local
157 readmax = _bufferevent_get_read_max(bufev_p); in bufferevent_readcb()
161 if (bufev_p->read_suspended) in bufferevent_readcb()
182 _bufferevent_decrement_read_buckets(bufev_p, res); in bufferevent_readcb()
205 struct bufferevent_private *bufev_p = in bufferevent_writecb() local
221 if (bufev_p->connecting) { in bufferevent_writecb()
225 if (bufev_p->connection_refused) { in bufferevent_writecb()
226 bufev_p->connection_refused = 0; in bufferevent_writecb()
233 bufev_p->connecting = 0; in bufferevent_writecb()
253 bufev_p->write_suspended) { in bufferevent_writecb()
260 atmost = _bufferevent_get_write_max(bufev_p); in bufferevent_writecb()
262 if (bufev_p->write_suspended) in bufferevent_writecb()
284 _bufferevent_decrement_write_buckets(bufev_p, res); in bufferevent_writecb()
320 struct bufferevent_private *bufev_p; in bufferevent_socket_new() local
328 if ((bufev_p = mm_calloc(1, sizeof(struct bufferevent_private)))== NULL) in bufferevent_socket_new()
331 if (bufferevent_init_common(bufev_p, base, &bufferevent_ops_socket, in bufferevent_socket_new()
333 mm_free(bufev_p); in bufferevent_socket_new()
336 bufev = &bufev_p->bev; in bufferevent_socket_new()
356 struct bufferevent_private *bufev_p = in bufferevent_socket_connect() local
366 if (!bufev_p) in bufferevent_socket_connect()
387 bufev_p->connecting = 1; in bufferevent_socket_connect()
408 bufev_p->connecting = 1; in bufferevent_socket_connect()
415 bufev_p->connecting = 1; in bufferevent_socket_connect()
419 bufev_p->connection_refused = 1; in bufferevent_socket_connect()
420 bufev_p->connecting = 1; in bufferevent_socket_connect()
567 struct bufferevent_private *bufev_p = in be_socket_disable() local
574 if ((event & EV_WRITE) && ! bufev_p->connecting) { in be_socket_disable()
584 struct bufferevent_private *bufev_p = in be_socket_destruct() local
594 if ((bufev_p->options & BEV_OPT_CLOSE_ON_FREE) && fd >= 0) in be_socket_destruct()