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

convert figures to mbps

Browse Source 
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2023-04-13 06:02:28 +02:00
parent b65f565734
commit 520b48cd0e
No known key found for this signature in database
GPG Key ID: 0FE274EE8C95166E
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
DAS/simulator.py
View File

@ -220,13 +220,13 @@ class Simulator:
cnS:sampleProgress,
cnN:nodeProgress,
cnV:validatorProgress,
cnT0: trafficStats[0]["Tx"]["mean"],
cnT1: trafficStats[1]["Tx"]["mean"],
cnT2: trafficStats[2]["Tx"]["mean"],
cnR1: trafficStats[1]["Rx"]["mean"],
cnR2: trafficStats[2]["Rx"]["mean"],
cnD1: trafficStats[1]["RxDup"]["mean"],
cnD2: trafficStats[2]["RxDup"]["mean"],
cnT0: trafficStats[0]["Tx"]["mean"] / 1e3 * 8 / self.config.stepDuration * self.config.segmentSize,
cnT1: trafficStats[1]["Tx"]["mean"] / 1e3 * 8 / self.config.stepDuration * self.config.segmentSize,
cnT2: trafficStats[2]["Tx"]["mean"] / 1e3 * 8 / self.config.stepDuration * self.config.segmentSize,
cnR1: trafficStats[1]["Rx"]["mean"] / 1e3 * 8 / self.config.stepDuration * self.config.segmentSize,
cnR2: trafficStats[2]["Rx"]["mean"] / 1e3 * 8 / self.config.stepDuration * self.config.segmentSize,
cnD1: trafficStats[1]["RxDup"]["mean"] / 1e3 * 8 / self.config.stepDuration * self.config.segmentSize,
cnD2: trafficStats[2]["RxDup"]["mean"] / 1e3 * 8 / self.config.stepDuration * self.config.segmentSize,
})
if missingSamples == oldMissingSamples:
@ -249,6 +249,10 @@ class Simulator:
if self.config.plotProgress:
progress.plot.line(subplots = [[cnS, cnN, cnV], [cnT0], [cnT1, cnR1, cnD1], [cnT2, cnR2, cnD2]],
title = str(self.shape))
axs[0].set_ylabel("progress")
axs[1].set_ylabel("throughput [mbps]")
axs[2].set_ylabel("throughput [mbps]")
axs[3].set_ylabel("throughput [mbps]")
if not os.path.exists("results"):
os.makedirs("results")
if not os.path.exists("results/"+self.execID):