Searched refs:downstream_ (Results 1 – 8 of 8) sorted by relevance
60 if (downstream_) { in ~Http2DownstreamConnection()61 downstream_->disable_downstream_rtimer(); in ~Http2DownstreamConnection()62 downstream_->disable_downstream_wtimer(); in ~Http2DownstreamConnection()65 if (downstream_->get_request_state() == DownstreamState::STREAM_CLOSED && in ~Http2DownstreamConnection()66 downstream_->get_upgraded()) { in ~Http2DownstreamConnection()75 downstream_->get_downstream_stream_id() != -1) { in ~Http2DownstreamConnection()76 submit_rst_stream(downstream_, error_code); in ~Http2DownstreamConnection()78 auto &resp = downstream_->response(); in ~Http2DownstreamConnection()80 http2session_->consume(downstream_->get_downstream_stream_id(), in ~Http2DownstreamConnection()102 downstream_ = downstream; in attach_downstream()[all …]
242 downstream_ = downstream; in attach_downstream()246 downstream_ = nullptr; in attach_downstream()325 auto downstream = this->downstream_; in initiate_connection()451 response_htp_.data = downstream_; in initiate_connection()463 const auto &req = downstream_->request(); in push_request_headers()465 auto &balloc = downstream_->get_block_allocator(); in push_request_headers()484 downstream_->set_request_downstream_host(authority); in push_request_headers()486 auto buf = downstream_->get_request_buf(); in push_request_headers()528 auto cookie = downstream_->assemble_request_cookie(); in push_request_headers()539 downstream_->set_chunked_request(true); in push_request_headers()[all …]
44 downstream_ = downstream; in attach_downstream()54 downstream_ = nullptr; in detach_downstream()58 downstream_->set_request_header_sent(true); in push_request_headers()59 auto src = downstream_->get_blocked_request_buf(); in push_request_headers()60 auto dest = downstream_->get_request_buf(); in push_request_headers()72 auto upstream = downstream_->get_upstream(); in end_upload_data()73 auto &resp = downstream_->response(); in end_upload_data()81 if (upstream->send_reply(downstream_, nullptr, 0) != 0) { in end_upload_data()
86 downstream_ = downstream; in attach_downstream()95 downstream_ = nullptr; in detach_downstream()103 auto upstream = downstream_->get_upstream(); in send_reply()105 auto &resp = downstream_->response(); in send_reply()109 auto &balloc = downstream_->get_block_allocator(); in send_reply()160 if (upstream->send_reply(downstream_, buf.base, buf.len) != 0) { in send_reply()194 auto &req = downstream_->request(); in push_request_headers()262 downstream_->set_request_header_sent(true); in push_request_headers()263 auto src = downstream_->get_blocked_request_buf(); in push_request_headers()264 auto dest = downstream_->get_request_buf(); in push_request_headers()[all …]
1034 assert(!downstream_); in attach_downstream()1035 downstream_ = std::move(downstream); in attach_downstream()1039 if (downstream_ && downstream_->accesslog_ready()) { in delete_downstream()1040 handler_->write_accesslog(downstream_.get()); in delete_downstream()1043 downstream_.reset(); in delete_downstream()1046 Downstream *HttpsUpstream::get_downstream() const { return downstream_.get(); } in get_downstream()1049 return std::unique_ptr<Downstream>(downstream_.release()); in pop_downstream()1417 if (downstream_ && downstream_->accesslog_ready()) { in on_handler_delete()1418 handler_->write_accesslog(downstream_.get()); in on_handler_delete()1426 assert(downstream == downstream_.get()); in on_downstream_reset()[all …]
34 : client_handler_(nullptr), downstream_(nullptr) {} in DownstreamConnection()46 Downstream *DownstreamConnection::get_downstream() { return downstream_; } in get_downstream()
76 Downstream *downstream_; variable
105 std::unique_ptr<Downstream> downstream_; variable