| /third_party/nghttp2/src/ |
| 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()
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()
98 upstream->remove_downstream(downstream); in on_stream_close_callback()
131 auto downstream = http->pop_downstream(); in upgrade_upstream() local
[all …]
|
| D | shrpx_https_upstream.cc | 113 auto downstream = in on_start_request() local
116 attach_downstream(std::move(downstream)); in on_start_request()
139 auto downstream = upstream->get_downstream(); in htp_uricb() local
140 auto &req = downstream->request(); in htp_uricb()
142 auto &balloc = downstream->get_block_allocator(); in htp_uricb()
153 assert(downstream->get_request_state() == DownstreamState::INITIAL); in htp_uricb()
154 downstream->set_request_state( in htp_uricb()
176 auto downstream = upstream->get_downstream(); in htp_hdr_keycb() local
177 auto &req = downstream->request(); in htp_hdr_keycb()
185 if (downstream->get_request_state() == DownstreamState::INITIAL) { in htp_hdr_keycb()
[all …]
|
| D | shrpx_http3_upstream.cc | 247 auto downstream = in http_begin_request_headers() local
249 nghttp3_conn_set_stream_user_data(httpconn_, stream_id, downstream.get()); in http_begin_request_headers()
251 downstream->reset_upstream_rtimer(); in http_begin_request_headers()
255 auto &req = downstream->request(); in http_begin_request_headers()
259 add_pending_downstream(std::move(downstream)); in http_begin_request_headers()
263 std::unique_ptr<Downstream> downstream) { in add_pending_downstream() argument
264 downstream_queue_.add_pending(std::move(downstream)); in add_pending_downstream()
969 int Http3Upstream::on_timeout(Downstream *downstream) { return 0; } in on_timeout() argument
971 int Http3Upstream::on_downstream_abort_request(Downstream *downstream, in on_downstream_abort_request() argument
975 rv = error_reply(downstream, status_code); in on_downstream_abort_request()
[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_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_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_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_http2_session.cc | 283 auto downstream = dc->get_downstream(); in disconnect() local
284 auto upstream = downstream->get_upstream(); in disconnect()
288 if (upstream->on_downstream_reset(downstream, hard) != 0) { in disconnect()
387 auto &downstreamconf = *get_config()->conn.downstream; in initiate_connection()
798 auto downstream = dconn->get_downstream(); in resume_data() local
800 downstream->get_downstream_stream_id()); in resume_data()
814 Downstream *downstream) { in call_downstream_readcb() argument
815 auto upstream = downstream->get_upstream(); in call_downstream_readcb()
819 if (upstream->downstream_read(downstream->get_downstream_connection()) != 0) { in call_downstream_readcb()
843 auto downstream = dconn->get_downstream(); in on_stream_close_callback() local
[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_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_http_downstream_connection.cc | 63 auto downstream = dconn->get_downstream(); in timeoutcb() local
64 auto upstream = downstream->get_upstream(); in timeoutcb()
66 auto &resp = downstream->response(); in timeoutcb()
78 void retry_downstream_connection(Downstream *downstream, in retry_downstream_connection() argument
80 auto upstream = downstream->get_upstream(); in retry_downstream_connection()
83 assert(!downstream->get_request_header_sent()); in retry_downstream_connection()
85 downstream->add_retry(); in retry_downstream_connection()
87 if (downstream->no_more_retry()) { in retry_downstream_connection()
92 downstream->pop_downstream_connection(); in retry_downstream_connection()
93 auto buf = downstream->get_request_buf(); in retry_downstream_connection()
[all …]
|
| D | shrpx_upstream.h | 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;
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,
79 virtual int initiate_push(Downstream *downstream, const StringRef &uri) = 0;
[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);
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);
79 virtual int send_reply(Downstream *downstream, const uint8_t *body,
81 virtual int initiate_push(Downstream *downstream, const StringRef &uri);
[all …]
|
| 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_downstream_queue.h | 47 Downstream *downstream; member
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,
100 StringRef make_host_key(Downstream *downstream) const;
|
| 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_mruby.h | 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_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 | 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_api_downstream_connection.cc | 81 int APIDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream() argument
83 DCLOG(INFO, this) << "Attaching to DOWNSTREAM:" << downstream; in attach_downstream()
86 downstream_ = downstream; in attach_downstream()
91 void APIDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream() argument
93 DCLOG(INFO, this) << "Detaching from DOWNSTREAM:" << downstream; in detach_downstream()
362 new_config.conn.downstream = std::make_shared<DownstreamConfig>(); in handle_backendconfig()
363 const auto &downstreamconf = new_config.conn.downstream; in handle_backendconfig()
366 auto &src = config->conn.downstream; in handle_backendconfig()
|
| 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_client_handler.cc | 807 uint32_t ClientHandler::get_affinity_cookie(Downstream *downstream, in get_affinity_cookie() argument
809 auto h = downstream->find_affinity_cookie(cookie_name); in get_affinity_cookie()
819 downstream->renew_affinity_cookie(h); in get_affinity_cookie()
854 Downstream *downstream) { in get_downstream_addr() argument
881 downstream); in get_downstream_addr()
884 hash = get_affinity_cookie(downstream, shared_addr->affinity.cookie.name); in get_downstream_addr()
962 Downstream *downstream) { in get_downstream_addr_strict_affinity() argument
965 auto h = downstream->find_affinity_cookie(shared_addr->affinity.cookie.name); in get_downstream_addr_strict_affinity()
1017 downstream->renew_affinity_cookie(addr->affinity_hash); in get_downstream_addr_strict_affinity()
1023 ClientHandler::get_downstream_connection(int &err, Downstream *downstream) { in get_downstream_connection() argument
[all …]
|
| /third_party/flutter/flutter/packages/flutter/test/painting/ |
| D | text_painter_rtl_test.dart | 24 painter.getWordBoundary(const TextPosition(offset: 1, affinity: TextAffinity.downstream)),
28 painter.getWordBoundary(const TextPosition(offset: 5, affinity: TextAffinity.downstream)),
32 painter.getWordBoundary(const TextPosition(offset: 9, affinity: TextAffinity.downstream)),
53 …ebrew1 = painter.getWordBoundary(const TextPosition(offset: 4, affinity: TextAffinity.downstream));
55 …lish2 = painter.getWordBoundary(const TextPosition(offset: 14, affinity: TextAffinity.downstream));
57 …brew3 = painter.getWordBoundary(const TextPosition(offset: 24, affinity: TextAffinity.downstream));
75 …painter.getOffsetForCaret(const TextPosition(offset: 0, affinity: TextAffinity.downstream), Rect.z…
83 …painter.getOffsetForCaret(const TextPosition(offset: 1, affinity: TextAffinity.downstream), Rect.z…
91 …painter.getOffsetForCaret(const TextPosition(offset: 7, affinity: TextAffinity.downstream), Rect.z…
99 …painter.getOffsetForCaret(const TextPosition(offset: 8, affinity: TextAffinity.downstream), Rect.z…
[all …]
|
| /third_party/node/tools/inspector_protocol/ |
| D | roll.py | 108 downstream = os.path.normpath(os.path.expanduser(
111 CheckRepoIsClean(downstream, '/v8')
113 CheckRepoIsV8Checkout(downstream)
117 CheckRepoIsNotAtMasterBranch(downstream)
119 dest_dir = os.path.join(downstream, 'third_party/inspector_protocol')
|