Home
last modified time | relevance | path

Searched refs:upstream (Results 1 - 25 of 42) sorted by relevance

12

/third_party/nghttp2/src/
H A Dshrpx_mruby_module_env.cc88 auto upstream = downstream->get_upstream(); in env_get_remote_addr() local
89 auto handler = upstream->get_client_handler(); in env_get_remote_addr()
101 auto upstream = downstream->get_upstream(); in env_get_server_port() local
102 auto handler = upstream->get_client_handler(); in env_get_server_port()
113 auto upstream = downstream->get_upstream(); in env_get_server_addr() local
114 auto handler = upstream->get_client_handler(); in env_get_server_addr()
125 auto upstream = downstream->get_upstream(); in env_get_tls_used() local
126 auto handler = upstream->get_client_handler(); in env_get_tls_used()
136 auto upstream = downstream->get_upstream(); in env_get_tls_sni() local
137 auto handler = upstream in env_get_tls_sni()
148 auto upstream = downstream->get_upstream(); env_get_tls_client_fingerprint_md() local
200 auto upstream = downstream->get_upstream(); env_get_tls_client_subject_name() local
230 auto upstream = downstream->get_upstream(); env_get_tls_client_issuer_name() local
260 auto upstream = downstream->get_upstream(); env_get_tls_client_serial() local
290 auto upstream = downstream->get_upstream(); env_get_tls_client_not_before() local
324 auto upstream = downstream->get_upstream(); env_get_tls_client_not_after() local
358 auto upstream = downstream->get_upstream(); env_get_tls_cipher() local
374 auto upstream = downstream->get_upstream(); env_get_tls_protocol() local
390 auto upstream = downstream->get_upstream(); env_get_tls_session_id() local
417 auto upstream = downstream->get_upstream(); env_get_tls_session_reused() local
433 auto upstream = downstream->get_upstream(); env_get_alpn() local
444 auto upstream = downstream->get_upstream(); env_get_tls_handshake_finished() local
[all...]
H A Dshrpx_http2_upstream.cc61 auto upstream = static_cast<Http2Upstream *>(user_data); in on_stream_close_callback() local
63 ULOG(INFO, upstream) << "Stream stream_id=" << stream_id in on_stream_close_callback()
76 upstream->consume(stream_id, req.unconsumed_body_length); in on_stream_close_callback()
81 upstream->remove_downstream(downstream); in on_stream_close_callback()
98 upstream->remove_downstream(downstream); in on_stream_close_callback()
169 if (config->http2.upstream.debug.frame_debug) { in on_header_callback2()
176 auto upstream = static_cast<Http2Upstream *>(user_data); in on_header_callback2() local
195 ULOG(INFO, upstream) << "Too large or many header field size=" in on_header_callback2()
205 if (upstream->error_reply(downstream, 431) != 0) { in on_header_callback2()
238 auto upstream in on_invalid_header_callback2() local
264 auto upstream = static_cast<Http2Upstream *>(user_data); on_begin_headers_callback() local
551 auto upstream = static_cast<Http2Upstream *>(user_data); on_frame_recv_callback() local
632 auto upstream = static_cast<Http2Upstream *>(user_data); on_data_chunk_recv_callback() local
668 auto upstream = static_cast<Http2Upstream *>(user_data); on_frame_send_callback() local
812 auto upstream = static_cast<Http2Upstream *>(user_data); on_frame_not_send_callback() local
842 auto upstream = static_cast<Http2Upstream *>(downstream->get_upstream()); send_data_callback() local
895 auto upstream = static_cast<Http2Upstream *>(w->data); settings_timeout_cb() local
908 auto upstream = static_cast<Http2Upstream *>(w->data); shutdown_timeout_cb() local
917 auto upstream = static_cast<Http2Upstream *>(w->data); prepare_cb() local
1448 auto upstream = static_cast<Http2Upstream *>(user_data); downstream_data_read_callback() local
[all...]
H A Dshrpx_http3_upstream.cc54 auto upstream = static_cast<Http3Upstream *>(w->data); in timeoutcb() local
56 if (upstream->handle_expiry() != 0 || upstream->on_write() != 0) { in timeoutcb()
63 auto handler = upstream->get_client_handler(); in timeoutcb()
71 auto upstream = static_cast<Http3Upstream *>(w->data); in shutdown_timeout_cb() local
72 auto handler = upstream->get_client_handler(); in shutdown_timeout_cb()
74 if (upstream->submit_goaway() != 0) { in shutdown_timeout_cb()
82 auto upstream = static_cast<Http3Upstream *>(w->data); in prepare_cb() local
83 auto handler = upstream->get_client_handler(); in prepare_cb()
85 if (upstream in prepare_cb()
107 auto upstream = static_cast<Http3Upstream *>(handler->get_upstream()); get_conn() local
179 auto upstream = static_cast<Http3Upstream *>(user_data); qlog_write() local
207 auto upstream = static_cast<Http3Upstream *>(user_data); get_new_connection_id() local
235 auto upstream = static_cast<Http3Upstream *>(user_data); remove_connection_id() local
271 auto upstream = static_cast<Http3Upstream *>(user_data); recv_stream_data() local
306 auto upstream = static_cast<Http3Upstream *>(user_data); stream_close() local
348 auto upstream = static_cast<Http3Upstream *>(user_data); acked_stream_data_offset() local
378 auto upstream = static_cast<Http3Upstream *>(user_data); extend_max_stream_data() local
406 auto upstream = static_cast<Http3Upstream *>(user_data); extend_max_remote_streams_bidi() local
422 auto upstream = static_cast<Http3Upstream *>(user_data); stream_reset() local
469 auto upstream = static_cast<Http3Upstream *>(user_data); stream_stop_sending() local
481 auto upstream = static_cast<Http3Upstream *>(user_data); handshake_completed() local
514 auto upstream = static_cast<Http3Upstream *>(user_data); path_validation() local
559 auto upstream = static_cast<Http3Upstream *>(user_data); recv_tx_key() local
1230 auto upstream = static_cast<Http3Upstream *>(conn_user_data); downstream_read_data_callback() local
2022 auto upstream = static_cast<Http3Upstream *>(user_data); http_deferred_consume() local
2034 auto upstream = static_cast<Http3Upstream *>(user_data); http_acked_stream_data() local
2074 auto upstream = static_cast<Http3Upstream *>(user_data); http_begin_request_headers() local
2086 auto upstream = static_cast<Http3Upstream *>(user_data); http_recv_request_header() local
2107 auto upstream = static_cast<Http3Upstream *>(user_data); http_recv_request_trailer() local
2183 auto upstream = static_cast<Http3Upstream *>(user_data); http_end_request_headers() local
2426 auto upstream = static_cast<Http3Upstream *>(user_data); http_recv_data() local
2457 auto upstream = static_cast<Http3Upstream *>(user_data); http_end_stream() local
2490 auto upstream = static_cast<Http3Upstream *>(conn_user_data); http_stream_close() local
2556 auto upstream = static_cast<Http3Upstream *>(user_data); http_stop_sending() local
2583 auto upstream = static_cast<Http3Upstream *>(user_data); http_reset_stream() local
[all...]
H A Dshrpx_https_upstream.cc119 auto &upstreamconf = get_config()->conn.upstream; in on_start_request()
130 auto upstream = static_cast<HttpsUpstream *>(htp->data); in htp_msg_begin() local
131 upstream->on_start_request(); in htp_msg_begin()
138 auto upstream = static_cast<HttpsUpstream *>(htp->data); in htp_uricb() local
139 auto downstream = upstream->get_downstream(); in htp_uricb()
150 ULOG(INFO, upstream) << "Too large URI size=" in htp_uricb()
175 auto upstream = static_cast<HttpsUpstream *>(htp->data); in htp_hdr_keycb() local
176 auto downstream = upstream->get_downstream(); in htp_hdr_keycb()
182 ULOG(INFO, upstream) << "Too large header block size=" in htp_hdr_keycb()
198 ULOG(INFO, upstream) in htp_hdr_keycb()
230 auto upstream = static_cast<HttpsUpstream *>(htp->data); htp_hdr_valcb() local
335 auto upstream = static_cast<HttpsUpstream *>(htp->data); htp_hdrs_completecb() local
563 auto upstream = static_cast<HttpsUpstream *>(htp->data); htp_bodycb() local
584 auto upstream = static_cast<HttpsUpstream *>(htp->data); htp_msg_completecb() local
[all...]
H A Dshrpx_http_downstream_connection.cc64 auto upstream = downstream->get_upstream(); in timeoutcb() local
65 auto handler = upstream->get_client_handler(); in timeoutcb()
71 if (upstream->downstream_error(dconn, Downstream::EVENT_TIMEOUT) != 0) { in timeoutcb()
80 auto upstream = downstream->get_upstream(); in retry_downstream_connection() local
81 auto handler = upstream->get_client_handler(); in retry_downstream_connection()
114 rv = upstream->on_downstream_abort_request_with_https_redirect(downstream); in retry_downstream_connection()
116 rv = upstream->on_downstream_abort_request(downstream, status_code); in retry_downstream_connection()
155 auto upstream = downstream->get_upstream(); in readcb() local
156 auto handler = upstream->get_client_handler(); in readcb()
158 rv = upstream in readcb()
176 auto upstream = downstream->get_upstream(); writecb() local
596 auto upstream = downstream_->get_upstream(); push_request_headers() local
922 auto upstream = downstream->get_upstream(); htp_hdrs_completecb() local
1238 auto upstream = downstream_->get_upstream(); write_first() local
1290 auto upstream = downstream_->get_upstream(); write_clear() local
1423 auto upstream = downstream_->get_upstream(); write_tls() local
1593 on_upstream_change(Upstream *upstream) on_upstream_change() argument
[all...]
H A Dshrpx_http2_session.cc274 // ClientHandler object if upstream is h2. So be careful when you in disconnect()
284 auto upstream = downstream->get_upstream(); in disconnect() local
286 // Failure is allowed only for HTTP/1 upstream where upstream is in disconnect()
288 if (upstream->on_downstream_reset(downstream, hard) != 0) { in disconnect()
289 delete upstream->get_client_handler(); in disconnect()
815 auto upstream = downstream->get_upstream(); in call_downstream_readcb() local
816 if (!upstream) { in call_downstream_readcb()
819 if (upstream->downstream_read(downstream->get_downstream_connection()) != 0) { in call_downstream_readcb()
820 delete upstream in call_downstream_readcb()
844 auto upstream = downstream->get_upstream(); on_stream_close_callback() local
1099 auto upstream = downstream->get_upstream(); on_response_headers() local
1235 auto upstream = downstream->get_upstream(); on_frame_recv_callback() local
1294 auto upstream = downstream->get_upstream(); on_frame_recv_callback() local
1450 auto upstream = downstream->get_upstream(); on_data_chunk_recv_callback() local
1542 auto upstream = downstream->get_upstream(); on_frame_not_send_callback() local
1945 auto upstream = downstream->get_upstream(); submit_pending_requests() local
2218 auto upstream = downstream->get_upstream(); handle_downstream_push_promise() local
2299 auto upstream = promised_downstream->get_upstream(); handle_downstream_push_promise_complete() local
[all...]
H A Dshrpx_health_monitor_downstream_connection.cc72 auto upstream = downstream_->get_upstream(); in end_upload_data() local
81 if (upstream->send_reply(downstream_, nullptr, 0) != 0) { in end_upload_data()
101 void HealthMonitorDownstreamConnection::on_upstream_change(Upstream *upstream) { in on_upstream_change() argument
H A Dshrpx_config.cc88 auto &upstreamconf = http2.upstream; in ~Config()
99 auto &dumpconf = http2.upstream.debug.dump; in ~Config()
894 // Parses upstream configuration parameter |src_params|, and stores
2973 http2conf.upstream.max_concurrent_streams = n; in parse_config()
3019 return parse_duration(&config->conn.upstream.timeout.http2_read, opt, in parse_config()
3022 return parse_duration(&config->conn.upstream.timeout.read, opt, optarg); in parse_config()
3024 return parse_duration(&config->conn.upstream.timeout.write, opt, optarg); in parse_config()
3070 resp = &config->http2.upstream.window_size; in parse_config()
3104 resp = &config->http2.upstream.connection_window_size; in parse_config()
3320 return parse_uint_with_unit(&config->conn.upstream in parse_config()
[all...]
H A Dshrpx_client_handler.cc327 auto upstream = static_cast<Http3Upstream *>(upstream_.get()); in read_quic() local
329 return upstream->on_read(faddr, remote_addr, local_addr, pi, data, datalen); in read_quic()
446 get_config()->conn.upstream.timeout.write, in ClientHandler()
447 get_config()->conn.upstream.timeout.read, in ClientHandler()
448 get_config()->conn.upstream.ratelimit.write, in ClientHandler()
449 get_config()->conn.upstream.ratelimit.read, writecb, readcb, in ClientHandler()
477 config->conn.upstream.accept_proxy_protocol) { in ClientHandler()
548 std::unique_ptr<Http3Upstream> &&upstream) { in setup_http3_upstream()
549 upstream_ = std::move(upstream); in setup_http3_upstream()
554 reset_upstream_read_timeout(config->conn.upstream in setup_http3_upstream()
547 setup_http3_upstream( std::unique_ptr<Http3Upstream> &&upstream) setup_http3_upstream() argument
1168 auto upstream = std::make_unique<Http2Upstream>(this); perform_http2_upgrade() local
[all...]
H A Dshrpx_mruby_module_response.cc264 auto upstream = downstream->get_upstream(); in response_return() local
266 rv = upstream->send_reply(downstream, body, bodylen); in response_return()
271 auto handler = upstream->get_client_handler(); in response_return()
353 auto upstream = downstream->get_upstream(); in response_send_info() local
355 rv = upstream->on_downstream_header_complete(downstream); in response_send_info()
360 auto handler = upstream->get_client_handler(); in response_send_info()
H A Dshrpx_quic_connection_handler.cc160 auto &upstreamconf = config->conn.upstream; in handle_packet()
208 if (quicconf.upstream.require_token) { in handle_packet()
270 if (quicconf.upstream.require_token) { in handle_packet()
291 if (quicconf.upstream.require_token) { in handle_packet()
313 if (quicconf.upstream.require_token) { in handle_packet()
402 if (quicconf.upstream.early_data) { in handle_new_connection()
420 auto upstream = std::make_unique<Http3Upstream>(handler.get()); in handle_new_connection() local
421 if (upstream->init(faddr, remote_addr, local_addr, hd, odcid, token, tokenlen, in handle_new_connection()
426 handler->setup_http3_upstream(std::move(upstream)); in handle_new_connection()
H A Dshrpx.cc2016 auto &upstreamconf = http2conf.upstream; in fill_default_config()
2023 // window size for HTTP/2 upstream connection per stream. 2**16-1 in fill_default_config()
2079 auto &upstreamconf = quicconf.upstream; in fill_default_config()
2102 auto &upstreamconf = http3conf.upstream; in fill_default_config()
2136 auto &upstreamconf = connconf.upstream; in fill_default_config()
2139 // Read timeout for HTTP2 upstream connection in fill_default_config()
2142 // Read timeout for HTTP3 upstream connection in fill_default_config()
2145 // Read timeout for non-HTTP2 upstream connection in fill_default_config()
2148 // Write timeout for HTTP2/non-HTTP2 upstream connection in fill_default_config()
2151 // Keep alive timeout for HTTP/1 upstream connectio in fill_default_config()
[all...]
H A Dshrpx_health_monitor_downstream_connection.h52 virtual void on_upstream_change(Upstream *upstream);
H A Dshrpx_downstream_connection.h61 virtual void on_upstream_change(Upstream *upstream) = 0;
H A Dshrpx_null_downstream_connection.cc77 void NullDownstreamConnection::on_upstream_change(Upstream *upstream) {} in on_upstream_change() argument
H A Dshrpx_null_downstream_connection.h53 virtual void on_upstream_change(Upstream *upstream);
H A Dshrpx_downstream.cc51 auto upstream = downstream->get_upstream(); in upstream_timeoutcb() local
56 DLOG(INFO, downstream) << "upstream timeout stream_id=" in upstream_timeoutcb()
63 upstream->on_timeout(downstream); in upstream_timeoutcb()
114 // upstream could be nullptr for unittests
115 Downstream::Downstream(Upstream *upstream, MemchunkPool *mcpool, in Downstream() argument
127 upstream_(upstream), in Downstream()
609 void Downstream::reset_upstream(Upstream *upstream) { in reset_upstream() argument
610 upstream_ = upstream; in reset_upstream()
612 dconn_->on_upstream_change(upstream); in reset_upstream()
H A Dshrpx_http2_downstream_connection.h61 virtual void on_upstream_change(Upstream *upstream) {} in on_upstream_change() argument
/third_party/mesa3d/bin/
H A Dcommit_in_branch.py48 def branch_has_commit(upstream: str, branch: str, commit: str) -> bool:
53 commit, upstream + '/' + branch],
59 def branch_has_backport_of_commit(upstream: str, branch: str, commit: str) -> str:
65 branch + '-branchpoint..' + upstream + '/' + branch,
92 (upstream, _) = branch.split('/')
95 if line.startswith(upstream + '\t'):
99 raise argparse.ArgumentTypeError('Invalid remote: ' + upstream)
128 (upstream, branch) = args.branch.split('/')
130 if branch_has_commit(upstream, branch, args.commit):
134 backport = branch_has_backport_of_commit(upstream, branc
[all...]
H A Dcommit_in_branch_test.py15 # Let's assume main is bound to the upstream remote and not a fork
17 '--format=%(upstream)',
99 upstream = get_upstream()
100 assert branch_has_commit(upstream, branch, commit) == expected
115 upstream = get_upstream()
116 assert branch_has_backport_of_commit(upstream, branch, commit) == expected
/third_party/node/deps/undici/src/lib/
H A Dbalanced-pool.js61 for (const upstream of upstreams) {
62 this.addUpstream(upstream)
67 addUpstream (upstream) {
68 const upstreamOrigin = parseOrigin(upstream).origin
111 removeUpstream (upstream) {
112 const upstreamOrigin = parseOrigin(upstream).origin
135 // otherwise we would have to wait until an upstream
/third_party/node/deps/v8/third_party/inspector_protocol/
H A Droll.py125 "Rolls the inspector_protocol project (upstream) into V8's "
128 help="The inspector_protocol (upstream) tree.",
139 upstream = os.path.normpath(os.path.expanduser(args.ip_src_upstream))
142 CheckRepoIsClean(upstream, '/src')
144 CheckRepoIsInspectorProtocolCheckout(upstream)
150 src_dir = upstream
183 head_revision = GetHeadRevision(upstream)
/third_party/node/tools/inspector_protocol/
H A Droll.py93 "Rolls the inspector_protocol project (upstream) into V8's "
96 help="The inspector_protocol (upstream) tree.",
107 upstream = os.path.normpath(os.path.expanduser(args.ip_src_upstream))
110 CheckRepoIsClean(upstream, '/src')
112 CheckRepoIsInspectorProtocolCheckout(upstream)
118 src_dir = upstream
150 head_revision = GetHeadRevision(upstream)
/third_party/node/tools/dep_updaters/
H A Dupdate-googletest.sh15 git remote add googletest-upstream https://github.com/google/googletest.git
16 git fetch googletest-upstream "$NEW_UPSTREAM_SHA1"
17 git remote remove googletest-upstream
/third_party/ninja/misc/
H A Dninja.vim7 " Version 1.4 of this script is in the upstream vim repository and will be
9 " upstream.

Completed in 34 milliseconds

12