Home
last modified time | relevance | path

Searched refs:downstream_ (Results 1 - 9 of 9) sorted by relevance

/third_party/nghttp2/src/
H A Dshrpx_http2_downstream_connection.cc60 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_ in attach_downstream()
[all...]
H A Dshrpx_http_downstream_connection.cc244 downstream_ = downstream; in attach_downstream()
248 downstream_ = nullptr; in attach_downstream()
340 auto downstream = this->downstream_; in initiate_connection()
466 response_htp_.data = downstream_; in initiate_connection()
478 const auto &req = downstream_->request(); in push_request_headers()
480 auto &balloc = downstream_->get_block_allocator(); in push_request_headers()
499 downstream_->set_request_downstream_host(authority); in push_request_headers()
501 auto buf = downstream_->get_request_buf(); in push_request_headers()
545 auto cookie = downstream_->assemble_request_cookie(); in push_request_headers()
556 downstream_ in push_request_headers()
[all...]
H A Dshrpx_health_monitor_downstream_connection.cc44 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()
H A Dshrpx_api_downstream_connection.cc86 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_ in push_request_headers()
[all...]
H A Dshrpx_https_upstream.cc1096 assert(!downstream_); in attach_downstream()
1097 downstream_ = std::move(downstream); in attach_downstream()
1101 if (downstream_ && downstream_->accesslog_ready()) { in delete_downstream()
1102 handler_->write_accesslog(downstream_.get()); in delete_downstream()
1105 downstream_.reset(); in delete_downstream()
1108 Downstream *HttpsUpstream::get_downstream() const { return downstream_.get(); } in get_downstream()
1111 return std::unique_ptr<Downstream>(downstream_.release()); in pop_downstream()
1461 if (downstream_ && downstream_ in on_handler_delete()
[all...]
H A Dshrpx_downstream_connection.cc34 : client_handler_(nullptr), downstream_(nullptr) {} in DownstreamConnection()
46 Downstream *DownstreamConnection::get_downstream() { return downstream_; } in get_downstream()
H A Dshrpx_null_downstream_connection.cc43 downstream_ = downstream; in attach_downstream()
52 downstream_ = nullptr; in detach_downstream()
H A Dshrpx_downstream_connection.h76 Downstream *downstream_; member in shrpx::DownstreamConnection
H A Dshrpx_https_upstream.h105 std::unique_ptr<Downstream> downstream_; member in shrpx::HttpsUpstream

Completed in 7 milliseconds