merge in improved replication lag

cloudamqp · May 20, 2024 · 50ea08a · 50ea08a
1 parent 1fe2e67
commit 50ea08a
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/lavinmq/replication/follower.cr b/src/lavinmq/replication/follower.cr
@@ -71,12 +71,11 @@ module LavinMQ
 
       private def action_loop(socket = @lz4)
         while action = @actions.receive?
-          sent_bytes = action.send(socket)
+          action.send(socket)
           while action2 = @actions.try_receive?
-            sent_bytes += action2.send(socket)
+            action2.send(socket)
           end
           socket.flush
-          @sent_bytes += sent_bytes
         end
       rescue IO::Error
       ensure