| /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_downstream.cc | 50 auto downstream = static_cast<Downstream *>(w->data); in upstream_timeoutcb()
81 auto downstream = static_cast<Downstream *>(w->data); in downstream_timeoutcb()
115 Downstream::Downstream(Upstream *upstream, MemchunkPool *mcpool, in Downstream() function in shrpx::Downstream
173 Downstream::~Downstream() { in ~Downstream()
225 int Downstream::attach_downstream_connection( in attach_downstream_connection()
236 void Downstream::detach_downstream_connection() { in detach_downstream_connection()
257 DownstreamConnection *Downstream::get_downstream_connection() { in get_downstream_connection()
261 std::unique_ptr<DownstreamConnection> Downstream::pop_downstream_connection() { in pop_downstream_connection()
277 void Downstream::pause_read(IOCtrlReason reason) { in pause_read()
283 int Downstream::resume_read(IOCtrlReason reason, size_t consumed) { in resume_read()
[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_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_upstream.h | 37 class Downstream; variable
45 virtual int on_timeout(Downstream *downstream) { return 0; }; in on_timeout()
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;
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstream, const uint8_t *body,
[all …]
|
| D | shrpx_downstream_queue.h | 41 class Downstream; variable
47 Downstream *downstream;
77 void add_pending(std::unique_ptr<Downstream> downstream);
80 void mark_failure(Downstream *downstream);
83 void mark_active(Downstream *downstream);
86 void mark_blocked(Downstream *downstream);
95 Downstream *remove_and_get_blocked(Downstream *downstream,
97 Downstream *get_downstreams() const;
100 StringRef make_host_key(Downstream *downstream) const;
106 DList<Downstream> downstreams_;
|
| 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;
|
| D | shrpx_downstream_queue.cc | 51 void DownstreamQueue::add_pending(std::unique_ptr<Downstream> downstream) { in add_pending()
56 void DownstreamQueue::mark_failure(Downstream *downstream) { in mark_failure()
82 StringRef DownstreamQueue::make_host_key(Downstream *downstream) const { in make_host_key()
86 void DownstreamQueue::mark_active(Downstream *downstream) { in mark_active()
93 void DownstreamQueue::mark_blocked(Downstream *downstream) { in mark_blocked()
124 Downstream *DownstreamQueue::remove_and_get_blocked(Downstream *downstream, in remove_and_get_blocked()
127 auto delptr = std::unique_ptr<Downstream>(downstream); in remove_and_get_blocked()
171 Downstream *DownstreamQueue::get_downstreams() const { in get_downstreams()
|
| 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_client_handler.h | 52 class Downstream; variable
110 Downstream *downstream);
116 get_downstream_connection(int &err, Downstream *downstream);
133 void write_accesslog(Downstream *downstream);
173 uint32_t get_affinity_cookie(Downstream *downstream,
178 Downstream *downstream);
|
| D | shrpx_http2_upstream.cc | 67 auto downstream = static_cast<Downstream *>( in on_stream_close_callback()
177 auto downstream = static_cast<Downstream *>( in on_header_callback2()
239 auto downstream = static_cast<Downstream *>( in on_invalid_header_callback2()
281 auto downstream = std::make_unique<Downstream>(this, handler_->get_mcpool(), in on_start_request()
308 int Http2Upstream::on_request_headers(Downstream *downstream, in on_request_headers()
457 void Http2Upstream::start_downstream(Downstream *downstream) { in start_downstream()
466 void Http2Upstream::initiate_downstream(Downstream *downstream) { in initiate_downstream()
556 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback()
577 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback()
633 auto downstream = static_cast<Downstream *>( in on_data_chunk_recv_callback()
[all …]
|
| D | shrpx_https_upstream.cc | 114 std::make_unique<Downstream>(this, handler_->get_mcpool(), 0); in on_start_request()
812 int HttpsUpstream::resume_read(IOCtrlReason reason, Downstream *downstream, in resume_read()
850 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
878 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_write()
934 if (events & Downstream::EVENT_ERROR) { in downstream_error()
945 if (events & Downstream::EVENT_TIMEOUT) { in downstream_error()
962 int HttpsUpstream::send_reply(Downstream *downstream, const uint8_t *body, in send_reply()
1041 std::make_unique<Downstream>(this, handler_->get_mcpool(), 1)); in error_reply()
1080 void HttpsUpstream::attach_downstream(std::unique_ptr<Downstream> downstream) { in attach_downstream()
1093 Downstream *HttpsUpstream::get_downstream() const { return downstream_.get(); } in get_downstream()
[all …]
|
| D | shrpx_http3_upstream.cc | 248 std::make_unique<Downstream>(this, handler_->get_mcpool(), stream_id); in http_begin_request_headers()
263 std::unique_ptr<Downstream> downstream) { in add_pending_downstream()
997 int Http3Upstream::on_timeout(Downstream *downstream) { return 0; } in on_timeout()
999 int Http3Upstream::on_downstream_abort_request(Downstream *downstream, in on_downstream_abort_request()
1015 Downstream *downstream) { in on_downstream_abort_request_with_https_redirect()
1077 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
1097 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_write()
1149 if (events & Downstream::EVENT_ERROR) { in downstream_error()
1183 if (events & Downstream::EVENT_TIMEOUT) { in downstream_error()
1212 auto downstream = static_cast<Downstream *>(stream_user_data); in downstream_read_data_callback()
[all …]
|
| D | shrpx_http2_session.h | 51 class Downstream; variable
174 bool can_push_request(const Downstream *downstream) const;
198 int handle_downstream_push_promise(Downstream *downstream,
200 int handle_downstream_push_promise_complete(Downstream *downstream,
201 Downstream *promised_downstream);
|
| D | shrpx_http2_downstream_connection.h | 46 virtual int attach_downstream(Downstream *downstream);
47 virtual void detach_downstream(Downstream *downstream);
76 int submit_rst_stream(Downstream *downstream,
|
| D | shrpx_mruby.cc | 49 int MRubyContext::run_app(Downstream *downstream, int phase) { in run_app()
102 int MRubyContext::run_on_request_proc(Downstream *downstream) { in run_on_request_proc()
106 int MRubyContext::run_on_response_proc(Downstream *downstream) { in run_on_response_proc()
110 void MRubyContext::delete_downstream(Downstream *downstream) { in delete_downstream()
|
| D | shrpx_downstream_test.cc | 86 Downstream d(nullptr, nullptr, 0); in test_downstream_crumble_request_cookie()
131 Downstream d(nullptr, nullptr, 0); in test_downstream_assemble_request_cookie()
154 Downstream d(nullptr, nullptr, 0); in test_downstream_rewrite_location_response_header()
168 Downstream d(nullptr, nullptr, 0); in test_downstream_supports_non_final_response()
198 Downstream d(nullptr, nullptr, 0); in test_downstream_find_affinity_cookie()
|
| D | shrpx_mruby_module.h | 38 class Downstream; variable
44 void delete_downstream_from_module(mrb_state *mrb, Downstream *downstream);
|
| D | shrpx_health_monitor_downstream_connection.h | 38 virtual int attach_downstream(Downstream *downstream);
39 virtual void detach_downstream(Downstream *downstream);
|
| D | shrpx_null_downstream_connection.h | 39 virtual int attach_downstream(Downstream *downstream);
40 virtual void detach_downstream(Downstream *downstream);
|
| D | shrpx_null_downstream_connection.cc | 38 int NullDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
48 void NullDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
|
| D | shrpx_api_downstream_connection.h | 70 virtual int attach_downstream(Downstream *downstream);
71 virtual void detach_downstream(Downstream *downstream);
|
| D | shrpx_health_monitor_downstream_connection.cc | 39 Downstream *downstream) { in attach_downstream()
50 Downstream *downstream) { in detach_downstream()
|
| D | shrpx_http_downstream_connection.cc | 71 if (upstream->downstream_error(dconn, Downstream::EVENT_TIMEOUT) != 0) { in timeoutcb()
78 void retry_downstream_connection(Downstream *downstream, in retry_downstream_connection()
144 void backend_retry(Downstream *downstream) { in backend_retry()
237 int HttpDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
864 void HttpDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
909 auto downstream = static_cast<Downstream *>(htp->data); in htp_msg_begincb()
921 auto downstream = static_cast<Downstream *>(htp->data); in htp_hdrs_completecb()
1056 int ensure_header_field_buffer(const Downstream *downstream, in ensure_header_field_buffer()
1073 int ensure_max_header_fields(const Downstream *downstream, in ensure_max_header_fields()
1091 auto downstream = static_cast<Downstream *>(htp->data); in htp_hdr_keycb()
[all …]
|
| D | shrpx_http_downstream_connection.h | 50 virtual int attach_downstream(Downstream *downstream);
51 virtual void detach_downstream(Downstream *downstream);
|