Lines Matching refs:Downstream
67 auto downstream = static_cast<Downstream *>(
177 auto downstream = static_cast<Downstream *>(
239 auto downstream = static_cast<Downstream *>(
281 auto downstream = std::make_unique<Downstream>(this, handler_->get_mcpool(),
308 int Http2Upstream::on_request_headers(Downstream *downstream,
457 void Http2Upstream::start_downstream(Downstream *downstream) {
466 void Http2Upstream::initiate_downstream(Downstream *downstream) {
556 auto downstream = static_cast<Downstream *>(
577 auto downstream = static_cast<Downstream *>(
633 auto downstream = static_cast<Downstream *>(
679 auto downstream = static_cast<Downstream *>(
716 auto promised_downstream = std::make_unique<Downstream>(
723 // hanging Downstream.
823 auto downstream = static_cast<Downstream *>(
841 auto downstream = static_cast<Downstream *>(source->ptr);
1291 return downstream_error(dconn, Downstream::EVENT_ERROR);
1311 return downstream_error(dconn, Downstream::EVENT_ERROR);
1335 ULOG(INFO, this) << "Downstream body was ended by EOF";
1361 if (events & Downstream::EVENT_ERROR) {
1362 DCLOG(INFO, dconn) << "Downstream network/general error";
1393 if (events & Downstream::EVENT_TIMEOUT) {
1413 int Http2Upstream::rst_stream(Downstream *downstream, uint32_t error_code) {
1445 auto downstream = static_cast<Downstream *>(source->ptr);
1507 int Http2Upstream::send_reply(Downstream *downstream, const uint8_t *body,
1579 int Http2Upstream::error_reply(Downstream *downstream,
1624 std::unique_ptr<Downstream> downstream) {
1628 void Http2Upstream::remove_downstream(Downstream *downstream) {
1650 int Http2Upstream::on_downstream_header_complete(Downstream *downstream) {
1890 int Http2Upstream::on_downstream_body(Downstream *downstream,
1907 int Http2Upstream::on_downstream_body_complete(Downstream *downstream) {
1930 int Http2Upstream::resume_read(IOCtrlReason reason, Downstream *downstream,
1946 int Http2Upstream::on_downstream_abort_request(Downstream *downstream,
1961 Downstream *downstream) {
1973 int Http2Upstream::redirect_to_https(Downstream *downstream) {
2027 Downstream *downstream, const std::vector<nghttp2_nv> &nva) const {
2038 int Http2Upstream::on_timeout(Downstream *downstream) {
2059 int Http2Upstream::on_downstream_reset(Downstream *downstream, bool no_retry) {
2138 int Http2Upstream::prepare_push_promise(Downstream *downstream) {
2190 Downstream *downstream) {
2258 int Http2Upstream::initiate_push(Downstream *downstream, const StringRef &uri) {
2322 Downstream *
2323 Http2Upstream::on_downstream_push_promise(Downstream *downstream,
2328 std::make_unique<Downstream>(this, handler_->get_mcpool(), 0);
2351 Downstream *downstream, Downstream *promised_downstream) {
2376 Downstream *promised_downstream) {