| /third_party/nghttp2/src/ |
| D | shrpx_http2_upstream.h | 54 virtual int on_timeout(Downstream *downstream);
55 virtual int on_downstream_abort_request(Downstream *downstream,
58 on_downstream_abort_request_with_https_redirect(Downstream *downstream);
66 void add_pending_downstream(std::unique_ptr<Downstream> downstream);
67 void remove_downstream(Downstream *downstream);
69 int rst_stream(Downstream *downstream, uint32_t error_code);
71 int error_reply(Downstream *downstream, unsigned int status_code);
74 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
77 virtual int on_downstream_header_complete(Downstream *downstream);
78 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
[all …]
|
| D | shrpx_http3_upstream.h | 51 virtual int on_timeout(Downstream *downstream);
52 virtual int on_downstream_abort_request(Downstream *downstream,
55 on_downstream_abort_request_with_https_redirect(Downstream *downstream);
62 virtual int on_downstream_header_complete(Downstream *downstream);
63 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
65 virtual int on_downstream_body_complete(Downstream *downstream);
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry);
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstream, const uint8_t *body,
76 virtual int initiate_push(Downstream *downstream, const StringRef &uri);
[all …]
|
| D | shrpx_http2_upstream.cc | 67 auto downstream = static_cast<Downstream *>( in on_stream_close_callback() local
70 if (!downstream) { in on_stream_close_callback()
74 auto &req = downstream->request(); in on_stream_close_callback()
80 if (downstream->get_request_state() == DownstreamState::CONNECT_FAIL) { in on_stream_close_callback()
81 upstream->remove_downstream(downstream); in on_stream_close_callback()
82 // downstream was deleted in on_stream_close_callback()
87 if (downstream->can_detach_downstream_connection()) { in on_stream_close_callback()
89 downstream->detach_downstream_connection(); in on_stream_close_callback()
92 downstream->set_request_state(DownstreamState::STREAM_CLOSED); in on_stream_close_callback()
94 // At this point, downstream read may be paused. in on_stream_close_callback()
[all …]
|
| D | shrpx_upstream.h | 37 class Downstream; variable
45 virtual int on_timeout(Downstream *downstream) { return 0; } in on_timeout() argument
46 virtual int on_downstream_abort_request(Downstream *downstream,
51 on_downstream_abort_request_with_https_redirect(Downstream *downstream) = 0;
58 virtual int on_downstream_header_complete(Downstream *downstream) = 0;
59 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
61 virtual int on_downstream_body_complete(Downstream *downstream) = 0;
64 // Called when downstream connection for |downstream| is reset.
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
[all …]
|
| D | shrpx_downstream_queue.h | 41 class Downstream; variable
43 // Link entry in HostEntry.blocked and downstream because downstream
44 // could be deleted in anytime and we'd like to find Downstream in
45 // O(1). Downstream has field to link back to this object.
47 Downstream *downstream; member
72 // conn_max_per_host == 0 means no limit for downstream connection.
75 // Add |downstream| to this queue. This is entry point for
76 // Downstream object.
77 void add_pending(std::unique_ptr<Downstream> downstream);
78 // Set |downstream| to failure state, which means that downstream
[all …]
|
| D | shrpx_https_upstream.h | 51 virtual int on_downstream_abort_request(Downstream *downstream,
54 on_downstream_abort_request_with_https_redirect(Downstream *downstream);
62 void attach_downstream(std::unique_ptr<Downstream> downstream);
64 Downstream *get_downstream() const;
65 std::unique_ptr<Downstream> pop_downstream();
69 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
72 virtual int on_downstream_header_complete(Downstream *downstream);
73 virtual int on_downstream_body(Downstream *downstream, const uint8_t *data,
75 virtual int on_downstream_body_complete(Downstream *downstream);
78 virtual int on_downstream_reset(Downstream *downstream, bool no_retry);
[all …]
|
| D | shrpx_https_upstream.cc | 113 auto downstream = in on_start_request() local
114 std::make_unique<Downstream>(this, handler_->get_mcpool(), 0); in on_start_request()
116 attach_downstream(std::move(downstream)); in on_start_request()
136 auto downstream = upstream->get_downstream(); in htp_uricb() local
137 auto &req = downstream->request(); in htp_uricb()
139 auto &balloc = downstream->get_block_allocator(); in htp_uricb()
150 assert(downstream->get_request_state() == DownstreamState::INITIAL); in htp_uricb()
151 downstream->set_request_state( in htp_uricb()
173 auto downstream = upstream->get_downstream(); in htp_hdr_keycb() local
174 auto &req = downstream->request(); in htp_hdr_keycb()
[all …]
|
| D | shrpx_http3_upstream.cc | 252 auto downstream = in http_begin_request_headers() local
253 std::make_unique<Downstream>(this, handler_->get_mcpool(), stream_id); in http_begin_request_headers()
254 nghttp3_conn_set_stream_user_data(httpconn_, stream_id, downstream.get()); in http_begin_request_headers()
256 downstream->reset_upstream_rtimer(); in http_begin_request_headers()
257 downstream->repeat_header_timer(); in http_begin_request_headers()
261 auto &req = downstream->request(); in http_begin_request_headers()
265 add_pending_downstream(std::move(downstream)); in http_begin_request_headers()
269 std::unique_ptr<Downstream> downstream) { in add_pending_downstream() argument
270 downstream_queue_.add_pending(std::move(downstream)); in add_pending_downstream()
975 int Http3Upstream::on_timeout(Downstream *downstream) { in on_timeout() argument
[all …]
|
| D | shrpx_downstream.cc | 50 auto downstream = static_cast<Downstream *>(w->data); in header_timeoutcb() local
51 auto upstream = downstream->get_upstream(); in header_timeoutcb()
54 DLOG(INFO, downstream) << "request header timeout stream_id=" in header_timeoutcb()
55 << downstream->get_stream_id(); in header_timeoutcb()
58 downstream->disable_upstream_rtimer(); in header_timeoutcb()
59 downstream->disable_upstream_wtimer(); in header_timeoutcb()
61 upstream->on_timeout(downstream); in header_timeoutcb()
67 auto downstream = static_cast<Downstream *>(w->data); in upstream_timeoutcb() local
68 auto upstream = downstream->get_upstream(); in upstream_timeoutcb()
73 DLOG(INFO, downstream) << "upstream timeout stream_id=" in upstream_timeoutcb()
[all …]
|
| D | shrpx_downstream_queue.cc | 51 void DownstreamQueue::add_pending(std::unique_ptr<Downstream> downstream) { in add_pending() argument
52 downstream->set_dispatch_state(DispatchState::PENDING); in add_pending()
53 downstreams_.append(downstream.release()); in add_pending()
56 void DownstreamQueue::mark_failure(Downstream *downstream) { in mark_failure() argument
57 downstream->set_dispatch_state(DispatchState::FAILURE); in mark_failure()
82 StringRef DownstreamQueue::make_host_key(Downstream *downstream) const { in make_host_key()
83 return make_host_key(downstream->request().authority); in make_host_key()
86 void DownstreamQueue::mark_active(Downstream *downstream) { in mark_active() argument
87 auto &ent = find_host_entry(make_host_key(downstream)); in mark_active()
90 downstream->set_dispatch_state(DispatchState::ACTIVE); in mark_active()
[all …]
|
| D | shrpx_mruby_module_env.cc | 62 auto downstream = data->downstream; in env_get_ctx() local
64 auto dsym = intern_ptr(mrb, downstream); in env_get_ctx()
87 auto downstream = data->downstream; in env_get_remote_addr() local
88 auto upstream = downstream->get_upstream(); in env_get_remote_addr()
100 auto downstream = data->downstream; in env_get_server_port() local
101 auto upstream = downstream->get_upstream(); in env_get_server_port()
112 auto downstream = data->downstream; in env_get_server_addr() local
113 auto upstream = downstream->get_upstream(); in env_get_server_addr()
124 auto downstream = data->downstream; in env_get_tls_used() local
125 auto upstream = downstream->get_upstream(); in env_get_tls_used()
[all …]
|
| D | shrpx_mruby_module_request.cc | 52 auto downstream = data->downstream; in request_get_http_version_major() local
53 const auto &req = downstream->request(); in request_get_http_version_major()
61 auto downstream = data->downstream; in request_get_http_version_minor() local
62 const auto &req = downstream->request(); in request_get_http_version_minor()
70 auto downstream = data->downstream; in request_get_method() local
71 const auto &req = downstream->request(); in request_get_method()
81 auto downstream = data->downstream; in request_set_method() local
82 auto &req = downstream->request(); in request_set_method()
107 auto downstream = data->downstream; in request_get_authority() local
108 const auto &req = downstream->request(); in request_get_authority()
[all …]
|
| D | shrpx_mruby_module_response.cc | 52 auto downstream = data->downstream; in response_get_http_version_major() local
53 const auto &resp = downstream->response(); in response_get_http_version_major()
61 auto downstream = data->downstream; in response_get_http_version_minor() local
62 const auto &resp = downstream->response(); in response_get_http_version_minor()
70 auto downstream = data->downstream; in response_get_status() local
71 const auto &resp = downstream->response(); in response_get_status()
79 auto downstream = data->downstream; in response_set_status() local
80 auto &resp = downstream->response(); in response_set_status()
99 auto downstream = data->downstream; in response_get_headers() local
100 const auto &resp = downstream->response(); in response_get_headers()
[all …]
|
| D | shrpx_http_downstream_connection.cc | 69 auto downstream = dconn->get_downstream(); in timeoutcb() local
70 auto upstream = downstream->get_upstream(); in timeoutcb()
72 auto &resp = downstream->response(); in timeoutcb()
77 if (upstream->downstream_error(dconn, Downstream::EVENT_TIMEOUT) != 0) { in timeoutcb()
84 void retry_downstream_connection(Downstream *downstream, in retry_downstream_connection() argument
86 auto upstream = downstream->get_upstream(); in retry_downstream_connection()
89 assert(!downstream->get_request_header_sent()); in retry_downstream_connection()
91 downstream->add_retry(); in retry_downstream_connection()
93 if (downstream->no_more_retry()) { in retry_downstream_connection()
98 downstream->pop_downstream_connection(); in retry_downstream_connection()
[all …]
|
| D | shrpx_http2_session.cc | 290 auto downstream = dc->get_downstream(); in disconnect() local
291 auto upstream = downstream->get_upstream(); in disconnect()
295 if (upstream->on_downstream_reset(downstream, hard) != 0) { in disconnect()
394 auto &downstreamconf = *get_config()->conn.downstream; in initiate_connection()
458 SSLOG(INFO, this) << "Connecting to downstream server"; in initiate_connection()
741 SSLOG(INFO, this) << "Remove downstream"; in remove_downstream_connection()
805 auto downstream = dconn->get_downstream(); in resume_data() local
807 downstream->get_downstream_stream_id()); in resume_data()
821 Downstream *downstream) { in call_downstream_readcb() argument
822 auto upstream = downstream->get_upstream(); in call_downstream_readcb()
[all …]
|
| D | shrpx_mruby.h | 41 class Downstream; variable
50 int run_on_request_proc(Downstream *downstream);
51 int run_on_response_proc(Downstream *downstream);
53 int run_app(Downstream *downstream, int phase);
55 void delete_downstream(Downstream *downstream);
70 Downstream *downstream; member
|
| D | shrpx_null_downstream_connection.cc | 38 int NullDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream() argument
40 DCLOG(INFO, this) << "Attaching to DOWNSTREAM:" << downstream; in attach_downstream()
43 downstream_ = downstream; in attach_downstream()
48 void NullDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream() argument
50 DCLOG(INFO, this) << "Detaching from DOWNSTREAM:" << downstream; in detach_downstream()
|
| D | shrpx_http2_downstream_connection.cc | 95 int Http2DownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream() argument
97 DCLOG(INFO, this) << "Attaching to DOWNSTREAM:" << downstream; in attach_downstream()
102 downstream_ = downstream; in attach_downstream()
115 void Http2DownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream() argument
117 DCLOG(INFO, this) << "Detaching from DOWNSTREAM:" << downstream; in detach_downstream()
123 if (submit_rst_stream(downstream) == 0) { in detach_downstream()
135 downstream->disable_downstream_rtimer(); in detach_downstream()
136 downstream->disable_downstream_wtimer(); in detach_downstream()
140 int Http2DownstreamConnection::submit_rst_stream(Downstream *downstream, in submit_rst_stream() argument
144 downstream->get_downstream_stream_id() != -1) { in submit_rst_stream()
[all …]
|
| D | shrpx_health_monitor_downstream_connection.cc | 39 Downstream *downstream) { in attach_downstream() argument
41 DCLOG(INFO, this) << "Attaching to DOWNSTREAM:" << downstream; in attach_downstream()
44 downstream_ = downstream; in attach_downstream()
50 Downstream *downstream) { in detach_downstream() argument
52 DCLOG(INFO, this) << "Detaching from DOWNSTREAM:" << downstream; in detach_downstream()
|
| D | shrpx_client_handler.h | 59 class Downstream; variable
117 Downstream *downstream);
123 get_downstream_connection(int &err, Downstream *downstream);
138 // Writes upstream accesslog using |downstream|. The |downstream|
140 void write_accesslog(Downstream *downstream);
178 // Returns an affinity cookie value for |downstream|. |cookie_name|
180 uint32_t get_affinity_cookie(Downstream *downstream,
185 Downstream *downstream);
|
| D | shrpx_mruby.cc | 49 int MRubyContext::run_app(Downstream *downstream, int phase) { in run_app() argument
54 MRubyAssocData data{downstream, phase}; in run_app()
86 if (downstream->get_response_state() != DownstreamState::MSG_COMPLETE) { in run_app()
102 int MRubyContext::run_on_request_proc(Downstream *downstream) { in run_on_request_proc() argument
103 return run_app(downstream, PHASE_REQUEST); in run_on_request_proc()
106 int MRubyContext::run_on_response_proc(Downstream *downstream) { in run_on_response_proc() argument
107 return run_app(downstream, PHASE_RESPONSE); in run_on_response_proc()
110 void MRubyContext::delete_downstream(Downstream *downstream) { in delete_downstream() argument
114 delete_downstream_from_module(mrb_, downstream); in delete_downstream()
|
| D | shrpx_downstream_connection.h | 38 class Downstream; variable
46 virtual int attach_downstream(Downstream *downstream) = 0;
47 virtual void detach_downstream(Downstream *downstream) = 0;
72 Downstream *get_downstream();
76 Downstream *downstream_;
|
| D | shrpx_http2_session.h | 58 class Downstream; variable
88 // Connecting to downstream and/or performing SSL/TLS handshake
90 // Connected to downstream
180 // Returns true if request can be issued on downstream connection.
181 bool can_push_request(const Downstream *downstream) const;
182 // Initiates the connection checking if downstream connection has
205 int handle_downstream_push_promise(Downstream *downstream,
207 int handle_downstream_push_promise_complete(Downstream *downstream,
208 Downstream *promised_downstream);
210 // Returns number of downstream connections, including pushed
|
| D | shrpx_http2_downstream_connection.h | 53 virtual int attach_downstream(Downstream *downstream);
54 virtual void detach_downstream(Downstream *downstream);
83 int submit_rst_stream(Downstream *downstream,
|
| D | shrpx_api_downstream_connection.cc | 75 int APIDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream() argument
77 DCLOG(INFO, this) << "Attaching to DOWNSTREAM:" << downstream; in attach_downstream()
80 downstream_ = downstream; in attach_downstream()
85 void APIDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream() argument
87 DCLOG(INFO, this) << "Detaching from DOWNSTREAM:" << downstream; in detach_downstream()
355 new_config.conn.downstream = std::make_shared<DownstreamConfig>(); in handle_backendconfig()
356 const auto &downstreamconf = new_config.conn.downstream; in handle_backendconfig()
359 auto &src = config->conn.downstream; in handle_backendconfig()
|