Lines Matching refs:dconn
1055 int Http3Upstream::downstream_read(DownstreamConnection *dconn) {
1056 auto downstream = dconn->get_downstream();
1067 // dconn was deleted
1068 dconn = nullptr;
1075 // dconn was deleted
1076 dconn = nullptr;
1081 return downstream_eof(dconn);
1093 DCLOG(INFO, dconn) << "HTTP parser failure";
1096 return downstream_error(dconn, Downstream::EVENT_ERROR);
1112 int Http3Upstream::downstream_write(DownstreamConnection *dconn) {
1114 rv = dconn->on_write();
1116 return downstream_error(dconn, Downstream::EVENT_ERROR);
1124 int Http3Upstream::downstream_eof(DownstreamConnection *dconn) {
1125 auto downstream = dconn->get_downstream();
1128 DCLOG(INFO, dconn) << "EOF. stream_id=" << downstream->get_stream_id();
1134 // dconn was deleted
1135 dconn = nullptr;
1164 int Http3Upstream::downstream_error(DownstreamConnection *dconn, int events) {
1165 auto downstream = dconn->get_downstream();
1169 DCLOG(INFO, dconn) << "Downstream network/general error";
1171 DCLOG(INFO, dconn) << "Timeout";
1174 DCLOG(INFO, dconn) << "Note: this is tunnel connection";
1181 // dconn was deleted
1182 dconn = nullptr;
1292 auto dconn = downstream->get_downstream_connection();
1293 const auto &group = dconn->get_downstream_addr_group();
1301 // Returning -1 will signal deletion of dconn.
1317 // Returning -1 will signal deletion of dconn.
1384 auto dconn = downstream->get_downstream_connection();
1385 assert(dconn);
1386 auto &group = dconn->get_downstream_addr_group();
1617 std::unique_ptr<DownstreamConnection> dconn;
1629 auto dconn = handler_->get_downstream_connection(rv, downstream);
1630 if (!dconn) {
1634 rv = downstream->attach_downstream_connection(std::move(dconn));
2353 auto dconn = handler_->get_downstream_connection(rv, downstream);
2354 if (!dconn) {
2372 dconn_ptr = dconn.get();
2374 rv = downstream->attach_downstream_connection(std::move(dconn));