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

Add Tx and Rx stats to results

Browse Source
This commit is contained in:
Leonardo Bautista-Gomez 2023-03-27 21:24:25 +02:00
parent d9fc4e166e
commit 9ea8e764c2
2 changed files with 31 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
DAS/results.py
View File

@ -15,10 +15,16 @@ class Result:
self.tta = -1
self.missingVector = []
def populate(self, shape, config, missingVector):
def populate(self, shape, config, missingVector, bandwidthVector):
"""It populates part of the result data inside a vector."""
self.shape = shape
self.missingVector = missingVector
self.proTx = bandwidthVector[0]
self.proRx = bandwidthVector[1]
self.aveTx = bandwidthVector[2]
self.maxTx = bandwidthVector[3]
self.aveRx = bandwidthVector[4]
self.maxRx = bandwidthVector[5]
missingSamples = missingVector[-1]
if missingSamples == 0:
self.blockAvailable = 1

28
DAS/simulator.py
View File

@ -170,6 +170,12 @@ class Simulator:
arrived, expected = self.glob.checkStatus(self.validators)
missingSamples = expected - arrived
missingVector = []
proTxVector = []
proRxVector = []
aveTxVector = []
maxTxVector = []
aveRxVector = []
maxRxVector = []
steps = 0
while(True):
missingVector.append(missingSamples)
@ -192,10 +198,21 @@ class Simulator:
# log TX and RX statistics
statsTxInSlot = [v.statsTxInSlot for v in self.validators]
statsRxInSlot = [v.statsRxInSlot for v in self.validators]
proTx = statsTxInSlot[0]
proRx = statsRxInSlot[0]
aveTx = mean(statsTxInSlot[1:])
maxTx = max(statsTxInSlot[1:])
aveRx = mean(statsRxInSlot[1:])
maxRx = max(statsRxInSlot[1:])
self.logger.debug("step %d: TX_prod=%.1f, RX_prod=%.1f, TX_avg=%.1f, TX_max=%.1f, Rx_avg=%.1f, Rx_max=%.1f" %
(steps, statsTxInSlot[0], statsRxInSlot[0],
mean(statsTxInSlot[1:]), max(statsTxInSlot[1:]),
mean(statsRxInSlot[1:]), max(statsRxInSlot[1:])), extra=self.format)
(steps, proTx, proRx, aveTx, maxTx, aveRx, maxRx), extra=self.format)
proTxVector.append(proTx)
proRxVector.append(proRx)
aveTxVector.append(aveTx)
maxTxVector.append(maxTx)
aveRxVector.append(aveRx)
maxRxVector.append(maxRx)
for i in range(0,self.shape.numberNodes):
self.validators[i].updateStats()
@ -214,6 +231,9 @@ class Simulator:
else:
steps += 1
self.result.populate(self.shape, self.config, missingVector)
bandwidthVector = [sum(proTxVector), sum(proRxVector),
mean(aveTxVector), max(maxTxVector),
mean(aveRxVector), max(maxRxVector)]
self.result.populate(self.shape, self.config, missingVector, bandwidthVector)
return self.result