| /third_party/nghttp2/src/ |
| D | shrpx_downstream_connection_pool.cc | 35 for (auto dconn : pool_) { in remove_all() local
36 delete dconn; in remove_all()
43 std::unique_ptr<DownstreamConnection> dconn) { in add_downstream_connection() argument
44 pool_.insert(dconn.release()); in add_downstream_connection()
54 auto dconn = std::unique_ptr<DownstreamConnection>(*it); in pop_downstream_connection() local
57 return dconn; in pop_downstream_connection()
61 DownstreamConnection *dconn) { in remove_downstream_connection() argument
62 pool_.erase(dconn); in remove_downstream_connection()
63 delete dconn; in remove_downstream_connection()
|
| D | shrpx_http2_session.cc | 722 void Http2Session::add_downstream_connection(Http2DownstreamConnection *dconn) { in add_downstream_connection() argument
723 dconns_.append(dconn); in add_downstream_connection()
728 Http2DownstreamConnection *dconn) { in remove_downstream_connection() argument
730 dconns_.remove(dconn); in remove_downstream_connection()
731 dconn->detach_stream_data(); in remove_downstream_connection()
750 if (sd->dconn) { in remove_stream_data()
751 sd->dconn->detach_stream_data(); in remove_stream_data()
756 int Http2Session::submit_request(Http2DownstreamConnection *dconn, in submit_request() argument
771 dconn->attach_stream_data(sd.get()); in submit_request()
772 dconn->get_downstream()->set_downstream_stream_id(stream_id); in submit_request()
[all …]
|
| D | shrpx_http_downstream_connection.cc | 53 auto dconn = static_cast<HttpDownstreamConnection *>(conn->data); in timeoutcb() local
60 DCLOG(INFO, dconn) << "Time out"; in timeoutcb()
63 auto downstream = dconn->get_downstream(); in timeoutcb()
71 if (upstream->downstream_error(dconn, Downstream::EVENT_TIMEOUT) != 0) { in timeoutcb()
128 auto dconn = static_cast<HttpDownstreamConnection *>(conn->data); in connect_timeoutcb() local
129 auto addr = dconn->get_addr(); in connect_timeoutcb()
130 auto raddr = dconn->get_raddr(); in connect_timeoutcb()
132 DCLOG(WARN, dconn) << "Connect time out; addr=" in connect_timeoutcb()
137 auto downstream = dconn->get_downstream(); in connect_timeoutcb()
153 auto dconn = static_cast<HttpDownstreamConnection *>(conn->data); in readcb() local
[all …]
|
| D | shrpx_https_upstream.cc | 488 auto dconn = handler->get_downstream_connection(rv, downstream); in htp_hdrs_completecb() local
490 if (!dconn) { in htp_hdrs_completecb()
499 dconn_ptr = dconn.get(); in htp_hdrs_completecb()
501 if (downstream->attach_downstream_connection(std::move(dconn)) == 0) { in htp_hdrs_completecb()
831 int HttpsUpstream::downstream_read(DownstreamConnection *dconn) { in downstream_read() argument
832 auto downstream = dconn->get_downstream(); in downstream_read()
839 return downstream_eof(dconn); in downstream_read()
850 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
874 int HttpsUpstream::downstream_write(DownstreamConnection *dconn) { in downstream_write() argument
876 rv = dconn->on_write(); in downstream_write()
[all …]
|
| D | shrpx_client_handler.cc | 716 std::unique_ptr<DownstreamConnection> dconn) { in pool_downstream_connection() argument
717 if (!dconn->poolable()) { in pool_downstream_connection()
721 dconn->set_client_handler(nullptr); in pool_downstream_connection()
723 auto &group = dconn->get_downstream_addr_group(); in pool_downstream_connection()
726 CLOG(INFO, this) << "Pooling downstream connection DCONN:" << dconn.get() in pool_downstream_connection()
730 auto addr = dconn->get_addr(); in pool_downstream_connection()
732 dconn_pool->add_downstream_connection(std::move(dconn)); in pool_downstream_connection()
1037 auto dconn = std::make_unique<APIDownstreamConnection>(worker_); in get_downstream_connection() local
1038 dconn->set_client_handler(this); in get_downstream_connection()
1039 return dconn; in get_downstream_connection()
[all …]
|
| D | shrpx_upstream.h | 52 virtual int downstream_read(DownstreamConnection *dconn) = 0;
53 virtual int downstream_write(DownstreamConnection *dconn) = 0;
54 virtual int downstream_eof(DownstreamConnection *dconn) = 0;
55 virtual int downstream_error(DownstreamConnection *dconn, int events) = 0;
|
| D | shrpx_http2_session.h | 58 Http2DownstreamConnection *dconn; member
113 void add_downstream_connection(Http2DownstreamConnection *dconn);
114 void remove_downstream_connection(Http2DownstreamConnection *dconn);
118 int submit_request(Http2DownstreamConnection *dconn, const nghttp2_nv *nva,
127 int resume_data(Http2DownstreamConnection *dconn);
|
| D | shrpx_https_upstream.h | 57 virtual int downstream_read(DownstreamConnection *dconn);
58 virtual int downstream_write(DownstreamConnection *dconn);
59 virtual int downstream_eof(DownstreamConnection *dconn);
60 virtual int downstream_error(DownstreamConnection *dconn, int events);
|
| D | shrpx_http2_upstream.cc | 474 auto dconn = handler_->get_downstream_connection(rv, downstream); in initiate_downstream() local
475 if (!dconn) { in initiate_downstream()
492 dconn_ptr = dconn.get(); in initiate_downstream()
494 rv = downstream->attach_downstream_connection(std::move(dconn)); in initiate_downstream()
1250 int Http2Upstream::downstream_read(DownstreamConnection *dconn) { in downstream_read() argument
1251 auto downstream = dconn->get_downstream(); in downstream_read()
1263 dconn = nullptr; in downstream_read()
1271 dconn = nullptr; in downstream_read()
1276 return downstream_eof(dconn); in downstream_read()
1288 DCLOG(INFO, dconn) << "HTTP parser failure"; in downstream_read()
[all …]
|
| D | shrpx_http2_upstream.h | 61 virtual int downstream_read(DownstreamConnection *dconn);
62 virtual int downstream_write(DownstreamConnection *dconn);
63 virtual int downstream_eof(DownstreamConnection *dconn);
64 virtual int downstream_error(DownstreamConnection *dconn, int events);
|
| D | shrpx_http3_upstream.cc | 1036 int Http3Upstream::downstream_read(DownstreamConnection *dconn) { in downstream_read() argument
1037 auto downstream = dconn->get_downstream(); in downstream_read()
1049 dconn = nullptr; in downstream_read()
1057 dconn = nullptr; in downstream_read()
1062 return downstream_eof(dconn); in downstream_read()
1074 DCLOG(INFO, dconn) << "HTTP parser failure"; in downstream_read()
1077 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
1093 int Http3Upstream::downstream_write(DownstreamConnection *dconn) { in downstream_write() argument
1095 rv = dconn->on_write(); in downstream_write()
1097 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_write()
[all …]
|
| D | shrpx_downstream_connection_pool.h | 42 void add_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
44 void remove_downstream_connection(DownstreamConnection *dconn);
|
| D | shrpx_http3_upstream.h | 56 virtual int downstream_read(DownstreamConnection *dconn);
57 virtual int downstream_write(DownstreamConnection *dconn);
58 virtual int downstream_eof(DownstreamConnection *dconn);
59 virtual int downstream_error(DownstreamConnection *dconn, int events);
|
| D | shrpx_http2_downstream_connection.cc | 172 if (!sd || !sd->dconn) { in http2_data_read_callback()
175 auto dconn = sd->dconn; in http2_data_read_callback() local
176 auto downstream = dconn->get_downstream(); in http2_data_read_callback()
593 sd_->dconn = this; in attach_stream_data()
600 sd->dconn = nullptr; in detach_stream_data()
|
| D | shrpx_client_handler.h | 107 void pool_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
108 void remove_downstream_connection(DownstreamConnection *dconn);
|
| D | shrpx_downstream.cc | 94 auto dconn = downstream->get_downstream_connection(); in downstream_timeoutcb() local
96 if (dconn) { in downstream_timeoutcb()
97 dconn->on_timeout(); in downstream_timeoutcb()
226 std::unique_ptr<DownstreamConnection> dconn) { in attach_downstream_connection() argument
227 if (dconn->attach_downstream(this) != 0) { in attach_downstream_connection()
231 dconn_ = std::move(dconn); in attach_downstream_connection()
|
| D | shrpx_downstream.h | 342 int attach_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
|