Lines Matching refs:Downstream
248 std::make_unique<Downstream>(this, handler_->get_mcpool(), stream_id);
263 std::unique_ptr<Downstream> downstream) {
1016 int Http3Upstream::on_timeout(Downstream *downstream) { return 0; }
1018 int Http3Upstream::on_downstream_abort_request(Downstream *downstream,
1034 Downstream *downstream) {
1096 return downstream_error(dconn, Downstream::EVENT_ERROR);
1116 return downstream_error(dconn, Downstream::EVENT_ERROR);
1140 ULOG(INFO, this) << "Downstream body was ended by EOF";
1168 if (events & Downstream::EVENT_ERROR) {
1169 DCLOG(INFO, dconn) << "Downstream network/general error";
1202 if (events & Downstream::EVENT_TIMEOUT) {
1231 auto downstream = static_cast<Downstream *>(stream_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) {
1584 int Http3Upstream::on_downstream_reset(Downstream *downstream, bool no_retry) {
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) {
1767 Downstream *
1768 Http3Upstream::on_downstream_push_promise(Downstream *downstream,
1774 Downstream *downstream, Downstream *promised_downstream) {
1781 Downstream *promised_downstream) {}
2035 auto downstream = static_cast<Downstream *>(stream_user_data);
2047 int Http3Upstream::http_acked_stream_data(Downstream *downstream,
2087 auto downstream = static_cast<Downstream *>(stream_user_data);
2108 auto downstream = static_cast<Downstream *>(stream_user_data);
2123 int Http3Upstream::http_recv_request_header(Downstream *downstream,
2185 auto downstream = static_cast<Downstream *>(stream_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) {
2427 auto downstream = static_cast<Downstream *>(stream_user_data);
2437 int Http3Upstream::http_recv_data(Downstream *downstream, const uint8_t *data,
2458 auto downstream = static_cast<Downstream *>(stream_user_data);
2472 int Http3Upstream::http_end_stream(Downstream *downstream) {
2491 auto downstream = static_cast<Downstream *>(stream_user_data);
2505 int Http3Upstream::http_stream_close(Downstream *downstream,
2692 int Http3Upstream::error_reply(Downstream *downstream,
2740 int Http3Upstream::shutdown_stream(Downstream *downstream,
2777 void Http3Upstream::remove_downstream(Downstream *downstream) {
2798 Downstream *downstream, const std::vector<nghttp3_nv> &nva) const {