Lines Matching refs:dconn
503 auto dconn = handler->get_downstream_connection(rv, downstream);
505 if (!dconn) {
514 dconn_ptr = dconn.get();
516 if (downstream->attach_downstream_connection(std::move(dconn)) == 0) {
788 // dconn was deleted
846 int HttpsUpstream::downstream_read(DownstreamConnection *dconn) {
847 auto downstream = dconn->get_downstream();
854 return downstream_eof(dconn);
865 return downstream_error(dconn, Downstream::EVENT_ERROR);
889 int HttpsUpstream::downstream_write(DownstreamConnection *dconn) {
891 rv = dconn->on_write();
893 return downstream_error(dconn, Downstream::EVENT_ERROR);
903 int HttpsUpstream::downstream_eof(DownstreamConnection *dconn) {
904 auto downstream = dconn->get_downstream();
907 DCLOG(INFO, dconn) << "EOF";
917 DCLOG(INFO, dconn) << "The end of the response body was indicated by "
930 DCLOG(INFO, dconn) << "Return error reply";
946 int HttpsUpstream::downstream_error(DownstreamConnection *dconn, int events) {
947 auto downstream = dconn->get_downstream();
950 DCLOG(INFO, dconn) << "Network error/general error";
952 DCLOG(INFO, dconn) << "Timeout";
1126 auto dconn = downstream->get_downstream_connection();
1127 // dconn might be nullptr if this is non-final response from mruby.
1137 assert(dconn);
1138 const auto &group = dconn->get_downstream_addr_group();
1293 auto &group = dconn->get_downstream_addr_group();
1468 std::unique_ptr<DownstreamConnection> dconn;
1500 auto dconn = handler_->get_downstream_connection(rv, downstream_.get());
1501 if (!dconn) {
1505 rv = downstream_->attach_downstream_connection(std::move(dconn));