| /third_party/nghttp2/src/ |
| D | shrpx_https_upstream.cc | 113 auto downstream = in on_start_request() local
136 auto downstream = upstream->get_downstream(); in htp_uricb() local
173 auto downstream = upstream->get_downstream(); in htp_hdr_keycb() local
228 auto downstream = upstream->get_downstream(); in htp_hdr_valcb() local
339 auto downstream = upstream->get_downstream(); in htp_hdrs_completecb() local
561 auto downstream = upstream->get_downstream(); in htp_bodycb() local
586 auto downstream = upstream->get_downstream(); in htp_msg_completecb() local
627 auto downstream = get_downstream(); in on_read() local
763 auto downstream = get_downstream(); in on_write() local
820 int HttpsUpstream::resume_read(IOCtrlReason reason, Downstream *downstream, in resume_read()
[all …]
|
| D | shrpx_mruby_module_request.cc | 52 auto downstream = data->downstream; in request_get_http_version_major() local
61 auto downstream = data->downstream; in request_get_http_version_minor() local
70 auto downstream = data->downstream; in request_get_method() local
81 auto downstream = data->downstream; in request_set_method() local
107 auto downstream = data->downstream; in request_get_authority() local
117 auto downstream = data->downstream; in request_set_authority() local
141 auto downstream = data->downstream; in request_get_scheme() local
151 auto downstream = data->downstream; in request_set_scheme() local
175 auto downstream = data->downstream; in request_get_path() local
185 auto downstream = data->downstream; in request_set_path() local
[all …]
|
| D | shrpx_http2_upstream.cc | 67 auto downstream = static_cast<Downstream *>( in on_stream_close_callback() local
131 auto downstream = http->pop_downstream(); in upgrade_upstream() local
177 auto downstream = static_cast<Downstream *>( in on_header_callback2() local
237 auto downstream = static_cast<Downstream *>( in on_invalid_header_callback2() local
279 auto downstream = std::make_unique<Downstream>(this, handler_->get_mcpool(), in on_start_request() local
307 int Http2Upstream::on_request_headers(Downstream *downstream, in on_request_headers()
456 void Http2Upstream::start_downstream(Downstream *downstream) { in start_downstream()
465 void Http2Upstream::initiate_downstream(Downstream *downstream) { in initiate_downstream()
554 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback() local
575 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback() local
[all …]
|
| D | shrpx_mruby_module_env.cc | 62 auto downstream = data->downstream; in env_get_ctx() local
87 auto downstream = data->downstream; in env_get_remote_addr() local
100 auto downstream = data->downstream; in env_get_server_port() local
112 auto downstream = data->downstream; in env_get_server_addr() local
124 auto downstream = data->downstream; in env_get_tls_used() local
135 auto downstream = data->downstream; in env_get_tls_sni() local
147 auto downstream = data->downstream; in env_get_tls_client_fingerprint_md() local
198 auto downstream = data->downstream; in env_get_tls_client_subject_name() local
228 auto downstream = data->downstream; in env_get_tls_client_issuer_name() local
258 auto downstream = data->downstream; in env_get_tls_client_serial() local
[all …]
|
| 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()
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()
|
| D | shrpx_mruby_module_response.cc | 52 auto downstream = data->downstream; in response_get_http_version_major() local
61 auto downstream = data->downstream; in response_get_http_version_minor() local
70 auto downstream = data->downstream; in response_get_status() local
79 auto downstream = data->downstream; in response_set_status() local
99 auto downstream = data->downstream; in response_get_headers() local
109 auto downstream = data->downstream; in response_mod_header() local
192 auto downstream = data->downstream; in response_clear_headers() local
204 auto downstream = data->downstream; in response_return() local
281 auto downstream = data->downstream; in response_send_info() local
|
| D | shrpx_http_downstream_connection.cc | 69 auto downstream = dconn->get_downstream(); in timeoutcb() local
84 void retry_downstream_connection(Downstream *downstream, in retry_downstream_connection()
143 auto downstream = dconn->get_downstream(); in connect_timeoutcb() local
150 void backend_retry(Downstream *downstream) { in backend_retry()
160 auto downstream = dconn->get_downstream(); in readcb() local
181 auto downstream = dconn->get_downstream(); in writecb() local
201 auto downstream = dconn->get_downstream(); in connectcb() local
243 int HttpDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
345 auto downstream = this->downstream_; in initiate_connection() local
872 void HttpDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
[all …]
|
| D | shrpx_http3_upstream.cc | 252 auto downstream = in http_begin_request_headers() local
269 std::unique_ptr<Downstream> downstream) { in add_pending_downstream()
975 int Http3Upstream::on_timeout(Downstream *downstream) { in on_timeout()
988 int Http3Upstream::on_downstream_abort_request(Downstream *downstream, in on_downstream_abort_request()
1004 Downstream *downstream) { in on_downstream_abort_request_with_https_redirect()
1026 auto downstream = dconn->get_downstream(); in downstream_read() local
1095 auto downstream = dconn->get_downstream(); in downstream_eof() local
1135 auto downstream = dconn->get_downstream(); in downstream_error() local
1201 auto downstream = static_cast<Downstream *>(stream_user_data); in downstream_read_data_callback() local
1237 int Http3Upstream::on_downstream_header_complete(Downstream *downstream) { in on_downstream_header_complete()
[all …]
|
| 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_http2_session.cc | 290 auto downstream = dc->get_downstream(); in disconnect() local
805 auto downstream = dconn->get_downstream(); in resume_data() local
821 Downstream *downstream) { in call_downstream_readcb()
850 auto downstream = dconn->get_downstream(); in on_stream_close_callback() local
917 auto downstream = sd->dconn->get_downstream(); in on_header_callback2() local
1081 auto downstream = sd->dconn->get_downstream(); in on_begin_headers_callback() local
1101 int on_response_headers(Http2Session *http2session, Downstream *downstream, in on_response_headers()
1239 auto downstream = sd->dconn->get_downstream(); in on_frame_recv_callback() local
1271 auto downstream = sd->dconn->get_downstream(); in on_frame_recv_callback() local
1318 auto downstream = sd->dconn->get_downstream(); in on_frame_recv_callback() local
[all …]
|
| 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_health_monitor_downstream_connection.cc | 39 Downstream *downstream) { in attach_downstream()
50 Downstream *downstream) { in detach_downstream()
|
| D | shrpx_http2_downstream_connection.cc | 95 int Http2DownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
115 void Http2DownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
140 int Http2DownstreamConnection::submit_rst_stream(Downstream *downstream, in submit_rst_stream()
177 auto downstream = dconn->get_downstream(); in http2_data_read_callback() local
|
| D | shrpx_upstream.h | 45 virtual int on_timeout(Downstream *downstream) { return 0; } in on_timeout()
|
| D | shrpx_mruby.h | 70 Downstream *downstream; member
|
| D | shrpx_client_handler.cc | 795 uint32_t ClientHandler::get_affinity_cookie(Downstream *downstream, in get_affinity_cookie()
841 Downstream *downstream) { in get_downstream_addr()
949 Downstream *downstream) { in get_downstream_addr_strict_affinity()
1009 ClientHandler::get_downstream_connection(int &err, Downstream *downstream) { in get_downstream_connection()
1163 auto downstream = http->get_downstream(); in perform_http2_upgrade() local
1205 void ClientHandler::write_accesslog(Downstream *downstream) { in write_accesslog()
|
| D | shrpx_downstream_queue.h | 47 Downstream *downstream; member
|
| D | shrpx_mruby_module.cc | 62 void delete_downstream_from_module(mrb_state *mrb, Downstream *downstream) { in delete_downstream_from_module()
|
| D | shrpx_api_downstream_connection.cc | 75 int APIDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
85 void APIDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
|
| D | shrpx_downstream.cc | 50 auto downstream = static_cast<Downstream *>(w->data); in header_timeoutcb() local
67 auto downstream = static_cast<Downstream *>(w->data); in upstream_timeoutcb() local
98 auto downstream = static_cast<Downstream *>(w->data); in downstream_timeoutcb() local
|
| D | shrpx_log.h | 276 Downstream *downstream; member
|
| D | shrpx_log.cc | 585 auto downstream = lgsp.downstream; in upstream_accesslog() local
|
| D | shrpx_config.h | 887 } downstream; member
1024 std::shared_ptr<DownstreamConfig> downstream; member
|
| /third_party/grpc/src/python/grpcio/grpc/framework/foundation/ |
| D | stream_util.py | 28 def __init__(self, transformation, downstream): argument
|