status-im/das-research
2
0
Fork 0
mirror of https://github.com/status-im/das-research.git synced 2025-02-23 20:08:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

add to receivedQueue also in row/column receive code

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

6
DAS/validator.py
View File

@ -173,6 +173,9 @@ class Validator:
# register receive so that we are not sending back # register receive so that we are not sending back
self.columnNeighbors[id][src].receiving |= column self.columnNeighbors[id][src].receiving |= column
self.receivedBlock.mergeColumn(id, column) self.receivedBlock.mergeColumn(id, column)
for i in range(len(column)):
if column[i]:
self.receivedQueue.append((i, id))
self.statsRxInSlot += column.count(1) self.statsRxInSlot += column.count(1)
else: else:
pass pass
@ -183,6 +186,9 @@ class Validator:
# register receive so that we are not sending back # register receive so that we are not sending back
self.rowNeighbors[id][src].receiving |= row self.rowNeighbors[id][src].receiving |= row
self.receivedBlock.mergeRow(id, row) self.receivedBlock.mergeRow(id, row)
for i in range(len(row)):
if row[i]:
self.receivedQueue.append((id, i))
self.statsRxInSlot += row.count(1) self.statsRxInSlot += row.count(1)
else: else:
pass pass