| /third_party/nghttp2/src/ |
| H A D | shrpx_downstream_connection_pool.cc | 35 for (auto dconn : pool_) { in remove_all()
36 delete dconn; in remove_all()
43 std::unique_ptr<DownstreamConnection> dconn) { in add_downstream_connection()
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()
62 pool_.erase(dconn); in remove_downstream_connection()
63 delete dconn; in remove_downstream_connection()
42 add_downstream_connection( std::unique_ptr<DownstreamConnection> dconn) add_downstream_connection() argument
60 remove_downstream_connection( DownstreamConnection *dconn) remove_downstream_connection() argument
|
| H A 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()
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 in submit_request()
727 remove_downstream_connection( Http2DownstreamConnection *dconn) remove_downstream_connection() argument
796 resume_data(Http2DownstreamConnection *dconn) resume_data() argument
841 auto dconn = sd->dconn; on_stream_close_callback() local
1577 auto dconn = sd->dconn; send_data_callback() local
[all...] |
| H A 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()
68 // Do this so that dconn is not pooled 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 in connect_timeoutcb()
153 auto dconn = static_cast<HttpDownstreamConnection *>(conn->data); readcb() local
174 auto dconn = static_cast<HttpDownstreamConnection *>(conn->data); writecb() local
194 auto dconn = static_cast<HttpDownstreamConnection *>(conn->data); connectcb() local
826 remove_from_pool(HttpDownstreamConnection *dconn) remove_from_pool() argument
836 auto dconn = static_cast<HttpDownstreamConnection *>(conn->data); idle_readcb() local
849 auto dconn = static_cast<HttpDownstreamConnection *>(conn->data); idle_timeoutcb() local
952 auto dconn = downstream->get_downstream_connection(); htp_hdrs_completecb() local
[all...] |
| H A D | shrpx_https_upstream.cc | 503 auto dconn = handler->get_downstream_connection(rv, downstream); in htp_hdrs_completecb() local
505 if (!dconn) { in htp_hdrs_completecb()
514 dconn_ptr = dconn.get(); in htp_hdrs_completecb()
516 if (downstream->attach_downstream_connection(std::move(dconn)) == 0) { in htp_hdrs_completecb()
788 // dconn was deleted in on_write()
846 int HttpsUpstream::downstream_read(DownstreamConnection *dconn) { in downstream_read() argument
847 auto downstream = dconn->get_downstream(); in downstream_read()
854 return downstream_eof(dconn); in downstream_read()
865 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
889 int HttpsUpstream::downstream_write(DownstreamConnection *dconn) { in downstream_write() argument
903 downstream_eof(DownstreamConnection *dconn) downstream_eof() argument
946 downstream_error(DownstreamConnection *dconn, int events) downstream_error() argument
1126 auto dconn = downstream->get_downstream_connection(); on_downstream_header_complete() local
1468 std::unique_ptr<DownstreamConnection> dconn; on_downstream_reset() local
1500 auto dconn = handler_->get_downstream_connection(rv, downstream_.get()); on_downstream_reset() local
[all...] |
| H A D | shrpx_client_handler.cc | 716 std::unique_ptr<DownstreamConnection> dconn) { in pool_downstream_connection()
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()
715 pool_downstream_connection( std::unique_ptr<DownstreamConnection> dconn) pool_downstream_connection() argument
1042 auto dconn = std::make_unique<HealthMonitorDownstreamConnection>(); get_downstream_connection() local
1109 auto dconn = std::make_unique<NullDownstreamConnection>(group); get_downstream_connection() local
1120 auto dconn = addr->dconn_pool->pop_downstream_connection(); get_downstream_connection() local
1151 auto dconn = std::make_unique<Http2DownstreamConnection>(http2session); get_downstream_connection() local
[all...] |
| H A 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;
|
| H A 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);
|
| H A 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()
1262 // dconn was deleted in downstream_read()
1263 dconn = nullptr; in downstream_read()
1270 // dconn was deleted in downstream_read()
1271 dconn in downstream_read()
1307 downstream_write(DownstreamConnection *dconn) downstream_write() argument
1319 downstream_eof(DownstreamConnection *dconn) downstream_eof() argument
1357 downstream_error(DownstreamConnection *dconn, int events) downstream_error() argument
1675 auto dconn = downstream->get_downstream_connection(); on_downstream_header_complete() local
1796 auto dconn = downstream->get_downstream_connection(); on_downstream_header_complete() local
2092 std::unique_ptr<DownstreamConnection> dconn; on_downstream_reset() local
2104 auto dconn = handler_->get_downstream_connection(rv, downstream); on_downstream_reset() local
[all...] |
| H A 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);
|
| H A 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);
|
| H A D | shrpx_http3_upstream.cc | 1055 int Http3Upstream::downstream_read(DownstreamConnection *dconn) { in downstream_read() argument
1056 auto downstream = dconn->get_downstream(); in downstream_read()
1067 // dconn was deleted in downstream_read()
1068 dconn = nullptr; in downstream_read()
1075 // dconn was deleted in downstream_read()
1076 dconn = nullptr; in downstream_read()
1081 return downstream_eof(dconn); in downstream_read()
1093 DCLOG(INFO, dconn) << "HTTP parser failure"; in downstream_read()
1096 return downstream_error(dconn, Downstream::EVENT_ERROR); in downstream_read()
1112 int Http3Upstream::downstream_write(DownstreamConnection *dconn) { in downstream_write() argument
1124 downstream_eof(DownstreamConnection *dconn) downstream_eof() argument
1164 downstream_error(DownstreamConnection *dconn, int events) downstream_error() argument
1292 auto dconn = downstream->get_downstream_connection(); on_downstream_header_complete() local
1384 auto dconn = downstream->get_downstream_connection(); on_downstream_header_complete() local
1617 std::unique_ptr<DownstreamConnection> dconn; on_downstream_reset() local
1629 auto dconn = handler_->get_downstream_connection(rv, downstream); on_downstream_reset() local
2353 auto dconn = handler_->get_downstream_connection(rv, downstream); initiate_downstream() local
[all...] |
| H A D | shrpx_downstream_connection_pool.h | 42 void add_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
44 void remove_downstream_connection(DownstreamConnection *dconn);
|
| H A 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);
|
| H A 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()
586 // It is possible sd->dconn is not NULL. sd is detached when in attach_stream_data()
593 sd_->dconn = this; in attach_stream_data()
600 sd->dconn = nullptr; in detach_stream_data()
|
| H A D | shrpx_client_handler.h | 107 void pool_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
108 void remove_downstream_connection(DownstreamConnection *dconn);
|
| H A 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()
227 if (dconn->attach_downstream(this) != 0) { in attach_downstream_connection()
231 dconn_ = std::move(dconn); in attach_downstream_connection()
225 attach_downstream_connection( std::unique_ptr<DownstreamConnection> dconn) attach_downstream_connection() argument
|
| H A D | shrpx_downstream.h | 342 int attach_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
|