Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-04-18 05:56:31 +03:00
Code Issues Packages Projects Releases Wiki Activity

actually drain mailbox

Browse Source
This commit is contained in:
holger krekel
2024-12-17 14:28:40 +01:00
parent 5238c85dc5
commit 30e0cd7328
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
python/tests/test_5_simulation.py
View File

@@ -17,11 +17,11 @@ class Relay:
return self.peers.values()
def receive_all(self, peers=None):
peers = peers if peers else list(self.peers.values())
peers = peers if peers else self.peers.values()
for peer in peers:
# drain peer mailbox by reading messages from each sender separately
for from_peer in self.peers.values():
for msg in peer.from2mailbox.get(from_peer, []):
for msg in peer.from2mailbox.pop(from_peer, []):
msg.receive_imf(peer)
peer.current_clock = max(peer.current_clock, msg.clock) + 1