From: Remi Gacogne <remi.gacogne@powerdns.com>
Date: Fri, 22 Dec 2023 16:31:56 +0000 (+0100)
Subject: dnsdist: Try flushing egress data after processing readable streams
X-Git-Tag: auth-4.9.0-alpha1~18^2~3
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=4cec715d6ae84060630ce761e91a9a9da53e6cf4;p=thirdparty%2Fpdns.git

dnsdist: Try flushing egress data after processing readable streams
---

diff --git a/pdns/dnsdistdist/doh3.cc b/pdns/dnsdistdist/doh3.cc
index b6a24d77ce..3f724ff7e8 100644
--- a/pdns/dnsdistdist/doh3.cc
+++ b/pdns/dnsdistdist/doh3.cc
@@ -898,6 +898,8 @@ static void handleSocketReadable(DOH3Frontend& frontend, ClientState& clientStat
       }
 
       processH3Events(clientState, frontend, conn->get(), client, serverConnID);
+
+      flushEgress(sock, conn->get().d_conn, client);
     }
     else {
       DEBUGLOG("Connection not established");
diff --git a/pdns/dnsdistdist/doq.cc b/pdns/dnsdistdist/doq.cc
index 3fed6bb0ad..26c967d840 100644
--- a/pdns/dnsdistdist/doq.cc
+++ b/pdns/dnsdistdist/doq.cc
@@ -713,6 +713,8 @@ static void handleSocketReadable(DOQFrontend& frontend, ClientState& clientState
       while (quiche_stream_iter_next(readable.get(), &streamID)) {
         handleReadableStream(frontend, clientState, *conn, streamID, client, serverConnID);
       }
+
+      flushEgress(sock, conn->get().d_conn, client);
     }
     else {
       DEBUGLOG("Connection not established");