From 2ff4bf4825906429917f6ddeee72228898cc955a Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Fri, 1 Mar 2024 15:29:16 +0100 Subject: [PATCH] add forwardOnReceive Normally, nodes would queue messages for forwarding to mesh neighbors right on receive Signed-off-by: Csaba Kiraly --- DAS/validator.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/DAS/validator.py b/DAS/validator.py index 2b489b8..f7cb014 100644 --- a/DAS/validator.py +++ b/DAS/validator.py @@ -111,6 +111,7 @@ class Validator: self.dumbRandomScheduler = False # dumb random scheduler self.segmentShuffleScheduler = True # send each segment that's worth sending once in shuffled order, then repeat self.segmentShuffleSchedulerPersist = True # Persist scheduler state between timesteps + self.forwardOnReceive = True # forward segments as soon as received def logIDs(self): """It logs the assigned rows and columns.""" @@ -196,8 +197,9 @@ class Validator: if not self.receivedBlock.getSegment(rID, cID): self.logger.trace("Recv new: %d->%d: %d,%d", src, self.ID, rID, cID, extra=self.format) self.receivedBlock.setSegment(rID, cID) - if self.perNodeQueue or self.perNeighborQueue: - self.receivedQueue.append((rID, cID)) + if self.forwardOnReceive: + if self.perNodeQueue or self.perNeighborQueue: + self.receivedQueue.append((rID, cID)) else: self.logger.trace("Recv DUP: %d->%d: %d,%d", src, self.ID, rID, cID, extra=self.format) self.statsRxDupInSlot += 1