Lines Matching refs:Http3Upstream
54 auto upstream = static_cast<Http3Upstream *>(w->data);
71 auto upstream = static_cast<Http3Upstream *>(w->data);
82 auto upstream = static_cast<Http3Upstream *>(w->data);
107 auto upstream = static_cast<Http3Upstream *>(handler->get_upstream());
112 Http3Upstream::Http3Upstream(ClientHandler *handler)
140 Http3Upstream::~Http3Upstream() {
179 auto upstream = static_cast<Http3Upstream *>(user_data);
185 void Http3Upstream::qlog_write(const void *data, size_t datalen, bool fin) {
207 auto upstream = static_cast<Http3Upstream *>(user_data);
235 auto upstream = static_cast<Http3Upstream *>(user_data);
246 void Http3Upstream::http_begin_request_headers(int64_t stream_id) {
262 void Http3Upstream::add_pending_downstream(
271 auto upstream = static_cast<Http3Upstream *>(user_data);
281 int Http3Upstream::recv_stream_data(uint32_t flags, int64_t stream_id,
306 auto upstream = static_cast<Http3Upstream *>(user_data);
320 int Http3Upstream::stream_close(int64_t stream_id, uint64_t app_error_code) {
348 auto upstream = static_cast<Http3Upstream *>(user_data);
358 int Http3Upstream::acked_stream_data_offset(int64_t stream_id,
378 auto upstream = static_cast<Http3Upstream *>(user_data);
388 int Http3Upstream::extend_max_stream_data(int64_t stream_id) {
406 auto upstream = static_cast<Http3Upstream *>(user_data);
414 void Http3Upstream::extend_max_remote_streams_bidi(uint64_t max_streams) {
422 auto upstream = static_cast<Http3Upstream *>(user_data);
432 int Http3Upstream::stream_reset(int64_t stream_id) {
450 int Http3Upstream::http_shutdown_stream_read(int64_t stream_id) {
469 auto upstream = static_cast<Http3Upstream *>(user_data);
481 auto upstream = static_cast<Http3Upstream *>(user_data);
491 int Http3Upstream::handshake_completed() {
514 auto upstream = static_cast<Http3Upstream *>(user_data);
523 int Http3Upstream::send_new_token(const ngtcp2_addr *remote_addr) {
559 auto upstream = static_cast<Http3Upstream *>(user_data);
568 int Http3Upstream::init(const UpstreamAddr *faddr, const Address &remote_addr,
765 int Http3Upstream::on_read() { return 0; }
767 int Http3Upstream::on_write() {
796 int Http3Upstream::write_streams() {
1016 int Http3Upstream::on_timeout(Downstream *downstream) { return 0; }
1018 int Http3Upstream::on_downstream_abort_request(Downstream *downstream,
1033 int Http3Upstream::on_downstream_abort_request_with_https_redirect(
1055 int Http3Upstream::downstream_read(DownstreamConnection *dconn) {
1112 int Http3Upstream::downstream_write(DownstreamConnection *dconn) {
1124 int Http3Upstream::downstream_eof(DownstreamConnection *dconn) {
1164 int Http3Upstream::downstream_error(DownstreamConnection *dconn, int events) {
1222 ClientHandler *Http3Upstream::get_client_handler() const { return handler_; }
1230 auto upstream = static_cast<Http3Upstream *>(conn_user_data);
1267 int Http3Upstream::on_downstream_header_complete(Downstream *downstream) {
1459 int Http3Upstream::on_downstream_body(Downstream *downstream,
1474 int Http3Upstream::on_downstream_body_complete(Downstream *downstream) {
1511 void Http3Upstream::on_handler_delete() {
1584 int Http3Upstream::on_downstream_reset(Downstream *downstream, bool no_retry) {
1664 void Http3Upstream::pause_read(IOCtrlReason reason) {}
1666 int Http3Upstream::resume_read(IOCtrlReason reason, Downstream *downstream,
1679 int Http3Upstream::send_reply(Downstream *downstream, const uint8_t *body,
1755 int Http3Upstream::initiate_push(Downstream *downstream, const StringRef &uri) {
1759 int Http3Upstream::response_riovec(struct iovec *iov, int iovcnt) const {
1763 void Http3Upstream::response_drain(size_t n) {}
1765 bool Http3Upstream::response_empty() const { return false; }
1768 Http3Upstream::on_downstream_push_promise(Downstream *downstream,
1773 int Http3Upstream::on_downstream_push_promise_complete(
1778 bool Http3Upstream::push_enabled() const { return false; }
1780 void Http3Upstream::cancel_premature_downstream(
1783 int Http3Upstream::on_read(const UpstreamAddr *faddr,
1855 int Http3Upstream::send_packet(const UpstreamAddr *faddr,
1883 void Http3Upstream::on_send_blocked(const UpstreamAddr *faddr,
1908 int Http3Upstream::send_blocked_packet() {
1933 void Http3Upstream::signal_write_upstream_addr(const UpstreamAddr *faddr) {
1947 int Http3Upstream::handle_error() {
1984 int Http3Upstream::handle_expiry() {
2003 void Http3Upstream::reset_timer() {
2022 auto upstream = static_cast<Http3Upstream *>(user_data);
2034 auto upstream = static_cast<Http3Upstream *>(user_data);
2047 int Http3Upstream::http_acked_stream_data(Downstream *downstream,
2074 auto upstream = static_cast<Http3Upstream *>(user_data);
2086 auto upstream = static_cast<Http3Upstream *>(user_data);
2107 auto upstream = static_cast<Http3Upstream *>(user_data);
2123 int Http3Upstream::http_recv_request_header(Downstream *downstream,
2183 auto upstream = static_cast<Http3Upstream *>(user_data);
2202 int Http3Upstream::http_end_request_headers(Downstream *downstream, int fin) {
2336 void Http3Upstream::start_downstream(Downstream *downstream) {
2345 void Http3Upstream::initiate_downstream(Downstream *downstream) {
2426 auto upstream = static_cast<Http3Upstream *>(user_data);
2437 int Http3Upstream::http_recv_data(Downstream *downstream, const uint8_t *data,
2457 auto upstream = static_cast<Http3Upstream *>(user_data);
2472 int Http3Upstream::http_end_stream(Downstream *downstream) {
2490 auto upstream = static_cast<Http3Upstream *>(conn_user_data);
2505 int Http3Upstream::http_stream_close(Downstream *downstream,
2556 auto upstream = static_cast<Http3Upstream *>(user_data);
2566 int Http3Upstream::http_stop_sending(int64_t stream_id,
2583 auto upstream = static_cast<Http3Upstream *>(user_data);
2593 int Http3Upstream::http_reset_stream(int64_t stream_id,
2606 int Http3Upstream::setup_httpconn() {
2692 int Http3Upstream::error_reply(Downstream *downstream,
2740 int Http3Upstream::shutdown_stream(Downstream *downstream,
2759 int Http3Upstream::shutdown_stream_read(int64_t stream_id,
2772 void Http3Upstream::consume(int64_t stream_id, size_t nconsumed) {
2777 void Http3Upstream::remove_downstream(Downstream *downstream) {
2797 void Http3Upstream::log_response_headers(
2809 int Http3Upstream::check_shutdown() {
2821 int Http3Upstream::start_graceful_shutdown() {
2850 int Http3Upstream::submit_goaway() {
2864 int Http3Upstream::open_qlog_file(const StringRef &dir,
2904 ngtcp2_conn *Http3Upstream::get_conn() const { return conn_; }