Lines Matching refs:bufev
206 static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg);
382 bufferevent_setcb(evcon->bufev, in evhttp_write_buffer()
388 bufferevent_enable(evcon->bufev, EV_READ|EV_WRITE); in evhttp_write_buffer()
394 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_send_continue_done()
401 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_send_continue()
402 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_send_continue()
407 bufferevent_setcb(evcon->bufev, in evhttp_send_continue()
450 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_request()
535 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_response()
609 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_make_header()
745 bufferevent_disable(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_fail_()
807 evhttp_write_cb(struct bufferevent *bufev, void *arg) in evhttp_write_cb() argument
999 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_trailer()
1007 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_read_trailer()
1021 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_lingering_close()
1049 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_body()
1117 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_read_body()
1132 evhttp_read_cb(struct bufferevent *bufev, void *arg) in evhttp_read_cb() argument
1166 input = bufferevent_get_input(evcon->bufev); in evhttp_read_cb()
1190 struct bufferevent *bev = evcon->bufev; in evhttp_deferred_read_cb()
1192 (bev->readcb)(evcon->bufev, evcon); in evhttp_deferred_read_cb()
1200 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_write_connectioncb()
1254 if (evcon->bufev != NULL) { in evhttp_connection_free()
1256 !(bufferevent_get_options_(evcon->bufev) & BEV_OPT_CLOSE_ON_FREE); in evhttp_connection_free()
1258 evcon->fd = bufferevent_getfd(evcon->bufev); in evhttp_connection_free()
1260 bufferevent_free(evcon->bufev); in evhttp_connection_free()
1335 bufferevent_setcb(evcon->bufev, NULL, NULL, NULL, NULL); in evhttp_connection_reset_()
1348 bufferevent_disable_hard_(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_reset_()
1351 evcon->fd = bufferevent_getfd(evcon->bufev); in evhttp_connection_reset_()
1362 err = bufferevent_setfd(evcon->bufev, -1); in evhttp_connection_reset_()
1366 tmp = bufferevent_get_output(evcon->bufev); in evhttp_connection_reset_()
1369 tmp = bufferevent_get_input(evcon->bufev); in evhttp_connection_reset_()
1382 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_connection_start_detectclose()
1389 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_connection_stop_detectclose()
1469 buf = bufferevent_get_output(evcon->bufev); in evhttp_connection_read_on_write_error()
1479 evhttp_error_cb(struct bufferevent *bufev, short what, void *arg) in evhttp_error_cb() argument
1485 evcon->fd = bufferevent_getfd(bufev); in evhttp_error_cb()
1555 evbuffer_get_length(bufferevent_get_input(bufev))) { in evhttp_error_cb()
1572 evhttp_connection_cb(struct bufferevent *bufev, short what, void *arg) in evhttp_connection_cb() argument
1579 evcon->fd = bufferevent_getfd(bufev); in evhttp_connection_cb()
1590 evhttp_error_cb(bufev, what, arg); in evhttp_connection_cb()
1628 bufferevent_setcb(evcon->bufev, in evhttp_connection_cb()
1637 bufferevent_set_timeouts(evcon->bufev, &read_tv, &write_tv); in evhttp_connection_cb()
1639 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_cb()
2188 EV_SIZE_ARG(evbuffer_get_length(bufferevent_get_input(req->evcon->bufev))))); in evhttp_get_body_length()
2260 if (!evbuffer_get_length(bufferevent_get_input(evcon->bufev))) in evhttp_get_body()
2279 res = evhttp_parse_firstline_(req, bufferevent_get_input(evcon->bufev)); in evhttp_read_firstline()
2302 res = evhttp_parse_headers_(req, bufferevent_get_input(evcon->bufev)); in evhttp_read_header()
2334 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_read_header()
2413 evcon->bufev = bev; in evhttp_connection_base_bufferevent_new()
2424 bufferevent_base_set(base, evcon->bufev); in evhttp_connection_base_bufferevent_new()
2445 return evcon->bufev; in evhttp_connection_get_bufferevent()
2490 bufferevent_base_set(base, evcon->bufev); in evhttp_connection_set_base()
2513 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_set_timeout_tv()
2518 bufferevent_set_timeouts(evcon->bufev, &read_tv, &write_tv); in evhttp_connection_set_timeout_tv()
2560 return bufferevent_socket_get_conn_address_(evcon->bufev); in evhttp_connection_get_addr()
2588 if (bufferevent_setfd(evcon->bufev, evcon->fd)) in evhttp_connection_connect_()
2591 if (bufferevent_setfd(evcon->bufev, -1)) in evhttp_connection_connect_()
2596 bufferevent_setcb(evcon->bufev, in evhttp_connection_connect_()
2603 bufferevent_set_timeouts(evcon->bufev, &conn_tv, &conn_tv); in evhttp_connection_connect_()
2605 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_connect_()
2608 if (bufferevent_enable(evcon->bufev, EV_WRITE)) in evhttp_connection_connect_()
2620 ret = bufferevent_socket_connect(evcon->bufev, sa, socklen); in evhttp_connection_connect_()
2622 ret = bufferevent_socket_connect_hostname(evcon->bufev, in evhttp_connection_connect_()
2737 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_start_read_()
2738 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_start_read_()
2742 bufferevent_setcb(evcon->bufev, in evhttp_start_read_()
2750 if (evbuffer_get_length(bufferevent_get_input(evcon->bufev))) { in evhttp_start_read_()
2759 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_start_write_()
2760 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_start_write_()
2903 output = bufferevent_get_output(evcon->bufev); in evhttp_send_reply_chunk_with_cb()
2936 output = bufferevent_get_output(evcon->bufev); in evhttp_send_reply_end()
3474 bufferevent_disable(req->evcon->bufev, EV_READ); in evhttp_handle_request()
4270 if (bufferevent_setfd(evcon->bufev, fd)) in evhttp_get_request_connection()
4272 if (bufferevent_enable(evcon->bufev, EV_READ)) in evhttp_get_request_connection()
4274 if (bufferevent_disable(evcon->bufev, EV_WRITE)) in evhttp_get_request_connection()
4276 bufferevent_socket_set_conn_address_(evcon->bufev, sa, salen); in evhttp_get_request_connection()