| /third_party/nghttp2/src/ |
| D | shrpx_https_upstream.cc | 113 auto downstream = in on_start_request() local
139 auto downstream = upstream->get_downstream(); in htp_uricb() local
176 auto downstream = upstream->get_downstream(); in htp_hdr_keycb() local
231 auto downstream = upstream->get_downstream(); in htp_hdr_valcb() local
342 auto downstream = upstream->get_downstream(); in htp_hdrs_completecb() local
549 auto downstream = upstream->get_downstream(); in htp_bodycb() local
574 auto downstream = upstream->get_downstream(); in htp_msg_completecb() local
615 auto downstream = get_downstream(); in on_read() local
743 auto downstream = get_downstream(); in on_write() local
803 int HttpsUpstream::resume_read(IOCtrlReason reason, Downstream *downstream, in resume_read()
[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
239 auto downstream = static_cast<Downstream *>( in on_invalid_header_callback2() local
281 auto downstream = std::make_unique<Downstream>(this, handler_->get_mcpool(), in on_start_request() local
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() local
577 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback() local
[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_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
199 auto downstream = data->downstream; in env_get_tls_client_subject_name() local
229 auto downstream = data->downstream; in env_get_tls_client_issuer_name() local
259 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
193 auto downstream = data->downstream; in response_clear_headers() local
205 auto downstream = data->downstream; in response_return() local
282 auto downstream = data->downstream; in response_send_info() local
|
| D | shrpx_http_downstream_connection.cc | 63 auto downstream = dconn->get_downstream(); in timeoutcb() local
78 void retry_downstream_connection(Downstream *downstream, in retry_downstream_connection()
137 auto downstream = dconn->get_downstream(); in connect_timeoutcb() local
144 void backend_retry(Downstream *downstream) { in backend_retry()
154 auto downstream = dconn->get_downstream(); in readcb() local
175 auto downstream = dconn->get_downstream(); in writecb() local
195 auto downstream = dconn->get_downstream(); in connectcb() local
237 int HttpDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
340 auto downstream = this->downstream_; in initiate_connection() local
864 void HttpDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
[all …]
|
| D | shrpx_http3_upstream.cc | 247 auto downstream = in http_begin_request_headers() local
263 std::unique_ptr<Downstream> downstream) { in add_pending_downstream()
969 int Http3Upstream::on_timeout(Downstream *downstream) { return 0; } in on_timeout()
971 int Http3Upstream::on_downstream_abort_request(Downstream *downstream, in on_downstream_abort_request()
987 Downstream *downstream) { in on_downstream_abort_request_with_https_redirect()
1009 auto downstream = dconn->get_downstream(); in downstream_read() local
1078 auto downstream = dconn->get_downstream(); in downstream_eof() local
1118 auto downstream = dconn->get_downstream(); in downstream_error() local
1184 auto downstream = static_cast<Downstream *>(stream_user_data); in downstream_read_data_callback() local
1220 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 | 283 auto downstream = dc->get_downstream(); in disconnect() local
798 auto downstream = dconn->get_downstream(); in resume_data() local
814 Downstream *downstream) { in call_downstream_readcb()
843 auto downstream = dconn->get_downstream(); in on_stream_close_callback() local
910 auto downstream = sd->dconn->get_downstream(); in on_header_callback2() local
1075 auto downstream = sd->dconn->get_downstream(); in on_begin_headers_callback() local
1095 int on_response_headers(Http2Session *http2session, Downstream *downstream, in on_response_headers()
1234 auto downstream = sd->dconn->get_downstream(); in on_frame_recv_callback() local
1268 auto downstream = sd->dconn->get_downstream(); in on_frame_recv_callback() local
1315 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()
176 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 | 807 uint32_t ClientHandler::get_affinity_cookie(Downstream *downstream, in get_affinity_cookie()
854 Downstream *downstream) { in get_downstream_addr()
962 Downstream *downstream) { in get_downstream_addr_strict_affinity()
1023 ClientHandler::get_downstream_connection(int &err, Downstream *downstream) { in get_downstream_connection()
1177 auto downstream = http->get_downstream(); in perform_http2_upgrade() local
1220 void ClientHandler::write_accesslog(Downstream *downstream) { in write_accesslog()
|
| D | shrpx_downstream_queue.h | 47 Downstream *downstream; member
|
| D | shrpx_api_downstream_connection.cc | 81 int APIDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
91 void APIDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
|
| D | shrpx_mruby_module.cc | 62 void delete_downstream_from_module(mrb_state *mrb, Downstream *downstream) { in delete_downstream_from_module()
|
| D | shrpx_log.h | 266 Downstream *downstream; member
|
| D | shrpx_downstream.cc | 50 auto downstream = static_cast<Downstream *>(w->data); in upstream_timeoutcb() local
81 auto downstream = static_cast<Downstream *>(w->data); in downstream_timeoutcb() local
|
| D | shrpx_log.cc | 588 auto downstream = lgsp.downstream; in upstream_accesslog() local
|
| D | shrpx_config.h | 922 } downstream; member
1060 std::shared_ptr<DownstreamConfig> downstream; member
|
| /third_party/gstreamer/gstplugins_base/ext/gl/ |
| D | gstgltransformation.c | 836 float upstream[16], downstream[16]; in gst_gl_transformation_prepare_output_buffer() local
|
| /third_party/gstreamer/gstplugins_bad/sys/uvch264/ |
| D | gstuvch264_src.c | 1577 GstEvent *downstream; in gst_uvc_h264_src_buffer_probe() local
|