Lines Matching refs:bufev

198 static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg);
373 bufferevent_setcb(evcon->bufev, in evhttp_write_buffer()
379 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_write_buffer()
385 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_send_continue_done()
392 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_send_continue()
393 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_send_continue()
398 bufferevent_setcb(evcon->bufev, in evhttp_send_continue()
441 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_request()
523 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_response()
597 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_make_header()
733 bufferevent_disable(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_fail_()
790 evhttp_write_cb(struct bufferevent *bufev, void *arg) in evhttp_write_cb() argument
982 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_trailer()
990 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_read_trailer()
1004 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_lingering_close()
1032 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_body()
1100 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_read_body()
1115 evhttp_read_cb(struct bufferevent *bufev, void *arg) in evhttp_read_cb() argument
1149 input = bufferevent_get_input(evcon->bufev); in evhttp_read_cb()
1173 evhttp_read_cb(evcon->bufev, evcon); in evhttp_deferred_read_cb()
1181 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_write_connectioncb()
1231 if (evcon->bufev != NULL) in evhttp_connection_free()
1232 bufferevent_free(evcon->bufev); in evhttp_connection_free()
1238 evcon->fd = bufferevent_getfd(evcon->bufev); in evhttp_connection_free()
1241 bufferevent_disable(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_free()
1243 if (!(bufferevent_get_options_(evcon->bufev) & BEV_OPT_CLOSE_ON_FREE)) { in evhttp_connection_free()
1323 bufferevent_disable_hard_(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_reset_()
1326 evcon->fd = bufferevent_getfd(evcon->bufev); in evhttp_connection_reset_()
1337 bufferevent_setfd(evcon->bufev, -1); in evhttp_connection_reset_()
1340 tmp = bufferevent_get_output(evcon->bufev); in evhttp_connection_reset_()
1343 tmp = bufferevent_get_input(evcon->bufev); in evhttp_connection_reset_()
1357 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_connection_start_detectclose()
1365 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_connection_stop_detectclose()
1445 buf = bufferevent_get_output(evcon->bufev); in evhttp_connection_read_on_write_error()
1455 evhttp_error_cb(struct bufferevent *bufev, short what, void *arg) in evhttp_error_cb() argument
1461 evcon->fd = bufferevent_getfd(bufev); in evhttp_error_cb()
1540 evhttp_connection_cb(struct bufferevent *bufev, short what, void *arg) in evhttp_connection_cb() argument
1547 evcon->fd = bufferevent_getfd(bufev); in evhttp_connection_cb()
1558 evhttp_error_cb(bufev, what, arg); in evhttp_connection_cb()
1596 bufferevent_setcb(evcon->bufev, in evhttp_connection_cb()
1605 bufferevent_set_timeouts(evcon->bufev, &read_tv, &write_tv); in evhttp_connection_cb()
1607 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_cb()
2146 EV_SIZE_ARG(evbuffer_get_length(bufferevent_get_input(req->evcon->bufev))))); in evhttp_get_body_length()
2219 if (!evbuffer_get_length(bufferevent_get_input(evcon->bufev))) in evhttp_get_body()
2238 res = evhttp_parse_firstline_(req, bufferevent_get_input(evcon->bufev)); in evhttp_read_firstline()
2261 res = evhttp_parse_headers_(req, bufferevent_get_input(evcon->bufev)); in evhttp_read_header()
2293 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_read_header()
2372 evcon->bufev = bev; in evhttp_connection_base_bufferevent_new()
2383 bufferevent_base_set(base, evcon->bufev); in evhttp_connection_base_bufferevent_new()
2404 return evcon->bufev; in evhttp_connection_get_bufferevent()
2449 bufferevent_base_set(base, evcon->bufev); in evhttp_connection_set_base()
2472 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_set_timeout_tv()
2477 bufferevent_set_timeouts(evcon->bufev, &read_tv, &write_tv); in evhttp_connection_set_timeout_tv()
2519 return bufferevent_socket_get_conn_address_(evcon->bufev); in evhttp_connection_get_addr()
2547 bufferevent_setfd(evcon->bufev, evcon->fd); in evhttp_connection_connect_()
2549 bufferevent_setfd(evcon->bufev, -1); in evhttp_connection_connect_()
2553 bufferevent_setcb(evcon->bufev, in evhttp_connection_connect_()
2560 bufferevent_set_timeouts(evcon->bufev, &conn_tv, &conn_tv); in evhttp_connection_connect_()
2562 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_connect_()
2565 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_connection_connect_()
2576 ret = bufferevent_socket_connect(evcon->bufev, sa, socklen); in evhttp_connection_connect_()
2578 ret = bufferevent_socket_connect_hostname(evcon->bufev, in evhttp_connection_connect_()
2689 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_start_read_()
2690 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_start_read_()
2694 bufferevent_setcb(evcon->bufev, in evhttp_start_read_()
2702 if (evbuffer_get_length(bufferevent_get_input(evcon->bufev))) { in evhttp_start_read_()
2711 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_start_write_()
2712 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_start_write_()
2851 output = bufferevent_get_output(evcon->bufev); in evhttp_send_reply_chunk_with_cb()
2884 output = bufferevent_get_output(evcon->bufev); in evhttp_send_reply_end()
4203 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_get_request_connection()
4204 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_get_request_connection()
4205 bufferevent_setfd(evcon->bufev, fd); in evhttp_get_request_connection()