From 7c0fcaba7891efe6ff73956cc0270d49007fb1a4 Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Tue, 14 Feb 2023 11:51:04 +0100 Subject: [PATCH] add validator.perNodeQueue conf option Signed-off-by: Csaba Kiraly --- DAS/validator.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/DAS/validator.py b/DAS/validator.py index 6c5575c..88e32d6 100644 --- a/DAS/validator.py +++ b/DAS/validator.py @@ -119,6 +119,7 @@ class Validator: # TODO: this should be a parameter self.bwUplink = 110 if not self.amIproposer else 2200 # approx. 10Mbps and 200Mbps + self.perNodeQueue = False # keep a global queue of incoming messages for later sequential dispatch self.sched = self.nextToSend() def logIDs(self): @@ -230,7 +231,8 @@ class Validator: neigh.receiving.setall(0) # add newly received segments to the send queue - self.sendQueue.extend(self.receivedQueue) + if self.perNeighborQueue: + self.sendQueue.extend(self.receivedQueue) self.receivedQueue.clear() def updateStats(self):