| /third_party/nghttp2/src/ |
| D | shrpx_https_upstream.cc | 100 auto downstream = in on_start_request() local
126 auto downstream = upstream->get_downstream(); in htp_uricb() local
163 auto downstream = upstream->get_downstream(); in htp_hdr_keycb() local
218 auto downstream = upstream->get_downstream(); in htp_hdr_valcb() local
329 auto downstream = upstream->get_downstream(); in htp_hdrs_completecb() local
524 auto downstream = upstream->get_downstream(); in htp_bodycb() local
549 auto downstream = upstream->get_downstream(); in htp_msg_completecb() local
584 auto downstream = get_downstream(); in on_read() local
712 auto downstream = get_downstream(); in on_write() local
765 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
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()
451 void Http2Upstream::start_downstream(Downstream *downstream) { in start_downstream()
460 void Http2Upstream::initiate_downstream(Downstream *downstream) { in initiate_downstream()
548 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback() local
569 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
193 auto downstream = data->downstream; in env_get_tls_client_subject_name() local
217 auto downstream = data->downstream; in env_get_tls_client_issuer_name() local
241 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 | 61 auto downstream = dconn->get_downstream(); in timeoutcb() local
76 void retry_downstream_connection(Downstream *downstream, in retry_downstream_connection()
135 auto downstream = dconn->get_downstream(); in connect_timeoutcb() local
142 void backend_retry(Downstream *downstream) { in backend_retry()
152 auto downstream = dconn->get_downstream(); in readcb() local
173 auto downstream = dconn->get_downstream(); in writecb() local
193 auto downstream = dconn->get_downstream(); in connectcb() local
235 int HttpDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
325 auto downstream = this->downstream_; in initiate_connection() local
846 void HttpDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
[all …]
|
| D | shrpx_mruby.cc | 49 int MRubyContext::run_app(Downstream *downstream, int phase) { in run_app()
101 int MRubyContext::run_on_request_proc(Downstream *downstream) { in run_on_request_proc()
105 int MRubyContext::run_on_response_proc(Downstream *downstream) { in run_on_response_proc()
109 void MRubyContext::delete_downstream(Downstream *downstream) { in delete_downstream()
|
| D | shrpx_http2_session.cc | 283 auto downstream = dc->get_downstream(); in disconnect() local
785 auto downstream = dconn->get_downstream(); in resume_data() local
801 Downstream *downstream) { in call_downstream_readcb()
830 auto downstream = dconn->get_downstream(); in on_stream_close_callback() local
897 auto downstream = sd->dconn->get_downstream(); in on_header_callback2() local
1062 auto downstream = sd->dconn->get_downstream(); in on_begin_headers_callback() local
1082 int on_response_headers(Http2Session *http2session, Downstream *downstream, in on_response_headers()
1221 auto downstream = sd->dconn->get_downstream(); in on_frame_recv_callback() local
1255 auto downstream = sd->dconn->get_downstream(); in on_frame_recv_callback() local
1302 auto downstream = sd->dconn->get_downstream(); in on_frame_recv_callback() local
[all …]
|
| 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_downstream_queue.h | 47 Downstream *downstream; member
|
| D | shrpx_client_handler.cc | 742 uint32_t ClientHandler::get_affinity_cookie(Downstream *downstream, in get_affinity_cookie()
790 Downstream *downstream) { in get_downstream_addr()
892 ClientHandler::get_downstream_connection(int &err, Downstream *downstream) { in get_downstream_connection()
1039 auto downstream = http->get_downstream(); in perform_http2_upgrade() local
1082 void ClientHandler::write_accesslog(Downstream *downstream) { in write_accesslog()
|
| 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 | 81 int APIDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
91 void APIDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
|
| 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
|
| /third_party/curl/lib/ |
| D | content_encoding.h | 28 struct contenc_writer *downstream; /* Downstream writer. */ member
|
| D | content_encoding.c | 971 struct contenc_writer *downstream, in new_unencoding_writer()
|
| /third_party/grpc/src/python/grpcio/grpc/framework/foundation/ |
| D | stream_util.py | 28 def __init__(self, transformation, downstream): argument
|
| /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
|