From c2a08ef35588ccd512a7ea7c9898c83e5fd2864e Mon Sep 17 00:00:00 2001
From: Mark Qvist <mark@unsigned.io>
Date: Tue, 21 Jan 2025 20:44:11 +0100
Subject: [PATCH] Enqueue and batch process distribution queue mappings

---
 LXMF/LXMRouter.py | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 deletions(-)

diff --git a/LXMF/LXMRouter.py b/LXMF/LXMRouter.py
index 1e62914..ee1dca8 100644
--- a/LXMF/LXMRouter.py
+++ b/LXMF/LXMRouter.py
@@ -656,15 +656,16 @@ class LXMRouter:
             time.sleep(LXMRouter.PROCESSING_INTERVAL)
 
     def flush_queues(self):
-        self.flush_peer_distribution_queue()
-        RNS.log("Calculating peer distribution queue mappings...", RNS.LOG_DEBUG); st = time.time()
-        for peer_id in self.peers.copy():
-            if peer_id in self.peers:
-                peer = self.peers[peer_id]
-                if peer.queued_items():
-                    peer.process_queues()
+        if len(self.peers) > 0:
+            self.flush_peer_distribution_queue()
+            RNS.log("Calculating peer distribution queue mappings...", RNS.LOG_DEBUG); st = time.time()
+            for peer_id in self.peers.copy():
+                if peer_id in self.peers:
+                    peer = self.peers[peer_id]
+                    if peer.queued_items():
+                        peer.process_queues()
 
-        RNS.log(f"Distribution queue mapping completed in {RNS.prettytime(time.time()-st)}", RNS.LOG_DEBUG)
+            RNS.log(f"Distribution queue mapping completed in {RNS.prettytime(time.time()-st)}", RNS.LOG_DEBUG)
 
     def clean_links(self):
         closed_links = []