Lines Matching refs:downstream_
1096 assert(!downstream_);
1097 downstream_ = std::move(downstream);
1101 if (downstream_ && downstream_->accesslog_ready()) {
1102 handler_->write_accesslog(downstream_.get());
1105 downstream_.reset();
1108 Downstream *HttpsUpstream::get_downstream() const { return downstream_.get(); }
1111 return std::unique_ptr<Downstream>(downstream_.release());
1461 if (downstream_ && downstream_->accesslog_ready()) {
1462 handler_->write_accesslog(downstream_.get());
1470 assert(downstream == downstream_.get());
1472 downstream_->pop_downstream_connection();
1474 if (!downstream_->request_submission_ready()) {
1475 switch (downstream_->get_response_state()) {
1480 if (on_downstream_abort_request(downstream_.get(), 502) != 0) {
1491 downstream_->add_retry();
1495 if (no_retry || downstream_->no_more_retry()) {
1500 auto dconn = handler_->get_downstream_connection(rv, downstream_.get());
1505 rv = downstream_->attach_downstream_connection(std::move(dconn));
1511 rv = downstream_->push_request_headers();
1522 rv = on_downstream_abort_request(downstream_.get(), 502);
1527 downstream_->pop_downstream_connection();
1537 if (!downstream_) {
1541 auto buf = downstream_->get_response_buf();
1547 if (!downstream_) {
1551 auto buf = downstream_->get_response_buf();
1557 if (!downstream_) {
1561 auto buf = downstream_->get_response_buf();