From dc00073246a2822e1109d6a0d5a690b0f5a309b0 Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Tue, 20 Feb 2024 09:09:18 +0100 Subject: [PATCH] observer: fix row/column count test Signed-off-by: Csaba Kiraly --- DAS/observer.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/DAS/observer.py b/DAS/observer.py index f848837..0086120 100644 --- a/DAS/observer.py +++ b/DAS/observer.py @@ -28,9 +28,13 @@ class Observer: self.columns[c] += 1 for i in range(self.config.blockSizeC): - self.logger.debug("Row/Column %d have %d and %d validators assigned." % (i, self.rows[i], self.columns[i]), extra=self.format) - if self.rows[i] == 0 or self.columns[i] == 0: - self.logger.warning("There is a row/column that has not been assigned", extra=self.format) + self.logger.debug("Row %d have %d validators assigned." % (i, self.rows[i]), extra=self.format) + if self.rows[i] == 0: + self.logger.warning("There is a row that has not been assigned", extra=self.format) + for i in range(self.config.blockSizeR): + self.logger.debug("Column %d have %d validators assigned." % (i, self.columns[i]), extra=self.format) + if self.columns[i] == 0: + self.logger.warning("There is a column that has not been assigned", extra=self.format) def checkBroadcasted(self): """It checks how many broadcasted samples are still missing in the network."""