Lines Matching refs:upstream_
161 auto iovcnt = upstream_->response_riovec(iov.data(), iov.size()); in write_clear()
175 upstream_->response_drain(nwrite); in write_clear()
292 auto iovcnt = upstream_->response_riovec(&iov, 1); in write_tls()
312 upstream_->response_drain(nwrite); in write_tls()
314 iovcnt = upstream_->response_riovec(&iov, 1); in write_tls()
327 auto upstream = static_cast<Http3Upstream *>(upstream_.get()); in read_quic()
332 int ClientHandler::write_quic() { return upstream_->on_write(); } in write_quic()
338 assert(upstream_); in upstream_read()
339 if (upstream_->on_read() != 0) { in upstream_read()
346 assert(upstream_); in upstream_write()
347 if (upstream_->on_write() != 0) { in upstream_write()
351 if (get_should_close_after_write() && upstream_->response_empty()) { in upstream_write()
537 upstream_ = std::make_unique<HttpsUpstream>(this); in setup_upstream_io_callback()
549 upstream_ = std::move(upstream); in setup_http3_upstream()
563 if (upstream_) { in ~ClientHandler()
564 upstream_->on_handler_delete(); in ~ClientHandler()
588 Upstream *ClientHandler::get_upstream() { return upstream_.get(); } in get_upstream()
658 upstream_ = std::move(http2_upstream); in validate_next_proto()
672 upstream_ = std::make_unique<HttpsUpstream>(this); in validate_next_proto()
1161 upstream_ = std::make_unique<Http2Upstream>(this); in direct_http2_upgrade()
1184 upstream_.release(); in perform_http2_upgrade()
1200 upstream_ = std::move(upstream); in perform_http2_upgrade()