status-im
/
das-research
mirror of https://github.com/status-im/das-research.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

factorize restore 

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2023-02-28 12:24:37 +01:00
parent 82ee2b5189
commit b5368b4e43
No known key found for this signature in database
GPG Key ID: 0FE274EE8C95166E
1 changed files with 24 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
DAS/validator.py
View File

@ -437,6 +437,9 @@ class Validator:
"""It restores the rows assigned to the validator, that can be repaired.""" """It restores the rows assigned to the validator, that can be repaired."""
if self.repairOnTheFly: if self.repairOnTheFly:
for id in self.rowIDs: for id in self.rowIDs:
self.restoreRow(id)
def restoreRow(self, id):
rep = self.block.repairRow(id) rep = self.block.repairRow(id)
if (rep.any()): if (rep.any()):
# If operation is based on send queues, segments should # If operation is based on send queues, segments should
@ -451,6 +454,9 @@ class Validator:
"""It restores the columns assigned to the validator, that can be repaired.""" """It restores the columns assigned to the validator, that can be repaired."""
if self.repairOnTheFly: if self.repairOnTheFly:
for id in self.columnIDs: for id in self.columnIDs:
self.restoreColumn(id)
def restoreColumn(self, id):
rep = self.block.repairColumn(id) rep = self.block.repairColumn(id)
if (rep.any()): if (rep.any()):
# If operation is based on send queues, segments should # If operation is based on send queues, segments should