Lines Matching refs:Downstream
50 auto downstream = static_cast<Downstream *>(w->data);
81 auto downstream = static_cast<Downstream *>(w->data);
115 Downstream::Downstream(Upstream *upstream, MemchunkPool *mcpool,
173 Downstream::~Downstream() {
225 int Downstream::attach_downstream_connection(
236 void Downstream::detach_downstream_connection() {
257 DownstreamConnection *Downstream::get_downstream_connection() {
261 std::unique_ptr<DownstreamConnection> Downstream::pop_downstream_connection() {
277 void Downstream::pause_read(IOCtrlReason reason) {
283 int Downstream::resume_read(IOCtrlReason reason, size_t consumed) {
291 void Downstream::force_resume_read() {
311 StringRef Downstream::assemble_request_cookie() {
353 uint32_t Downstream::find_affinity_cookie(const StringRef &name) {
396 size_t Downstream::count_crumble_request_cookie() {
417 void Downstream::crumble_request_cookie(std::vector<nghttp2_nv> &nva) {
599 void Downstream::set_request_start_time(
605 Downstream::get_request_start_time() const {
609 void Downstream::reset_upstream(Upstream *upstream) {
616 Upstream *Downstream::get_upstream() const { return upstream_; }
618 void Downstream::set_stream_id(int64_t stream_id) { stream_id_ = stream_id; }
620 int64_t Downstream::get_stream_id() const { return stream_id_; }
622 void Downstream::set_request_state(DownstreamState state) {
626 DownstreamState Downstream::get_request_state() const { return request_state_; }
628 bool Downstream::get_chunked_request() const { return chunked_request_; }
630 void Downstream::set_chunked_request(bool f) { chunked_request_ = f; }
632 bool Downstream::request_buf_full() {
651 DefaultMemchunks *Downstream::get_request_buf() { return &request_buf_; }
654 // Downstream. Otherwise, the program will crash.
655 int Downstream::push_request_headers() {
663 int Downstream::push_upload_data_chunk(const uint8_t *data, size_t datalen) {
687 int Downstream::end_upload_data() {
699 void Downstream::rewrite_location_response_header(
727 bool Downstream::get_chunked_response() const { return chunked_response_; }
729 void Downstream::set_chunked_response(bool f) { chunked_response_ = f; }
731 int Downstream::on_read() {
739 void Downstream::set_response_state(DownstreamState state) {
743 DownstreamState Downstream::get_response_state() const {
747 DefaultMemchunks *Downstream::get_response_buf() { return &response_buf_; }
749 bool Downstream::response_buf_full() {
761 bool Downstream::validate_request_recv_body_length() const {
778 bool Downstream::validate_response_recv_body_length() const {
795 void Downstream::check_upgrade_fulfilled_http2() {
803 void Downstream::check_upgrade_fulfilled_http1() {
836 void Downstream::inspect_http2_request() {
842 void Downstream::inspect_http1_request() {
875 void Downstream::inspect_http1_response() {
882 void Downstream::reset_response() {
888 bool Downstream::get_non_final_response() const {
892 bool Downstream::supports_non_final_response() const {
897 bool Downstream::get_upgraded() const { return upgraded_; }
899 bool Downstream::get_http2_upgrade_request() const {
904 StringRef Downstream::get_http2_settings() const {
912 void Downstream::set_downstream_stream_id(int64_t stream_id) {
916 int64_t Downstream::get_downstream_stream_id() const {
920 uint32_t Downstream::get_response_rst_stream_error_code() const {
924 void Downstream::set_response_rst_stream_error_code(uint32_t error_code) {
928 void Downstream::set_expect_final_response(bool f) {
932 bool Downstream::get_expect_final_response() const {
936 bool Downstream::expect_response_body() const {
941 bool Downstream::expect_response_trailer() const {
977 void Downstream::reset_upstream_rtimer() {
985 void Downstream::reset_upstream_wtimer() {
997 void Downstream::ensure_upstream_wtimer() {
1005 void Downstream::disable_upstream_rtimer() {
1013 void Downstream::disable_upstream_wtimer() {
1021 void Downstream::reset_downstream_rtimer() {
1029 void Downstream::reset_downstream_wtimer() {
1041 void Downstream::ensure_downstream_wtimer() {
1049 void Downstream::disable_downstream_rtimer() {
1057 void Downstream::disable_downstream_wtimer() {
1065 bool Downstream::accesslog_ready() const {
1069 void Downstream::add_retry() { ++num_retry_; }
1071 bool Downstream::no_more_retry() const { return num_retry_ > 50; }
1073 void Downstream::set_request_downstream_host(const StringRef &host) {
1077 void Downstream::set_request_pending(bool f) { request_pending_ = f; }
1079 bool Downstream::get_request_pending() const { return request_pending_; }
1081 void Downstream::set_request_header_sent(bool f) { request_header_sent_ = f; }
1083 bool Downstream::get_request_header_sent() const {
1087 bool Downstream::request_submission_ready() const {
1094 DispatchState Downstream::get_dispatch_state() const { return dispatch_state_; }
1096 void Downstream::set_dispatch_state(DispatchState s) { dispatch_state_ = s; }
1098 void Downstream::attach_blocked_link(BlockedLink *l) {
1105 BlockedLink *Downstream::detach_blocked_link() {
1111 bool Downstream::can_detach_downstream_connection() const {
1120 DefaultMemchunks Downstream::pop_response_buf() {
1124 void Downstream::set_assoc_stream_id(int64_t stream_id) {
1128 int64_t Downstream::get_assoc_stream_id() const { return assoc_stream_id_; }
1130 BlockAllocator &Downstream::get_block_allocator() { return balloc_; }
1132 void Downstream::add_rcbuf(nghttp2_rcbuf *rcbuf) {
1138 void Downstream::add_rcbuf(nghttp3_rcbuf *rcbuf) {
1144 void Downstream::set_downstream_addr_group(
1149 void Downstream::set_addr(const DownstreamAddr *addr) { addr_ = addr; }
1151 const DownstreamAddr *Downstream::get_addr() const { return addr_; }
1153 void Downstream::set_accesslog_written(bool f) { accesslog_written_ = f; }
1155 void Downstream::renew_affinity_cookie(uint32_t h) {
1160 uint32_t Downstream::get_affinity_cookie_to_send() const {
1167 DefaultMemchunks *Downstream::get_blocked_request_buf() {
1171 bool Downstream::get_blocked_request_data_eof() const {
1175 void Downstream::set_blocked_request_data_eof(bool f) {
1179 void Downstream::set_ws_key(const StringRef &key) { ws_key_ = key; }
1181 bool Downstream::get_expect_100_continue() const {
1185 bool Downstream::get_stop_reading() const { return stop_reading_; }
1187 void Downstream::set_stop_reading(bool f) { stop_reading_ = f; }