Home
last modified time | relevance | path

Searched refs:Downstream (Results 1 - 25 of 34) sorted by relevance

12

/third_party/nghttp2/src/
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 *downstrea
[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 *downstrea
[all...]
H A Dshrpx_downstream.cc50 auto downstream = static_cast<Downstream *>(w->data); in upstream_timeoutcb()
81 auto downstream = static_cast<Downstream *>(w->data); in downstream_timeoutcb()
115 Downstream::Downstream(Upstream *upstream, MemchunkPool *mcpool, in Downstream() function in shrpx::Downstream
173 Downstream::~Downstream() { in ~Downstream()
225 int Downstream::attach_downstream_connection( in attach_downstream_connection()
236 void Downstream::detach_downstream_connection() { in detach_downstream_connection()
257 DownstreamConnection *Downstream::get_downstream_connection() { in get_downstream_connection()
261 std::unique_ptr<DownstreamConnection> Downstream
[all...]
H A Dshrpx_upstream.h37 class Downstream;
45 virtual int on_timeout(Downstream *downstream) { return 0; }; in on_timeout()
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;
68 virtual int on_downstream_reset(Downstream *downstream, bool no_retry) = 0;
71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
73 virtual int send_reply(Downstream *downstrea
[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);
64 Downstream *get_downstream() const;
65 std::unique_ptr<Downstream> pop_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 *downstrea
[all...]
H A Dshrpx_downstream_queue.h41 class Downstream;
44 // could be deleted in anytime and we'd like to find Downstream in
45 // O(1). Downstream has field to link back to this object.
47 Downstream *downstream;
76 // Downstream object.
77 void add_pending(std::unique_ptr<Downstream> downstream);
80 void mark_failure(Downstream *downstream);
83 void mark_active(Downstream *downstream);
86 void mark_blocked(Downstream *downstream);
92 // may return Downstream objec
[all...]
H A Dshrpx_mruby.h41 class Downstream;
50 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;
H A Dshrpx_downstream_queue.cc51 void DownstreamQueue::add_pending(std::unique_ptr<Downstream> downstream) { in add_pending()
56 void DownstreamQueue::mark_failure(Downstream *downstream) { in mark_failure()
82 StringRef DownstreamQueue::make_host_key(Downstream *downstream) const { in make_host_key()
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()
127 auto delptr = std::unique_ptr<Downstream>(downstream); in remove_and_get_blocked()
171 Downstream *DownstreamQueue::get_downstreams() const { in get_downstreams()
H A Dshrpx_downstream_connection.h38 class Downstream;
46 virtual int attach_downstream(Downstream *downstream) = 0;
47 virtual void detach_downstream(Downstream *downstream) = 0;
72 Downstream *get_downstream();
76 Downstream *downstream_;
H A Dshrpx_client_handler.h52 class Downstream;
110 Downstream *downstream);
116 get_downstream_connection(int &err, Downstream *downstream);
133 void write_accesslog(Downstream *downstream);
173 uint32_t get_affinity_cookie(Downstream *downstream,
178 Downstream *downstream);
H A Dshrpx_http2_upstream.cc67 auto downstream = static_cast<Downstream *>( in on_stream_close_callback()
177 auto downstream = static_cast<Downstream *>( in on_header_callback2()
239 auto downstream = static_cast<Downstream *>( in on_invalid_header_callback2()
281 auto downstream = std::make_unique<Downstream>(this, handler_->get_mcpool(), in on_start_request()
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()
577 auto downstream = static_cast<Downstream *>( in on_frame_recv_callback()
633 auto downstream = static_cast<Downstream *>( in on_data_chunk_recv_callback()
[all...]
H A Dshrpx_https_upstream.cc114 std::make_unique<Downstream>(this, handler_->get_mcpool(), 0); in on_start_request()
651 ULOG(INFO, this) << "Downstream request buf is full"; in on_read()
755 ULOG(INFO, this) << "Downstream request buffer is full"; in on_read()
827 int HttpsUpstream::resume_read(IOCtrlReason reason, Downstream *downstream, in resume_read()
865 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
893 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_write()
949 if (events & Downstream::EVENT_ERROR) { in downstream_error()
960 if (events & Downstream::EVENT_TIMEOUT) { in downstream_error()
977 int HttpsUpstream::send_reply(Downstream *downstream, const uint8_t *body, in send_reply()
1056 std::make_unique<Downstream>(thi in error_reply()
[all...]
H A Dshrpx_http2_session.h51 class Downstream;
174 bool can_push_request(const Downstream *downstream) const;
198 int handle_downstream_push_promise(Downstream *downstream,
200 int handle_downstream_push_promise_complete(Downstream *downstream,
201 Downstream *promised_downstream);
H A Dshrpx_http3_upstream.cc248 std::make_unique<Downstream>(this, handler_->get_mcpool(), stream_id); in http_begin_request_headers()
263 std::unique_ptr<Downstream> downstream) { in add_pending_downstream()
1016 int Http3Upstream::on_timeout(Downstream *downstream) { return 0; } in on_timeout()
1018 int Http3Upstream::on_downstream_abort_request(Downstream *downstream, in on_downstream_abort_request()
1034 Downstream *downstream) { in on_downstream_abort_request_with_https_redirect()
1096 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
1116 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_write()
1140 ULOG(INFO, this) << "Downstream body was ended by EOF"; in downstream_eof()
1168 if (events & Downstream::EVENT_ERROR) { in downstream_error()
1169 DCLOG(INFO, dconn) << "Downstream networ in downstream_error()
[all...]
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_mruby.cc49 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()
H A Dshrpx_mruby_module.h38 class Downstream;
44 void delete_downstream_from_module(mrb_state *mrb, Downstream *downstream);
H A Dshrpx_health_monitor_downstream_connection.h38 virtual int attach_downstream(Downstream *downstream);
39 virtual void detach_downstream(Downstream *downstream);
H A Dshrpx_downstream_test.cc86 Downstream d(nullptr, nullptr, 0); in test_downstream_crumble_request_cookie()
131 Downstream d(nullptr, nullptr, 0); in test_downstream_assemble_request_cookie()
154 Downstream d(nullptr, nullptr, 0); in test_downstream_rewrite_location_response_header()
168 Downstream d(nullptr, nullptr, 0); in test_downstream_supports_non_final_response()
198 Downstream d(nullptr, nullptr, 0); in test_downstream_find_affinity_cookie()
H A Dshrpx_null_downstream_connection.cc38 int NullDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
48 void NullDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
H A Dshrpx_null_downstream_connection.h39 virtual int attach_downstream(Downstream *downstream);
40 virtual void detach_downstream(Downstream *downstream);
H A Dshrpx_api_downstream_connection.h70 virtual int attach_downstream(Downstream *downstream);
71 virtual void detach_downstream(Downstream *downstream);
H A Dshrpx_health_monitor_downstream_connection.cc39 Downstream *downstream) { in attach_downstream()
50 Downstream *downstream) { in detach_downstream()
H A Dshrpx_http_downstream_connection.cc71 if (upstream->downstream_error(dconn, Downstream::EVENT_TIMEOUT) != 0) { in timeoutcb()
78 void retry_downstream_connection(Downstream *downstream, in retry_downstream_connection()
144 void backend_retry(Downstream *downstream) { in backend_retry()
237 int HttpDownstreamConnection::attach_downstream(Downstream *downstream) { in attach_downstream()
864 void HttpDownstreamConnection::detach_downstream(Downstream *downstream) { in detach_downstream()
909 auto downstream = static_cast<Downstream *>(htp->data); in htp_msg_begincb()
921 auto downstream = static_cast<Downstream *>(htp->data); in htp_hdrs_completecb()
993 // Reset content-length because we reuse same Downstream for the in htp_hdrs_completecb()
1071 int ensure_header_field_buffer(const Downstream *downstream, in ensure_header_field_buffer()
1088 int ensure_max_header_fields(const Downstream *downstrea
[all...]
H A Dshrpx_http_downstream_connection.h50 virtual int attach_downstream(Downstream *downstream);
51 virtual void detach_downstream(Downstream *downstream);

Completed in 14 milliseconds

12