From ead127e73edc124b8b833e7dfcd274822b54057e Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Fri, 24 Feb 2023 08:42:35 +0100 Subject: [PATCH] change defaults to queue per p2p link Signed-off-by: Csaba Kiraly --- DAS/validator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/DAS/validator.py b/DAS/validator.py index 1b15fb4..00acc91 100644 --- a/DAS/validator.py +++ b/DAS/validator.py @@ -141,7 +141,7 @@ class Validator: self.repairOnTheFly = True self.sendLineUntil = (self.shape.blockSize + 1) // 2 # stop sending on a p2p link if at least this amount of samples passed - self.perNeighborQueue = False # queue incoming messages to outgoing connections on arrival (as typical GossipSub impl) + self.perNeighborQueue = True # queue incoming messages to outgoing connections on arrival (as typical GossipSub impl) self.perNodeQueue = False # keep a global queue of incoming messages for later sequential dispatch self.shuffleLines = True # shuffle the order of rows/columns in each iteration while trying to send self.shuffleNeighbors = True # shuffle the order of neighbors when sending the same segment to each neighbor