Lines Matching refs:Http3Upstream
54 auto upstream = static_cast<Http3Upstream *>(w->data); in timeoutcb()
71 auto upstream = static_cast<Http3Upstream *>(w->data); in shutdown_timeout_cb()
82 auto upstream = static_cast<Http3Upstream *>(w->data); in prepare_cb()
107 auto upstream = static_cast<Http3Upstream *>(handler->get_upstream()); in get_conn()
112 Http3Upstream::Http3Upstream(ClientHandler *handler) in Http3Upstream() function in shrpx::Http3Upstream
140 Http3Upstream::~Http3Upstream() { in ~Http3Upstream()
179 auto upstream = static_cast<Http3Upstream *>(user_data); in qlog_write()
185 void Http3Upstream::qlog_write(const void *data, size_t datalen, bool fin) { in qlog_write()
207 auto upstream = static_cast<Http3Upstream *>(user_data); in get_new_connection_id()
235 auto upstream = static_cast<Http3Upstream *>(user_data); in remove_connection_id()
246 void Http3Upstream::http_begin_request_headers(int64_t stream_id) { in http_begin_request_headers()
262 void Http3Upstream::add_pending_downstream( in add_pending_downstream()
271 auto upstream = static_cast<Http3Upstream *>(user_data); in recv_stream_data()
281 int Http3Upstream::recv_stream_data(uint32_t flags, int64_t stream_id, in recv_stream_data()
306 auto upstream = static_cast<Http3Upstream *>(user_data); in stream_close()
320 int Http3Upstream::stream_close(int64_t stream_id, uint64_t app_error_code) { in stream_close()
348 auto upstream = static_cast<Http3Upstream *>(user_data); in acked_stream_data_offset()
358 int Http3Upstream::acked_stream_data_offset(int64_t stream_id, in acked_stream_data_offset()
378 auto upstream = static_cast<Http3Upstream *>(user_data); in extend_max_stream_data()
388 int Http3Upstream::extend_max_stream_data(int64_t stream_id) { in extend_max_stream_data()
406 auto upstream = static_cast<Http3Upstream *>(user_data); in extend_max_remote_streams_bidi()
414 void Http3Upstream::extend_max_remote_streams_bidi(uint64_t max_streams) { in extend_max_remote_streams_bidi()
422 auto upstream = static_cast<Http3Upstream *>(user_data); in stream_reset()
432 int Http3Upstream::http_shutdown_stream_read(int64_t stream_id) { in http_shutdown_stream_read()
451 auto upstream = static_cast<Http3Upstream *>(user_data); in stream_stop_sending()
463 auto upstream = static_cast<Http3Upstream *>(user_data); in handshake_completed()
473 int Http3Upstream::handshake_completed() { in handshake_completed()
496 auto upstream = static_cast<Http3Upstream *>(user_data); in path_validation()
505 int Http3Upstream::send_new_token(const ngtcp2_addr *remote_addr) { in send_new_token()
541 auto upstream = static_cast<Http3Upstream *>(user_data); in recv_tx_key()
550 int Http3Upstream::init(const UpstreamAddr *faddr, const Address &remote_addr, in init()
746 int Http3Upstream::on_read() { return 0; } in on_read()
748 int Http3Upstream::on_write() { in on_write()
777 int Http3Upstream::write_streams() { in write_streams()
997 int Http3Upstream::on_timeout(Downstream *downstream) { return 0; } in on_timeout()
999 int Http3Upstream::on_downstream_abort_request(Downstream *downstream, in on_downstream_abort_request()
1014 int Http3Upstream::on_downstream_abort_request_with_https_redirect( in on_downstream_abort_request_with_https_redirect()
1036 int Http3Upstream::downstream_read(DownstreamConnection *dconn) { in downstream_read()
1093 int Http3Upstream::downstream_write(DownstreamConnection *dconn) { in downstream_write()
1105 int Http3Upstream::downstream_eof(DownstreamConnection *dconn) { in downstream_eof()
1145 int Http3Upstream::downstream_error(DownstreamConnection *dconn, int events) { in downstream_error()
1203 ClientHandler *Http3Upstream::get_client_handler() const { return handler_; } in get_client_handler()
1211 auto upstream = static_cast<Http3Upstream *>(conn_user_data); in downstream_read_data_callback()
1248 int Http3Upstream::on_downstream_header_complete(Downstream *downstream) { in on_downstream_header_complete()
1440 int Http3Upstream::on_downstream_body(Downstream *downstream, in on_downstream_body()
1455 int Http3Upstream::on_downstream_body_complete(Downstream *downstream) { in on_downstream_body_complete()
1492 void Http3Upstream::on_handler_delete() { in on_handler_delete()
1567 int Http3Upstream::on_downstream_reset(Downstream *downstream, bool no_retry) { in on_downstream_reset()
1647 void Http3Upstream::pause_read(IOCtrlReason reason) {} in pause_read()
1649 int Http3Upstream::resume_read(IOCtrlReason reason, Downstream *downstream, in resume_read()
1662 int Http3Upstream::send_reply(Downstream *downstream, const uint8_t *body, in send_reply()
1738 int Http3Upstream::initiate_push(Downstream *downstream, const StringRef &uri) { in initiate_push()
1742 int Http3Upstream::response_riovec(struct iovec *iov, int iovcnt) const { in response_riovec()
1746 void Http3Upstream::response_drain(size_t n) {} in response_drain()
1748 bool Http3Upstream::response_empty() const { return false; } in response_empty()
1751 Http3Upstream::on_downstream_push_promise(Downstream *downstream, in on_downstream_push_promise()
1756 int Http3Upstream::on_downstream_push_promise_complete( in on_downstream_push_promise_complete()
1761 bool Http3Upstream::push_enabled() const { return false; } in push_enabled()
1763 void Http3Upstream::cancel_premature_downstream( in cancel_premature_downstream()
1766 int Http3Upstream::on_read(const UpstreamAddr *faddr, in on_read()
1838 int Http3Upstream::send_packet(const UpstreamAddr *faddr, in send_packet()
1866 void Http3Upstream::on_send_blocked(const UpstreamAddr *faddr, in on_send_blocked()
1891 int Http3Upstream::send_blocked_packet() { in send_blocked_packet()
1916 void Http3Upstream::signal_write_upstream_addr(const UpstreamAddr *faddr) { in signal_write_upstream_addr()
1930 int Http3Upstream::handle_error() { in handle_error()
1967 int Http3Upstream::handle_expiry() { in handle_expiry()
1986 void Http3Upstream::reset_timer() { in reset_timer()
2005 auto upstream = static_cast<Http3Upstream *>(user_data); in http_deferred_consume()
2017 auto upstream = static_cast<Http3Upstream *>(user_data); in http_acked_stream_data()
2030 int Http3Upstream::http_acked_stream_data(Downstream *downstream, in http_acked_stream_data()
2057 auto upstream = static_cast<Http3Upstream *>(user_data); in http_begin_request_headers()
2069 auto upstream = static_cast<Http3Upstream *>(user_data); in http_recv_request_header()
2090 auto upstream = static_cast<Http3Upstream *>(user_data); in http_recv_request_trailer()
2106 int Http3Upstream::http_recv_request_header(Downstream *downstream, in http_recv_request_header()
2166 auto upstream = static_cast<Http3Upstream *>(user_data); in http_end_request_headers()
2185 int Http3Upstream::http_end_request_headers(Downstream *downstream, int fin) { in http_end_request_headers()
2319 void Http3Upstream::start_downstream(Downstream *downstream) { in start_downstream()
2328 void Http3Upstream::initiate_downstream(Downstream *downstream) { in initiate_downstream()
2409 auto upstream = static_cast<Http3Upstream *>(user_data); in http_recv_data()
2420 int Http3Upstream::http_recv_data(Downstream *downstream, const uint8_t *data, in http_recv_data()
2440 auto upstream = static_cast<Http3Upstream *>(user_data); in http_end_stream()
2455 int Http3Upstream::http_end_stream(Downstream *downstream) { in http_end_stream()
2473 auto upstream = static_cast<Http3Upstream *>(conn_user_data); in http_stream_close()
2488 int Http3Upstream::http_stream_close(Downstream *downstream, in http_stream_close()
2539 auto upstream = static_cast<Http3Upstream *>(user_data); in http_stop_sending()
2549 int Http3Upstream::http_stop_sending(int64_t stream_id, in http_stop_sending()
2566 auto upstream = static_cast<Http3Upstream *>(user_data); in http_reset_stream()
2576 int Http3Upstream::http_reset_stream(int64_t stream_id, in http_reset_stream()
2589 int Http3Upstream::setup_httpconn() { in setup_httpconn()
2675 int Http3Upstream::error_reply(Downstream *downstream, in error_reply()
2723 int Http3Upstream::shutdown_stream(Downstream *downstream, in shutdown_stream()
2742 int Http3Upstream::shutdown_stream_read(int64_t stream_id, in shutdown_stream_read()
2755 void Http3Upstream::consume(int64_t stream_id, size_t nconsumed) { in consume()
2760 void Http3Upstream::remove_downstream(Downstream *downstream) { in remove_downstream()
2780 void Http3Upstream::log_response_headers( in log_response_headers()
2792 int Http3Upstream::check_shutdown() { in check_shutdown()
2804 int Http3Upstream::start_graceful_shutdown() { in start_graceful_shutdown()
2833 int Http3Upstream::submit_goaway() { in submit_goaway()
2847 int Http3Upstream::open_qlog_file(const StringRef &dir, in open_qlog_file()
2887 ngtcp2_conn *Http3Upstream::get_conn() const { return conn_; } in get_conn()