doq: fix formating

diff --git a/pdns/dnsdistdist/doq.cc b/pdns/dnsdistdist/doq.cc
index 0617ffcd862796f8d80f7a3ba37a8481e88c227b..a1ce4c647837fd3b1268045a5d3b7525b9598662 100644 (file)
--- a/pdns/dnsdistdist/doq.cc
+++ b/pdns/dnsdistdist/doq.cc
@@ -73,7 +73,6 @@ struct DOQServerConfig
       d_responseSender = std::move(sender);
       d_responseReceiver = std::move(receiver);
     }
-
   }
   DOQServerConfig(const DOQServerConfig&) = delete;
   DOQServerConfig(DOQServerConfig&&) = default;
@@ -440,7 +439,8 @@ static void sendBackDOQUnit(DOQUnitUniquePtr&& du, const char* description)
     if (!du->dsc->d_responseSender.send(std::move(du))) {
       vinfolog("Unable to pass a %s to the DoQ worker thread because the pipe is full", description);
     }
-  } catch (const std::exception& e) {
+  }
+  catch (const std::exception& e) {
     vinfolog("Unable to pass a %s to the DoQ worker thread because we couldn't write to the pipe: %s", description, e.what());
   }
 }
@@ -676,18 +676,17 @@ static void doq_dispatch_query(DOQServerConfig& dsc, PacketBuffer&& query, const
 
 static void flushResponses(pdns::channel::Receiver<DOQUnit>& receiver)
 {
-  for(;;) {
+  for (;;) {
     try {
       auto tmp = receiver.receive();
       if (!tmp) {
-        return ;
+        return;
       }
 
       auto du = std::move(*tmp);
       auto conn = getConnection(du->serverConnID);
 
       handleResponse(*du->dsc->df, *conn, du->streamID, du->response);
-
     }
     catch (const std::exception& e) {
       errlog("Error while processing response received over DoQ: %s", e.what());

diff --git a/pdns/dnsdistdist/doq.hh b/pdns/dnsdistdist/doq.hh
index 112fa09751c190eaf0855a510fc25023640c19af..c2ebb685e3a0250ca5c37859256c9f6638cfe96c 100644 (file)
--- a/pdns/dnsdistdist/doq.hh
+++ b/pdns/dnsdistdist/doq.hh
@@ -48,7 +48,7 @@ struct DOQFrontend
 #ifdef __linux__
   // On Linux this gives us 128k pending queries (default is 8192 queries),
   // which should be enough to deal with huge spikes
-  uint32_t d_internalPipeBufferSize{1024*1024};
+  uint32_t d_internalPipeBufferSize{1024 * 1024};
 #else
   uint32_t d_internalPipeBufferSize{0};
 #endif