From 6fc380d2c82ab6ac98af778c9f874c6172fa35a6 Mon Sep 17 00:00:00 2001 From: "simon.kagstrom" Date: Mon, 22 Feb 2010 06:22:54 +0000 Subject: [PATCH] Fix message dequeueing --- network-broker/network-broker | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/network-broker/network-broker b/network-broker/network-broker index 0b2c8e5..0dc853d 100755 --- a/network-broker/network-broker +++ b/network-broker/network-broker @@ -641,11 +641,14 @@ class Broker(SocketServer.UDPServer): def dequeue_old_messages(self): now = time.mktime(time.localtime()) + to_delete = 0 + for msg in self.messages: diff = now - msg.get_timestamp() # Older than one day? if diff > 24 * 60 * 60: - del msg + to_delete = to_delete + 1 + self.messages = self.messages[ to_delete : ] def ping_all_peers(self): """Ping all peers (to see that they are alive)"""