| /third_party/nghttp2/src/ |
| D | shrpx_downstream_connection.cc | 33 DownstreamConnection::DownstreamConnection() in DownstreamConnection() function in shrpx::DownstreamConnection
36 DownstreamConnection::~DownstreamConnection() {} in ~DownstreamConnection()
38 void DownstreamConnection::set_client_handler(ClientHandler *handler) { in set_client_handler()
42 ClientHandler *DownstreamConnection::get_client_handler() { in get_client_handler()
46 Downstream *DownstreamConnection::get_downstream() { return downstream_; } in get_downstream()
|
| D | shrpx_downstream_connection_pool.h | 35 class DownstreamConnection; variable
42 void add_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
43 std::unique_ptr<DownstreamConnection> pop_downstream_connection();
44 void remove_downstream_connection(DownstreamConnection *dconn);
48 std::set<DownstreamConnection *> pool_;
|
| D | shrpx_upstream.h | 38 class DownstreamConnection; variable
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_downstream_connection_pool.cc | 43 std::unique_ptr<DownstreamConnection> dconn) { in add_downstream_connection()
47 std::unique_ptr<DownstreamConnection>
54 auto dconn = std::unique_ptr<DownstreamConnection>(*it); in pop_downstream_connection()
61 DownstreamConnection *dconn) { in remove_downstream_connection()
|
| 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_downstream_connection.h | 42 class DownstreamConnection {
44 DownstreamConnection();
45 virtual ~DownstreamConnection();
|
| D | shrpx_client_handler.h | 47 class DownstreamConnection; variable
107 void pool_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
108 void remove_downstream_connection(DownstreamConnection *dconn);
115 std::unique_ptr<DownstreamConnection>
|
| 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.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_downstream.h | 58 class DownstreamConnection; variable
342 int attach_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);
344 DownstreamConnection *get_downstream_connection();
346 std::unique_ptr<DownstreamConnection> pop_downstream_connection();
572 std::unique_ptr<DownstreamConnection> dconn_;
|
| D | shrpx_health_monitor_downstream_connection.h | 34 class HealthMonitorDownstreamConnection : public DownstreamConnection {
|
| D | shrpx_null_downstream_connection.h | 35 class NullDownstreamConnection : public DownstreamConnection {
|
| D | shrpx_http2_downstream_connection.h | 42 class Http2DownstreamConnection : public DownstreamConnection {
|
| D | shrpx_api_downstream_connection.h | 66 class APIDownstreamConnection : public DownstreamConnection {
|
| D | shrpx_downstream.cc | 226 std::unique_ptr<DownstreamConnection> dconn) { in attach_downstream_connection()
254 std::unique_ptr<DownstreamConnection>(dconn_.release())); in detach_downstream_connection()
257 DownstreamConnection *Downstream::get_downstream_connection() { in get_downstream_connection()
261 std::unique_ptr<DownstreamConnection> Downstream::pop_downstream_connection() { in pop_downstream_connection()
274 return std::unique_ptr<DownstreamConnection>(dconn_.release()); in pop_downstream_connection()
|
| D | shrpx_https_upstream.cc | 499 DownstreamConnection *dconn_ptr; in htp_hdrs_completecb()
846 int HttpsUpstream::downstream_read(DownstreamConnection *dconn) { in downstream_read()
889 int HttpsUpstream::downstream_write(DownstreamConnection *dconn) { in downstream_write()
903 int HttpsUpstream::downstream_eof(DownstreamConnection *dconn) { in downstream_eof()
946 int HttpsUpstream::downstream_error(DownstreamConnection *dconn, int events) { in downstream_error()
1468 std::unique_ptr<DownstreamConnection> dconn; in on_downstream_reset()
|
| D | shrpx_http_downstream_connection.h | 44 class HttpDownstreamConnection : public DownstreamConnection {
|
| D | shrpx_http2_upstream.cc | 470 DownstreamConnection *dconn_ptr; in initiate_downstream()
1250 int Http2Upstream::downstream_read(DownstreamConnection *dconn) { in downstream_read()
1307 int Http2Upstream::downstream_write(DownstreamConnection *dconn) { in downstream_write()
1319 int Http2Upstream::downstream_eof(DownstreamConnection *dconn) { in downstream_eof()
1357 int Http2Upstream::downstream_error(DownstreamConnection *dconn, int events) { in downstream_error()
2092 std::unique_ptr<DownstreamConnection> dconn; in on_downstream_reset()
|
| D | shrpx_http3_upstream.cc | 1055 int Http3Upstream::downstream_read(DownstreamConnection *dconn) { in downstream_read()
1112 int Http3Upstream::downstream_write(DownstreamConnection *dconn) { in downstream_write()
1124 int Http3Upstream::downstream_eof(DownstreamConnection *dconn) { in downstream_eof()
1164 int Http3Upstream::downstream_error(DownstreamConnection *dconn, int events) { in downstream_error()
1617 std::unique_ptr<DownstreamConnection> dconn; in on_downstream_reset()
2349 DownstreamConnection *dconn_ptr; in initiate_downstream()
|
| D | shrpx_client_handler.cc | 716 std::unique_ptr<DownstreamConnection> dconn) { in pool_downstream_connection()
1022 std::unique_ptr<DownstreamConnection>
|