Only log progress if long queue

cloudamqp · Oct 18, 2024 · 7918942 · 7918942
1 parent 36e793c
commit 7918942
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/lavinmq/queue/message_store.cr b/src/lavinmq/queue/message_store.cr
@@ -350,7 +350,7 @@ module LavinMQ
       # Populate bytesize, size and segment_msg_count
       private def load_stats_from_segments : Nil
         counter = 0
-        is_long_queue = @segments.size > 128
+        is_long_queue = @segments.size > 255
         if is_long_queue
           @log.info { "Loading #{@segments.size} segments" }
         else
@@ -373,7 +373,11 @@ module LavinMQ
           end
           mfile.pos = 4
           mfile.unmap # will be mmap on demand
-          @log.info { "Loaded #{counter}/#{@segments.size} segments" } if (counter &+= 1) % 128 == 0
+          if is_long_queue
+            @log.info { "Loaded #{counter}/#{@segments.size} segments" } if (counter &+= 1) % 128 == 0
+          else
+            @log.debug { "Loaded #{counter}/#{@segments.size} segments" } if (counter &+= 1) % 128 == 0
+          end
           @segment_msg_count[seg] = count
         end
         @log.info { "Loaded #{counter} segments" }