codex-storage/das-research
1
0
Fork 0
mirror of https://github.com/codex-storage/das-research.git synced 2025-02-23 08:18:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Received data plot updated

Browse Source
This commit is contained in:
Sudipta Basak 2024-06-04 09:15:40 +00:00
parent 3ed4248aa0
commit fe8cde9a61
No known key found for this signature in database
1 changed files with 15 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
DAS/visualizor.py
View File

@ -954,7 +954,7 @@ class Visualizor:
for nc in result.shape.nodeClasses: for nc in result.shape.nodeClasses:
if nc != 0: vectors[nc] = result.metrics["progress"][f"TX class{nc} mean"] if nc != 0: vectors[nc] = result.metrics["progress"][f"TX class{nc} mean"]
for _k in vectors.keys(): for _k in vectors.keys():
for i in range(len(vectors[0])): for i in range(len(list(vectors.values())[0])):
vectors[_k][i] = (vectors[_k][i] * 8 * (1000/self.config.stepDuration) * self.config.segmentSize) / 1000000 vectors[_k][i] = (vectors[_k][i] * 8 * (1000/self.config.stepDuration) * self.config.segmentSize) / 1000000
conf = {} conf = {}
attrbs = self.__get_attrbs__(result) attrbs = self.__get_attrbs__(result)
@ -981,7 +981,7 @@ class Visualizor:
conf["data"].append(_v) conf["data"].append(_v)
conf["xlabel"] = "Time (ms)" conf["xlabel"] = "Time (ms)"
conf["ylabel"] = "Bandwidth (MBits/s)" conf["ylabel"] = "Bandwidth (MBits/s)"
conf["xdots"] = [x*self.config.stepDuration for x in range(len(vectors[0]))] conf["xdots"] = [x*self.config.stepDuration for x in range(len(list(vectors.values())[0]))]
conf["path"] = plotPath+"/sentData.png" conf["path"] = plotPath+"/sentData.png"
maxi = 0 maxi = 0
for v in conf["data"]: for v in conf["data"]:
@ -993,11 +993,12 @@ class Visualizor:
def plotRecvData(self, result, plotPath): def plotRecvData(self, result, plotPath):
"""Plots the percentage of nodes ready in the network""" """Plots the percentage of nodes ready in the network"""
vector1 = result.metrics["progress"]["RX class1 mean"] vectors = {}
vector2 = result.metrics["progress"]["RX class2 mean"] for nc in result.shape.nodeClasses:
for i in range(len(vector1)): if nc != 0: vectors[nc] = result.metrics["progress"][f"RX class{nc} mean"]
vector1[i] = (vector1[i] * 8 * (1000/self.config.stepDuration) * self.config.segmentSize) / 1000000 for _k in vectors.keys():
vector2[i] = (vector2[i] * 8 * (1000/self.config.stepDuration) * self.config.segmentSize) / 1000000 for i in range(len(list(vectors.values())[0])):
vectors[_k][i] = (vectors[_k][i] * 8 * (1000/self.config.stepDuration) * self.config.segmentSize) / 1000000
conf = {} conf = {}
attrbs = self.__get_attrbs__(result) attrbs = self.__get_attrbs__(result)
nodeTypes = self.__getNodeTypes__(attrbs['ntypes']) nodeTypes = self.__getNodeTypes__(attrbs['ntypes'])
@ -1014,12 +1015,15 @@ class Visualizor:
conf["type"] = "plot" conf["type"] = "plot"
conf["legLoc"] = 2 conf["legLoc"] = 2
conf["desLoc"] = 2 conf["desLoc"] = 2
conf["colors"] = ["c-", "m-"] # conf["colors"] = ["c-", "m-"]
conf["labels"] = ["Solo stakers", "Staking pools"] conf["labels"] = []
conf["data"] = []
for _k, _v in vectors.items():
conf["labels"].append(f"Node Class: {_k}")
conf["data"].append(_v)
conf["xlabel"] = "Time (ms)" conf["xlabel"] = "Time (ms)"
conf["ylabel"] = "Bandwidth (MBits/s)" conf["ylabel"] = "Bandwidth (MBits/s)"
conf["data"] = [vector1, vector2] conf["xdots"] = [x*self.config.stepDuration for x in range(len(list(vectors.values())[0]))]
conf["xdots"] = [x*self.config.stepDuration for x in range(len(vector1))]
conf["path"] = plotPath+"/recvData.png" conf["path"] = plotPath+"/recvData.png"
maxi = 0 maxi = 0
for v in conf["data"]: for v in conf["data"]: