Searched refs:upstream_ (Results 1 – 4 of 4) sorted by relevance
127 upstream_(upstream), in Downstream()175 if (upstream_) { in ~Downstream()176 auto loop = upstream_->get_client_handler()->get_loop(); in ~Downstream()184 auto handler = upstream_->get_client_handler(); in ~Downstream()600 upstream_ = upstream; in reset_upstream()606 Upstream *Downstream::get_upstream() const { return upstream_; } in get_upstream()623 auto handler = upstream_->get_client_handler(); in request_buf_full()741 auto handler = upstream_->get_client_handler(); in response_buf_full()975 auto loop = upstream_->get_client_handler()->get_loop(); in reset_upstream_rtimer()980 auto loop = upstream_->get_client_handler()->get_loop(); in reset_upstream_wtimer()[all …]
157 auto iovcnt = upstream_->response_riovec(iov.data(), iov.size()); in write_clear()171 upstream_->response_drain(nwrite); in write_clear()259 auto iovcnt = upstream_->response_riovec(&iov, 1); in write_tls()279 upstream_->response_drain(nwrite); in write_tls()281 iovcnt = upstream_->response_riovec(&iov, 1); in write_tls()291 assert(upstream_); in upstream_read()292 if (upstream_->on_read() != 0) { in upstream_read()299 assert(upstream_); in upstream_write()300 if (upstream_->on_write() != 0) { in upstream_write()304 if (get_should_close_after_write() && upstream_->response_empty()) { in upstream_write()[all …]
188 std::unique_ptr<Upstream> upstream_; variable
557 Upstream *upstream_; variable