Lines Matching refs:bufev
206 static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg);
381 bufferevent_setcb(evcon->bufev, in evhttp_write_buffer()
387 bufferevent_enable(evcon->bufev, EV_READ|EV_WRITE); in evhttp_write_buffer()
393 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_send_continue_done()
400 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_send_continue()
401 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_send_continue()
406 bufferevent_setcb(evcon->bufev, in evhttp_send_continue()
449 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_request()
531 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_response()
605 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_make_header()
741 bufferevent_disable(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_fail_()
798 evhttp_write_cb(struct bufferevent *bufev, void *arg) in evhttp_write_cb() argument
990 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_trailer()
998 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_read_trailer()
1012 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_lingering_close()
1040 struct evbuffer *buf = bufferevent_get_input(evcon->bufev); in evhttp_read_body()
1108 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_read_body()
1123 evhttp_read_cb(struct bufferevent *bufev, void *arg) in evhttp_read_cb() argument
1157 input = bufferevent_get_input(evcon->bufev); in evhttp_read_cb()
1181 struct bufferevent *bev = evcon->bufev; in evhttp_deferred_read_cb()
1183 (bev->readcb)(evcon->bufev, evcon); in evhttp_deferred_read_cb()
1191 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_write_connectioncb()
1245 if (evcon->bufev != NULL) { in evhttp_connection_free()
1247 !(bufferevent_get_options_(evcon->bufev) & BEV_OPT_CLOSE_ON_FREE); in evhttp_connection_free()
1249 evcon->fd = bufferevent_getfd(evcon->bufev); in evhttp_connection_free()
1251 bufferevent_free(evcon->bufev); in evhttp_connection_free()
1326 bufferevent_setcb(evcon->bufev, NULL, NULL, NULL, NULL); in evhttp_connection_reset_()
1339 bufferevent_disable_hard_(evcon->bufev, EV_READ|EV_WRITE); in evhttp_connection_reset_()
1342 evcon->fd = bufferevent_getfd(evcon->bufev); in evhttp_connection_reset_()
1353 err = bufferevent_setfd(evcon->bufev, -1); in evhttp_connection_reset_()
1357 tmp = bufferevent_get_output(evcon->bufev); in evhttp_connection_reset_()
1360 tmp = bufferevent_get_input(evcon->bufev); in evhttp_connection_reset_()
1373 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_connection_start_detectclose()
1380 bufferevent_disable(evcon->bufev, EV_READ); in evhttp_connection_stop_detectclose()
1460 buf = bufferevent_get_output(evcon->bufev); in evhttp_connection_read_on_write_error()
1470 evhttp_error_cb(struct bufferevent *bufev, short what, void *arg) in evhttp_error_cb() argument
1476 evcon->fd = bufferevent_getfd(bufev); in evhttp_error_cb()
1546 evbuffer_get_length(bufferevent_get_input(bufev))) { in evhttp_error_cb()
1563 evhttp_connection_cb(struct bufferevent *bufev, short what, void *arg) in evhttp_connection_cb() argument
1570 evcon->fd = bufferevent_getfd(bufev); in evhttp_connection_cb()
1581 evhttp_error_cb(bufev, what, arg); in evhttp_connection_cb()
1619 bufferevent_setcb(evcon->bufev, in evhttp_connection_cb()
1628 bufferevent_set_timeouts(evcon->bufev, &read_tv, &write_tv); in evhttp_connection_cb()
1630 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_cb()
2179 EV_SIZE_ARG(evbuffer_get_length(bufferevent_get_input(req->evcon->bufev))))); in evhttp_get_body_length()
2251 if (!evbuffer_get_length(bufferevent_get_input(evcon->bufev))) in evhttp_get_body()
2270 res = evhttp_parse_firstline_(req, bufferevent_get_input(evcon->bufev)); in evhttp_read_firstline()
2293 res = evhttp_parse_headers_(req, bufferevent_get_input(evcon->bufev)); in evhttp_read_header()
2325 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_read_header()
2404 evcon->bufev = bev; in evhttp_connection_base_bufferevent_new()
2415 bufferevent_base_set(base, evcon->bufev); in evhttp_connection_base_bufferevent_new()
2436 return evcon->bufev; in evhttp_connection_get_bufferevent()
2481 bufferevent_base_set(base, evcon->bufev); in evhttp_connection_set_base()
2504 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_set_timeout_tv()
2509 bufferevent_set_timeouts(evcon->bufev, &read_tv, &write_tv); in evhttp_connection_set_timeout_tv()
2551 return bufferevent_socket_get_conn_address_(evcon->bufev); in evhttp_connection_get_addr()
2579 if (bufferevent_setfd(evcon->bufev, evcon->fd)) in evhttp_connection_connect_()
2582 if (bufferevent_setfd(evcon->bufev, -1)) in evhttp_connection_connect_()
2587 bufferevent_setcb(evcon->bufev, in evhttp_connection_connect_()
2594 bufferevent_set_timeouts(evcon->bufev, &conn_tv, &conn_tv); in evhttp_connection_connect_()
2596 bufferevent_set_timeouts(evcon->bufev, &evcon->timeout, &evcon->timeout); in evhttp_connection_connect_()
2599 if (bufferevent_enable(evcon->bufev, EV_WRITE)) in evhttp_connection_connect_()
2611 ret = bufferevent_socket_connect(evcon->bufev, sa, socklen); in evhttp_connection_connect_()
2613 ret = bufferevent_socket_connect_hostname(evcon->bufev, in evhttp_connection_connect_()
2728 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_start_read_()
2729 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_start_read_()
2733 bufferevent_setcb(evcon->bufev, in evhttp_start_read_()
2741 if (evbuffer_get_length(bufferevent_get_input(evcon->bufev))) { in evhttp_start_read_()
2750 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_start_write_()
2751 bufferevent_enable(evcon->bufev, EV_READ); in evhttp_start_write_()
2894 output = bufferevent_get_output(evcon->bufev); in evhttp_send_reply_chunk_with_cb()
2927 output = bufferevent_get_output(evcon->bufev); in evhttp_send_reply_end()
3462 bufferevent_disable(req->evcon->bufev, EV_READ); in evhttp_handle_request()
4258 if (bufferevent_setfd(evcon->bufev, fd)) in evhttp_get_request_connection()
4260 if (bufferevent_enable(evcon->bufev, EV_READ)) in evhttp_get_request_connection()
4262 if (bufferevent_disable(evcon->bufev, EV_WRITE)) in evhttp_get_request_connection()
4264 bufferevent_socket_set_conn_address_(evcon->bufev, sa, salen); in evhttp_get_request_connection()