Lines Matching defs:downstream
67 auto downstream = static_cast<Downstream *>( in on_stream_close_callback() local
131 auto downstream = http->pop_downstream(); in upgrade_upstream() local
177 auto downstream = static_cast<Downstream *>( in on_header_callback2() local
239 auto downstream = static_cast<Downstream *>( in on_invalid_header_callback2() local
281 auto downstream = std::make_unique<Downstream>(this, handler_->get_mcpool(), in on_start_request() local
308 int Http2Upstream::on_request_headers(Downstream *downstream, in on_request_headers()
451 void Http2Upstream::start_downstream(Downstream *downstream) { in start_downstream()
460 void Http2Upstream::initiate_downstream(Downstream *downstream) { in initiate_downstream()
548 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback() local
569 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback() local
625 auto downstream = static_cast<Downstream *>( in on_data_chunk_recv_callback() local
671 auto downstream = static_cast<Downstream *>( in on_frame_send_callback() local
815 auto downstream = static_cast<Downstream *>( in on_frame_not_send_callback() local
833 auto downstream = static_cast<Downstream *>(source->ptr); in send_data_callback() local
1241 auto downstream = dconn->get_downstream(); in downstream_read() local
1310 auto downstream = dconn->get_downstream(); in downstream_eof() local
1348 auto downstream = dconn->get_downstream(); in downstream_error() local
1403 int Http2Upstream::rst_stream(Downstream *downstream, uint32_t error_code) { in rst_stream()
1435 auto downstream = static_cast<Downstream *>(source->ptr); in downstream_data_read_callback() local
1497 int Http2Upstream::send_reply(Downstream *downstream, const uint8_t *body, in send_reply()
1569 int Http2Upstream::error_reply(Downstream *downstream, in error_reply()
1614 std::unique_ptr<Downstream> downstream) { in add_pending_downstream()
1618 void Http2Upstream::remove_downstream(Downstream *downstream) { in remove_downstream()
1640 int Http2Upstream::on_downstream_header_complete(Downstream *downstream) { in on_downstream_header_complete()
1872 int Http2Upstream::on_downstream_body(Downstream *downstream, in on_downstream_body()
1889 int Http2Upstream::on_downstream_body_complete(Downstream *downstream) { in on_downstream_body_complete()
1912 int Http2Upstream::resume_read(IOCtrlReason reason, Downstream *downstream, in resume_read()
1928 int Http2Upstream::on_downstream_abort_request(Downstream *downstream, in on_downstream_abort_request()
1943 Downstream *downstream) { in on_downstream_abort_request_with_https_redirect()
1955 int Http2Upstream::redirect_to_https(Downstream *downstream) { in redirect_to_https()
2009 Downstream *downstream, const std::vector<nghttp2_nv> &nva) const { in log_response_headers()
2020 int Http2Upstream::on_timeout(Downstream *downstream) { in on_timeout()
2041 int Http2Upstream::on_downstream_reset(Downstream *downstream, bool no_retry) { in on_downstream_reset()
2120 int Http2Upstream::prepare_push_promise(Downstream *downstream) { in prepare_push_promise()
2172 Downstream *downstream) { in submit_push_promise()
2240 int Http2Upstream::initiate_push(Downstream *downstream, const StringRef &uri) { in initiate_push()
2305 Http2Upstream::on_downstream_push_promise(Downstream *downstream, in on_downstream_push_promise()
2333 Downstream *downstream, Downstream *promised_downstream) { in on_downstream_push_promise_complete()