codex-storage
/
das-research
mirror of https://github.com/codex-storage/das-research.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

observer: fix row/column count test 

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2024-02-20 09:09:18 +01:00
parent e8c27531bd
commit dc00073246
No known key found for this signature in database
GPG Key ID: 0FE274EE8C95166E
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
DAS/observer.py
View File

@ -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."""