logos-storage/das-research
1
0
Fork 0
mirror of https://github.com/logos-storage/das-research.git synced 2026-01-06 23:23:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Adding failure rate logging

Browse Source
This commit is contained in:
leobago 2023-01-11 17:20:19 +01:00
parent d723cb1bc5
commit beabafba45
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
DAS/simulator.py
View File

@ -89,7 +89,6 @@ class Simulator:
self.steps = 0 self.steps = 0
while(missingSamples > 0): while(missingSamples > 0):
oldMissingSamples = missingSamples oldMissingSamples = missingSamples
self.logger.info("Step %d:" % self.steps, extra=self.format)
for i in range(1,self.numberValidators): for i in range(1,self.numberValidators):
self.validators[i].receiveRowsColumns() self.validators[i].receiveRowsColumns()
for i in range(1,self.numberValidators): for i in range(1,self.numberValidators):
@ -102,7 +101,8 @@ class Simulator:
arrived, expected = self.glob.checkStatus(self.validators) arrived, expected = self.glob.checkStatus(self.validators)
missingSamples = expected - arrived missingSamples = expected - arrived
self.logger.info("step %d, missing %d of %d" % (self.steps, missingSamples, expected), extra=self.format) missingRate = missingSamples*100/expected
self.logger.info("step %d, missing %d of %d (%0.02f %%)" % (self.steps, missingSamples, expected, missingRate), extra=self.format)
if missingSamples == oldMissingSamples: if missingSamples == oldMissingSamples:
break break
elif missingSamples == 0: elif missingSamples == 0:

5
DAS/validator.py
View File

@ -68,10 +68,13 @@ class Validator:
random.shuffle(order) random.shuffle(order)
while(order): while(order):
i = order.pop() i = order.pop()
if (random.randint(0,99) > self.failureRate): if (random.randint(0,99) >= self.failureRate):
self.block.data[i] = 1 self.block.data[i] = 1
else: else:
self.block.data[i] = 0 self.block.data[i] = 0
nbFailures = self.block.data.count(0)
measuredFailureRate = nbFailures * 100 / (self.blockSize * self.blockSize)
self.logger.info("Number of failures: %d (%0.02f %%)", nbFailures, measuredFailureRate, extra=self.format)
#broadcasted.print() #broadcasted.print()
for id in range(self.blockSize): for id in range(self.blockSize):
self.sendColumn(id) self.sendColumn(id)