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

add shuffledDict helper 

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2023-02-14 11:45:55 +01:00
parent 1403ca7ad0
commit 9ab51278c8
No known key found for this signature in database
GPG Key ID: 0FE274EE8C95166E
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
DAS/validator.py
View File

@ -15,6 +15,12 @@ def shuffled(lis):
for index in random.sample(range(len(lis)), len(lis)): for index in random.sample(range(len(lis)), len(lis)):
yield lis[index] yield lis[index]
def shuffledDict(d):
lis = list(d.values())
# based on https://stackoverflow.com/a/60342323
for index in random.sample(range(len(d)), len(d)):
yield lis[index]
def sampleLine(line, limit): def sampleLine(line, limit):
""" sample up to 'limit' bits from a bitarray """ sample up to 'limit' bits from a bitarray
@ -233,7 +239,7 @@ class Validator:
line = self.getColumn(columnID) line = self.getColumn(columnID)
if line.any(): if line.any():
self.logger.debug("col %d -> %s", columnID, self.columnNeighbors[columnID] , extra=self.format) self.logger.debug("col %d -> %s", columnID, self.columnNeighbors[columnID] , extra=self.format)
for n in shuffled(list(self.columnNeighbors[columnID].values())): for n in shuffledDict(self.columnNeighbors[columnID]):
# if there is anything new to send, send it # if there is anything new to send, send it
toSend = line & ~n.sent & ~n.received toSend = line & ~n.sent & ~n.received
@ -245,7 +251,7 @@ class Validator:
line = self.getRow(rowID) line = self.getRow(rowID)
if line.any(): if line.any():
self.logger.debug("row %d -> %s", rowID, self.rowNeighbors[rowID], extra=self.format) self.logger.debug("row %d -> %s", rowID, self.rowNeighbors[rowID], extra=self.format)
for n in shuffled(list(self.rowNeighbors[rowID].values())): for n in shuffledDict(self.rowNeighbors[rowID]):
# if there is anything new to send, send it # if there is anything new to send, send it
toSend = line & ~n.sent & ~n.received toSend = line & ~n.sent & ~n.received