diff --git a/DAS/validator.py b/DAS/validator.py index 725bc98..26d4e6c 100644 --- a/DAS/validator.py +++ b/DAS/validator.py @@ -364,6 +364,7 @@ class Validator: """ Send as much as we can in the timeslot, limited by bwUplink """ + # process node level send queue while self.sendQueue: (rID, cID) = self.sendQueue[0] @@ -383,6 +384,7 @@ class Validator: self.sendQueue.popleft() + # process neighbor level send queues in shuffled breadth-first order progress = True while (progress): progress = False