Lines Matching refs:Downstream
248 std::make_unique<Downstream>(this, handler_->get_mcpool(), stream_id); in http_begin_request_headers()
263 std::unique_ptr<Downstream> downstream) { in add_pending_downstream()
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()
1015 Downstream *downstream) { in on_downstream_abort_request_with_https_redirect()
1077 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
1097 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_write()
1149 if (events & Downstream::EVENT_ERROR) { in downstream_error()
1183 if (events & Downstream::EVENT_TIMEOUT) { in downstream_error()
1212 auto downstream = static_cast<Downstream *>(stream_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()
1567 int Http3Upstream::on_downstream_reset(Downstream *downstream, bool no_retry) { in on_downstream_reset()
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()
1750 Downstream *
1751 Http3Upstream::on_downstream_push_promise(Downstream *downstream, in on_downstream_push_promise()
1757 Downstream *downstream, Downstream *promised_downstream) { in on_downstream_push_promise_complete()
1764 Downstream *promised_downstream) {} in cancel_premature_downstream()
2018 auto downstream = static_cast<Downstream *>(stream_user_data); in http_acked_stream_data()
2030 int Http3Upstream::http_acked_stream_data(Downstream *downstream, in http_acked_stream_data()
2070 auto downstream = static_cast<Downstream *>(stream_user_data); in http_recv_request_header()
2091 auto downstream = static_cast<Downstream *>(stream_user_data); in http_recv_request_trailer()
2106 int Http3Upstream::http_recv_request_header(Downstream *downstream, in http_recv_request_header()
2168 auto downstream = static_cast<Downstream *>(stream_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()
2410 auto downstream = static_cast<Downstream *>(stream_user_data); in http_recv_data()
2420 int Http3Upstream::http_recv_data(Downstream *downstream, const uint8_t *data, in http_recv_data()
2441 auto downstream = static_cast<Downstream *>(stream_user_data); in http_end_stream()
2455 int Http3Upstream::http_end_stream(Downstream *downstream) { in http_end_stream()
2474 auto downstream = static_cast<Downstream *>(stream_user_data); in http_stream_close()
2488 int Http3Upstream::http_stream_close(Downstream *downstream, in http_stream_close()
2675 int Http3Upstream::error_reply(Downstream *downstream, in error_reply()
2723 int Http3Upstream::shutdown_stream(Downstream *downstream, in shutdown_stream()
2760 void Http3Upstream::remove_downstream(Downstream *downstream) { in remove_downstream()
2781 Downstream *downstream, const std::vector<nghttp3_nv> &nva) const { in log_response_headers()