Searched refs:DownstreamConnection (Results 1 – 17 of 17) sorted by relevance
33 DownstreamConnection::DownstreamConnection() in DownstreamConnection() function in shrpx::DownstreamConnection36 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()
35 class DownstreamConnection; variable42 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_;
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()
38 class DownstreamConnection; variable52 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;
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);
42 class DownstreamConnection {44 DownstreamConnection();45 virtual ~DownstreamConnection();
47 class DownstreamConnection; variable101 void pool_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);102 void remove_downstream_connection(DownstreamConnection *dconn);109 std::unique_ptr<DownstreamConnection>
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);
54 class DownstreamConnection; variable337 int attach_downstream_connection(std::unique_ptr<DownstreamConnection> dconn);339 DownstreamConnection *get_downstream_connection();341 std::unique_ptr<DownstreamConnection> pop_downstream_connection();558 std::unique_ptr<DownstreamConnection> dconn_;
34 class HealthMonitorDownstreamConnection : public DownstreamConnection {
42 class Http2DownstreamConnection : public DownstreamConnection {
66 class APIDownstreamConnection : public DownstreamConnection {
44 class HttpDownstreamConnection : public DownstreamConnection {
216 std::unique_ptr<DownstreamConnection> dconn) { in attach_downstream_connection()244 std::unique_ptr<DownstreamConnection>(dconn_.release())); in detach_downstream_connection()247 DownstreamConnection *Downstream::get_downstream_connection() { in get_downstream_connection()251 std::unique_ptr<DownstreamConnection> Downstream::pop_downstream_connection() { in pop_downstream_connection()264 return std::unique_ptr<DownstreamConnection>(dconn_.release()); in pop_downstream_connection()
460 DownstreamConnection *dconn_ptr; in htp_hdrs_completecb()784 int HttpsUpstream::downstream_read(DownstreamConnection *dconn) { in downstream_read()827 int HttpsUpstream::downstream_write(DownstreamConnection *dconn) { in downstream_write()841 int HttpsUpstream::downstream_eof(DownstreamConnection *dconn) { in downstream_eof()884 int HttpsUpstream::downstream_error(DownstreamConnection *dconn, int events) { in downstream_error()1424 std::unique_ptr<DownstreamConnection> dconn; in on_downstream_reset()
463 DownstreamConnection *dconn_ptr; in initiate_downstream()1240 int Http2Upstream::downstream_read(DownstreamConnection *dconn) { in downstream_read()1297 int Http2Upstream::downstream_write(DownstreamConnection *dconn) { in downstream_write()1309 int Http2Upstream::downstream_eof(DownstreamConnection *dconn) { in downstream_eof()1347 int Http2Upstream::downstream_error(DownstreamConnection *dconn, int events) { in downstream_error()2074 std::unique_ptr<DownstreamConnection> dconn; in on_downstream_reset()
651 std::unique_ptr<DownstreamConnection> dconn) { in pool_downstream_connection()891 std::unique_ptr<DownstreamConnection>