Home
last modified time | relevance | path

Searched refs:downstream (Results 1 - 25 of 43) sorted by relevance

12

/third_party/nghttp2/src/
H A Dshrpx_http2_upstream.cc67 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()
82 // downstream was deleted 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()
94 // At this point, downstream rea in on_stream_close_callback()
131 auto downstream = http->pop_downstream(); upgrade_upstream() local
177 auto downstream = static_cast<Downstream *>( on_header_callback2() local
239 auto downstream = static_cast<Downstream *>( on_invalid_header_callback2() local
281 auto downstream = std::make_unique<Downstream>(this, handler_->get_mcpool(), on_start_request() local
308 on_request_headers(Downstream *downstream, const nghttp2_frame *frame) on_request_headers() argument
457 start_downstream(Downstream *downstream) start_downstream() argument
466 initiate_downstream(Downstream *downstream) initiate_downstream() argument
556 auto downstream = static_cast<Downstream *>( on_frame_recv_callback() local
577 auto downstream = static_cast<Downstream *>( on_frame_recv_callback() local
633 auto downstream = static_cast<Downstream *>( on_data_chunk_recv_callback() local
679 auto downstream = static_cast<Downstream *>( on_frame_send_callback() local
823 auto downstream = static_cast<Downstream *>( on_frame_not_send_callback() local
841 auto downstream = static_cast<Downstream *>(source->ptr); send_data_callback() local
1251 auto downstream = dconn->get_downstream(); downstream_read() local
1320 auto downstream = dconn->get_downstream(); downstream_eof() local
1358 auto downstream = dconn->get_downstream(); downstream_error() local
1413 rst_stream(Downstream *downstream, uint32_t error_code) rst_stream() argument
1445 auto downstream = static_cast<Downstream *>(source->ptr); downstream_data_read_callback() local
1507 send_reply(Downstream *downstream, const uint8_t *body, size_t bodylen) send_reply() argument
1579 error_reply(Downstream *downstream, unsigned int status_code) error_reply() argument
1623 add_pending_downstream( std::unique_ptr<Downstream> downstream) add_pending_downstream() argument
1628 remove_downstream(Downstream *downstream) remove_downstream() argument
1650 on_downstream_header_complete(Downstream *downstream) on_downstream_header_complete() argument
1890 on_downstream_body(Downstream *downstream, const uint8_t *data, size_t len, bool flush) on_downstream_body() argument
1907 on_downstream_body_complete(Downstream *downstream) on_downstream_body_complete() argument
1930 resume_read(IOCtrlReason reason, Downstream *downstream, size_t consumed) resume_read() argument
1946 on_downstream_abort_request(Downstream *downstream, unsigned int status_code) on_downstream_abort_request() argument
1960 on_downstream_abort_request_with_https_redirect( Downstream *downstream) on_downstream_abort_request_with_https_redirect() argument
1973 redirect_to_https(Downstream *downstream) redirect_to_https() argument
2026 log_response_headers( Downstream *downstream, const std::vector<nghttp2_nv> &nva) const log_response_headers() argument
2038 on_timeout(Downstream *downstream) on_timeout() argument
2059 on_downstream_reset(Downstream *downstream, bool no_retry) on_downstream_reset() argument
2138 prepare_push_promise(Downstream *downstream) prepare_push_promise() argument
2187 submit_push_promise(const StringRef &scheme, const StringRef &authority, const StringRef &path, Downstream *downstream) submit_push_promise() argument
2258 initiate_push(Downstream *downstream, const StringRef &uri) initiate_push() argument
2323 on_downstream_push_promise(Downstream *downstream, int32_t promised_stream_id) on_downstream_push_promise() argument
2350 on_downstream_push_promise_complete( Downstream *downstream, Downstream *promised_downstream) on_downstream_push_promise_complete() argument
[all...]
H A Dshrpx_https_upstream.cc113 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 in htp_hdr_keycb()
231 auto downstream = upstream->get_downstream(); htp_hdr_valcb() local
342 auto downstream = upstream->get_downstream(); htp_hdrs_completecb() local
564 auto downstream = upstream->get_downstream(); htp_bodycb() local
589 auto downstream = upstream->get_downstream(); htp_msg_completecb() local
630 auto downstream = get_downstream(); on_read() local
767 auto downstream = get_downstream(); on_write() local
827 resume_read(IOCtrlReason reason, Downstream *downstream, size_t consumed) resume_read() argument
847 auto downstream = dconn->get_downstream(); downstream_read() local
904 auto downstream = dconn->get_downstream(); downstream_eof() local
947 auto downstream = dconn->get_downstream(); downstream_error() local
977 send_reply(Downstream *downstream, const uint8_t *body, size_t bodylen) send_reply() argument
1052 auto downstream = get_downstream(); error_reply() local
1095 attach_downstream(std::unique_ptr<Downstream> downstream) attach_downstream() argument
1114 on_downstream_header_complete(Downstream *downstream) on_downstream_header_complete() argument
1342 on_downstream_body(Downstream *downstream, const uint8_t *data, size_t len, bool flush) on_downstream_body() argument
1363 on_downstream_body_complete(Downstream *downstream) on_downstream_body_complete() argument
1396 on_downstream_abort_request(Downstream *downstream, unsigned int status_code) on_downstream_abort_request() argument
1403 on_downstream_abort_request_with_https_redirect( Downstream *downstream) on_downstream_abort_request_with_https_redirect() argument
1410 redirect_to_https(Downstream *downstream) redirect_to_https() argument
1466 on_downstream_reset(Downstream *downstream, bool no_retry) on_downstream_reset() argument
1532 initiate_push(Downstream *downstream, const StringRef &uri) initiate_push() argument
1567 on_downstream_push_promise(Downstream *downstream, int32_t promised_stream_id) on_downstream_push_promise() argument
1572 on_downstream_push_promise_complete( Downstream *downstream, Downstream *promised_downstream) on_downstream_push_promise_complete() argument
[all...]
H A Dshrpx_mruby_module_env.cc62 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 in env_get_server_addr() local
124 auto downstream = data->downstream; env_get_tls_used() local
135 auto downstream = data->downstream; env_get_tls_sni() local
147 auto downstream = data->downstream; env_get_tls_client_fingerprint_md() local
199 auto downstream = data->downstream; env_get_tls_client_subject_name() local
229 auto downstream = data->downstream; env_get_tls_client_issuer_name() local
259 auto downstream = data->downstream; env_get_tls_client_serial() local
289 auto downstream = data->downstream; env_get_tls_client_not_before() local
323 auto downstream = data->downstream; env_get_tls_client_not_after() local
357 auto downstream = data->downstream; env_get_tls_cipher() local
373 auto downstream = data->downstream; env_get_tls_protocol() local
389 auto downstream = data->downstream; env_get_tls_session_id() local
416 auto downstream = data->downstream; env_get_tls_session_reused() local
432 auto downstream = data->downstream; env_get_alpn() local
443 auto downstream = data->downstream; env_get_tls_handshake_finished() local
[all...]
H A Dshrpx_http3_upstream.cc247 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()
264 downstream_queue_.add_pending(std::move(downstream)); in add_pending_downstream()
1016 int Http3Upstream::on_timeout(Downstream *downstream) { return 0; } in on_timeout() argument
1018 int Http3Upstream::on_downstream_abort_request(Downstream *downstream, in on_downstream_abort_request() argument
1022 rv = error_reply(downstream, status_cod in on_downstream_abort_request()
262 add_pending_downstream( std::unique_ptr<Downstream> downstream) add_pending_downstream() argument
1033 on_downstream_abort_request_with_https_redirect( Downstream *downstream) on_downstream_abort_request_with_https_redirect() argument
1056 auto downstream = dconn->get_downstream(); downstream_read() local
1125 auto downstream = dconn->get_downstream(); downstream_eof() local
1165 auto downstream = dconn->get_downstream(); downstream_error() local
1231 auto downstream = static_cast<Downstream *>(stream_user_data); downstream_read_data_callback() local
1267 on_downstream_header_complete(Downstream *downstream) on_downstream_header_complete() argument
1459 on_downstream_body(Downstream *downstream, const uint8_t *data, size_t len, bool flush) on_downstream_body() argument
1474 on_downstream_body_complete(Downstream *downstream) on_downstream_body_complete() argument
1584 on_downstream_reset(Downstream *downstream, bool no_retry) on_downstream_reset() argument
1666 resume_read(IOCtrlReason reason, Downstream *downstream, size_t consumed) resume_read() argument
1679 send_reply(Downstream *downstream, const uint8_t *body, size_t bodylen) send_reply() argument
1755 initiate_push(Downstream *downstream, const StringRef &uri) initiate_push() argument
1768 on_downstream_push_promise(Downstream *downstream, int32_t promised_stream_id) on_downstream_push_promise() argument
1773 on_downstream_push_promise_complete( Downstream *downstream, Downstream *promised_downstream) on_downstream_push_promise_complete() argument
2035 auto downstream = static_cast<Downstream *>(stream_user_data); http_acked_stream_data() local
2047 http_acked_stream_data(Downstream *downstream, uint64_t datalen) http_acked_stream_data() argument
2087 auto downstream = static_cast<Downstream *>(stream_user_data); http_recv_request_header() local
2108 auto downstream = static_cast<Downstream *>(stream_user_data); http_recv_request_trailer() local
2123 http_recv_request_header(Downstream *downstream, int32_t h3token, nghttp3_rcbuf *name, nghttp3_rcbuf *value, uint8_t flags, bool trailer) http_recv_request_header() argument
2185 auto downstream = static_cast<Downstream *>(stream_user_data); http_end_request_headers() local
2202 http_end_request_headers(Downstream *downstream, int fin) http_end_request_headers() argument
2336 start_downstream(Downstream *downstream) start_downstream() argument
2345 initiate_downstream(Downstream *downstream) initiate_downstream() argument
2427 auto downstream = static_cast<Downstream *>(stream_user_data); http_recv_data() local
2437 http_recv_data(Downstream *downstream, const uint8_t *data, size_t datalen) http_recv_data() argument
2458 auto downstream = static_cast<Downstream *>(stream_user_data); http_end_stream() local
2472 http_end_stream(Downstream *downstream) http_end_stream() argument
2491 auto downstream = static_cast<Downstream *>(stream_user_data); http_stream_close() local
2505 http_stream_close(Downstream *downstream, uint64_t app_error_code) http_stream_close() argument
2692 error_reply(Downstream *downstream, unsigned int status_code) error_reply() argument
2740 shutdown_stream(Downstream *downstream, uint64_t app_error_code) shutdown_stream() argument
2777 remove_downstream(Downstream *downstream) remove_downstream() argument
2797 log_response_headers( Downstream *downstream, const std::vector<nghttp3_nv> &nva) const log_response_headers() argument
[all...]
H A Dshrpx_http2_upstream.h54 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, cons
[all...]
H A Dshrpx_mruby_module_request.cc52 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 in request_set_method() local
107 auto downstream = data->downstream; request_get_authority() local
117 auto downstream = data->downstream; request_set_authority() local
141 auto downstream = data->downstream; request_get_scheme() local
151 auto downstream = data->downstream; request_set_scheme() local
175 auto downstream = data->downstream; request_get_path() local
185 auto downstream = data->downstream; request_set_path() local
206 auto downstream = data->downstream; request_get_headers() local
215 auto downstream = data->downstream; request_mod_header() local
301 auto downstream = data->downstream; request_clear_headers() local
315 auto downstream = data->downstream; request_push() local
[all...]
H A Dshrpx_http_downstream_connection.cc63 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 in retry_downstream_connection()
137 auto downstream = dconn->get_downstream(); connect_timeoutcb() local
144 backend_retry(Downstream *downstream) backend_retry() argument
154 auto downstream = dconn->get_downstream(); readcb() local
175 auto downstream = dconn->get_downstream(); writecb() local
195 auto downstream = dconn->get_downstream(); connectcb() local
237 attach_downstream(Downstream *downstream) attach_downstream() argument
864 detach_downstream(Downstream *downstream) detach_downstream() argument
909 auto downstream = static_cast<Downstream *>(htp->data); htp_msg_begincb() local
921 auto downstream = static_cast<Downstream *>(htp->data); htp_hdrs_completecb() local
1071 ensure_header_field_buffer(const Downstream *downstream, const HttpConfig &httpconf, size_t len) ensure_header_field_buffer() argument
1088 ensure_max_header_fields(const Downstream *downstream, const HttpConfig &httpconf) ensure_max_header_fields() argument
1106 auto downstream = static_cast<Downstream *>(htp->data); htp_hdr_keycb() local
1143 auto downstream = static_cast<Downstream *>(htp->data); htp_hdr_valcb() local
1162 auto downstream = static_cast<Downstream *>(htp->data); htp_bodycb() local
1174 auto downstream = static_cast<Downstream *>(htp->data); htp_msg_completecb() local
[all...]
H A Dshrpx_http3_upstream.h51 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, cons
[all...]
H A Dshrpx_downstream_queue.cc51 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 in mark_active()
93 mark_blocked(Downstream *downstream) mark_blocked() argument
124 remove_and_get_blocked(Downstream *downstream, bool next_blocked) remove_and_get_blocked() argument
[all...]
H A Dshrpx_http2_session.cc283 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()
451 SSLOG(INFO, this) << "Connecting to downstream server"; in initiate_connection()
734 SSLOG(INFO, this) << "Remove downstream"; in remove_downstream_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()
815 auto upstream = downstream in call_downstream_readcb()
813 call_downstream_readcb(Http2Session *http2session, Downstream *downstream) call_downstream_readcb() argument
843 auto downstream = dconn->get_downstream(); on_stream_close_callback() local
910 auto downstream = sd->dconn->get_downstream(); on_header_callback2() local
1075 auto downstream = sd->dconn->get_downstream(); on_begin_headers_callback() local
1095 on_response_headers(Http2Session *http2session, Downstream *downstream, nghttp2_session *session, const nghttp2_frame *frame) on_response_headers() argument
1234 auto downstream = sd->dconn->get_downstream(); on_frame_recv_callback() local
1268 auto downstream = sd->dconn->get_downstream(); on_frame_recv_callback() local
1315 auto downstream = sd->dconn->get_downstream(); on_frame_recv_callback() local
1362 auto downstream = sd->dconn->get_downstream(); on_frame_recv_callback() local
1420 auto downstream = sd->dconn->get_downstream(); on_data_chunk_recv_callback() local
1480 auto downstream = sd->dconn->get_downstream(); on_frame_send_callback() local
1538 auto downstream = sd->dconn->get_downstream(); on_frame_not_send_callback() local
1578 auto downstream = dconn->get_downstream(); send_data_callback() local
1933 auto downstream = dconn->get_downstream(); submit_pending_requests() local
2216 handle_downstream_push_promise(Downstream *downstream, int32_t promised_stream_id) handle_downstream_push_promise() argument
2255 handle_downstream_push_promise_complete( Downstream *downstream, Downstream *promised_downstream) handle_downstream_push_promise_complete() argument
[all...]
H A Dshrpx_mruby_module_response.cc52 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 in response_set_status() local
99 auto downstream = data->downstream; response_get_headers() local
109 auto downstream = data->downstream; response_mod_header() local
193 auto downstream = data->downstream; response_clear_headers() local
205 auto downstream = data->downstream; response_return() local
282 auto downstream = data->downstream; response_send_info() local
[all...]
H A Dshrpx_upstream.h45 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;
64 // Called when downstream connection for |downstream| is reset.
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
[all...]
H A Dshrpx_https_upstream.h51 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, cons
[all...]
H A Dshrpx_http2_downstream_connection.cc95 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 in submit_rst_stream()
176 auto downstream = dconn->get_downstream(); http2_data_read_callback() local
[all...]
H A Dshrpx_downstream_queue.h43 // Link entry in HostEntry.blocked and downstream because downstream
47 Downstream *downstream; member
72 // conn_max_per_host == 0 means no limit for downstream connection.
75 // Add |downstream| to this queue. This is entry point for
77 void add_pending(std::unique_ptr<Downstream> downstream);
78 // Set |downstream| to failure state, which means that downstream
80 void mark_failure(Downstream *downstream);
81 // Set |downstream| t
[all...]
H A Dshrpx_mruby.cc49 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()
H A Dshrpx_mruby.h50 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
H A Dshrpx_null_downstream_connection.cc38 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()
H A Dshrpx_health_monitor_downstream_connection.cc39 Downstream *downstream) { in attach_downstream()
41 DCLOG(INFO, this) << "Attaching to DOWNSTREAM:" << downstream; in attach_downstream()
44 downstream_ = downstream; in attach_downstream()
50 Downstream *downstream) { in detach_downstream()
52 DCLOG(INFO, this) << "Detaching from DOWNSTREAM:" << downstream; in detach_downstream()
38 attach_downstream( Downstream *downstream) attach_downstream() argument
49 detach_downstream( Downstream *downstream) detach_downstream() argument
H A Dshrpx_client_handler.h110 Downstream *downstream);
116 get_downstream_connection(int &err, Downstream *downstream);
131 // Writes upstream accesslog using |downstream|. The |downstream|
133 void write_accesslog(Downstream *downstream);
171 // Returns an affinity cookie value for |downstream|. |cookie_name|
173 uint32_t get_affinity_cookie(Downstream *downstream,
178 Downstream *downstream);
H A Dshrpx_http2_downstream_connection.h46 virtual int attach_downstream(Downstream *downstream);
47 virtual void detach_downstream(Downstream *downstream);
76 int submit_rst_stream(Downstream *downstream,
H A Dshrpx_client_handler.cc726 CLOG(INFO, this) << "Pooling downstream connection DCONN:" << dconn.get() in pool_downstream_connection()
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()
881 downstream); in get_downstream_addr()
884 hash = get_affinity_cookie(downstream, shared_addr->affinity.cookie.name); in get_downstream_addr()
930 CLOG(INFO, this) << "No working downstream address found"; in get_downstream_addr()
962 Downstream *downstream) { in get_downstream_addr_strict_affinity()
965 auto h = downstream in get_downstream_addr_strict_affinity()
852 get_downstream_addr(int &err, DownstreamAddrGroup *group, Downstream *downstream) get_downstream_addr() argument
960 get_downstream_addr_strict_affinity( int &err, const std::shared_ptr<SharedDownstreamAddr> &shared_addr, Downstream *downstream) get_downstream_addr_strict_affinity() argument
1023 get_downstream_connection(int &err, Downstream *downstream) get_downstream_connection() argument
1177 auto downstream = http->get_downstream(); perform_http2_upgrade() local
1220 write_accesslog(Downstream *downstream) write_accesslog() argument
[all...]
H A Dshrpx_api_downstream_connection.cc81 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()
/third_party/node/deps/v8/third_party/inspector_protocol/
H A Droll.py126 "third_party (downstream)."))
140 downstream = os.path.normpath(os.path.expanduser(
143 CheckRepoIsClean(downstream, '/v8')
145 CheckRepoIsV8Checkout(downstream)
149 CheckRepoIsNotAtMasterBranch(downstream)
151 dest_dir = os.path.join(downstream, 'third_party/inspector_protocol')
/third_party/node/tools/inspector_protocol/
H A Droll.py94 "third_party (downstream)."))
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')

Completed in 17 milliseconds

12