Lines Matching defs:HttpDownstreamConnection

53   auto dconn = static_cast<HttpDownstreamConnection *>(conn->data);
128   auto dconn = static_cast<HttpDownstreamConnection *>(conn->data);
153   auto dconn = static_cast<HttpDownstreamConnection *>(conn->data);
174   auto dconn = static_cast<HttpDownstreamConnection *>(conn->data);
194   auto dconn = static_cast<HttpDownstreamConnection *>(conn->data);
204 HttpDownstreamConnection::HttpDownstreamConnection(
212       on_read_(&HttpDownstreamConnection::noop),
213       on_write_(&HttpDownstreamConnection::noop),
214       signal_write_(&HttpDownstreamConnection::noop),
226 HttpDownstreamConnection::~HttpDownstreamConnection() {
237 int HttpDownstreamConnection::attach_downstream(Downstream *downstream) {
292 int HttpDownstreamConnection::initiate_connection() {
460     on_write_ = &HttpDownstreamConnection::write_first;
471 int HttpDownstreamConnection::push_request_headers() {
730 int HttpDownstreamConnection::process_blocked_request_buf() {
757 int HttpDownstreamConnection::push_upload_data_chunk(const uint8_t *data,
790 int HttpDownstreamConnection::end_upload_data() {
810 void HttpDownstreamConnection::end_upload_data_chunk() {
826 void remove_from_pool(HttpDownstreamConnection *dconn) {
836   auto dconn = static_cast<HttpDownstreamConnection *>(conn->data);
849   auto dconn = static_cast<HttpDownstreamConnection *>(conn->data);
864 void HttpDownstreamConnection::detach_downstream(Downstream *downstream) {
887 void HttpDownstreamConnection::pause_read(IOCtrlReason reason) {
891 int HttpDownstreamConnection::resume_read(IOCtrlReason reason,
903 void HttpDownstreamConnection::force_resume_read() {
1205 int HttpDownstreamConnection::write_first() {
1221     on_write_ = &HttpDownstreamConnection::write_tls;
1223     on_write_ = &HttpDownstreamConnection::write_clear;
1248 int HttpDownstreamConnection::read_clear() {
1287 int HttpDownstreamConnection::write_clear() {
1312       on_write_ = &HttpDownstreamConnection::noop;
1333 int HttpDownstreamConnection::tls_handshake() {
1362   signal_write_ = &HttpDownstreamConnection::actual_signal_write;
1369   on_read_ = &HttpDownstreamConnection::read_tls;
1370   on_write_ = &HttpDownstreamConnection::write_first;
1377 int HttpDownstreamConnection::read_tls() {
1418 int HttpDownstreamConnection::write_tls() {
1448       on_write_ = &HttpDownstreamConnection::noop;
1469 int HttpDownstreamConnection::process_input(const uint8_t *data,
1540 int HttpDownstreamConnection::connected() {
1570     on_read_ = &HttpDownstreamConnection::tls_handshake;
1571     on_write_ = &HttpDownstreamConnection::tls_handshake;
1576   signal_write_ = &HttpDownstreamConnection::actual_signal_write;
1583   on_read_ = &HttpDownstreamConnection::read_clear;
1584   on_write_ = &HttpDownstreamConnection::write_first;
1589 int HttpDownstreamConnection::on_read() { return on_read_(*this); }
1591 int HttpDownstreamConnection::on_write() { return on_write_(*this); }
1593 void HttpDownstreamConnection::on_upstream_change(Upstream *upstream) {}
1595 void HttpDownstreamConnection::signal_write() { signal_write_(*this); }
1597 int HttpDownstreamConnection::actual_signal_write() {
1602 int HttpDownstreamConnection::noop() { return 0; }
1605 HttpDownstreamConnection::get_downstream_addr_group() const {
1609 DownstreamAddr *HttpDownstreamConnection::get_addr() const { return addr_; }
1611 bool HttpDownstreamConnection::poolable() const {
1615 const Address *HttpDownstreamConnection::get_raddr() const { return raddr_; }