Lines Matching refs:dconn
474 auto dconn = handler_->get_downstream_connection(rv, downstream);
475 if (!dconn) {
492 dconn_ptr = dconn.get();
494 rv = downstream->attach_downstream_connection(std::move(dconn));
1250 int Http2Upstream::downstream_read(DownstreamConnection *dconn) {
1251 auto downstream = dconn->get_downstream();
1262 // dconn was deleted
1263 dconn = nullptr;
1270 // dconn was deleted
1271 dconn = nullptr;
1276 return downstream_eof(dconn);
1288 DCLOG(INFO, dconn) << "HTTP parser failure";
1291 return downstream_error(dconn, Downstream::EVENT_ERROR);
1307 int Http2Upstream::downstream_write(DownstreamConnection *dconn) {
1309 rv = dconn->on_write();
1311 return downstream_error(dconn, Downstream::EVENT_ERROR);
1319 int Http2Upstream::downstream_eof(DownstreamConnection *dconn) {
1320 auto downstream = dconn->get_downstream();
1323 DCLOG(INFO, dconn) << "EOF. stream_id=" << downstream->get_stream_id();
1329 // dconn was deleted
1330 dconn = nullptr;
1357 int Http2Upstream::downstream_error(DownstreamConnection *dconn, int events) {
1358 auto downstream = dconn->get_downstream();
1362 DCLOG(INFO, dconn) << "Downstream network/general error";
1364 DCLOG(INFO, dconn) << "Timeout";
1367 DCLOG(INFO, dconn) << "Note: this is tunnel connection";
1374 // dconn was deleted
1375 dconn = nullptr;
1675 auto dconn = downstream->get_downstream_connection();
1676 const auto &group = dconn->get_downstream_addr_group();
1684 // Returning -1 will signal deletion of dconn.
1700 // Returning -1 will signal deletion of dconn.
1796 auto dconn = downstream->get_downstream_connection();
1797 assert(dconn);
1798 auto &group = dconn->get_downstream_addr_group();
2092 std::unique_ptr<DownstreamConnection> dconn;
2104 auto dconn = handler_->get_downstream_connection(rv, downstream);
2105 if (!dconn) {
2109 rv = downstream->attach_downstream_connection(std::move(dconn));