Introduce a "too large" counter for the framestream remote logger

diff --git a/pdns/fstrm_logger.cc b/pdns/fstrm_logger.cc
index 7c839e7b19d61e71e24298d89d79555e7b566940..9e224790fd67cd38dca09766e84e115c2ebcd51e 100644 (file)
--- a/pdns/fstrm_logger.cc
+++ b/pdns/fstrm_logger.cc
@@ -170,7 +170,7 @@ RemoteLoggerInterface::Result FrameStreamLogger::queueData(const std::string& da
   }
   uint8_t* frame = (uint8_t*)malloc(data.length()); // NOLINT: it's the API
   if (frame == nullptr) {
-    ++d_queueFullDrops; // XXX separate count?
+    ++d_tooLargeCount;
     return Result::TooLarge;
   }
   memcpy(frame, data.c_str(), data.length());

diff --git a/pdns/fstrm_logger.hh b/pdns/fstrm_logger.hh
index 711c65a17189388daa39006b9b1f55a946840c42..44657247d86aafc16e362b100c709e08c611f932 100644 (file)
--- a/pdns/fstrm_logger.hh
+++ b/pdns/fstrm_logger.hh
@@ -63,7 +63,7 @@ public:
   {
     return Stats{.d_queued = d_framesSent,
                  .d_pipeFull = d_queueFullDrops,
-                 .d_tooLarge = 0,
+                 .d_tooLarge = d_tooLargeCount,
                  .d_otherError = d_permanentFailures};
   }
 
@@ -81,6 +81,7 @@ private:
   struct fstrm_iothr* d_iothr{nullptr};
   std::atomic<uint64_t> d_framesSent{0};
   std::atomic<uint64_t> d_queueFullDrops{0};
+  std::atomic<uint64_t> d_tooLargeCount{0};
   std::atomic<uint64_t> d_permanentFailures{0};
 
   void cleanup();