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

Sent Data plot updated

Browse Source
This commit is contained in:
Sudipta Basak 2024-06-04 08:43:19 +00:00
parent c5214093ea
commit 3ed4248aa0
No known key found for this signature in database
1 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
DAS/visualizor.py
View File

@ -14,7 +14,8 @@ def plotData(conf):
plt.text(1.05, 0.05, conf["textBox"], fontsize=14, verticalalignment='bottom', transform=plt.gca().transAxes, bbox=props) plt.text(1.05, 0.05, conf["textBox"], fontsize=14, verticalalignment='bottom', transform=plt.gca().transAxes, bbox=props)
if conf["type"] == "plot" or conf["type"] == "plot_with_1line": if conf["type"] == "plot" or conf["type"] == "plot_with_1line":
for i in range(len(conf["data"])): for i in range(len(conf["data"])):
plt.plot(conf["xdots"], conf["data"][i], conf["colors"][i], label=conf["labels"][i]) # plt.plot(conf["xdots"], conf["data"][i], conf["colors"][i], label=conf["labels"][i])
plt.plot(conf["xdots"], conf["data"][i], label=conf["labels"][i])
elif conf["type"] == "individual_bar" or conf["type"] == "individual_bar_with_2line": elif conf["type"] == "individual_bar" or conf["type"] == "individual_bar_with_2line":
plt.bar(conf["xdots"], conf["data"]) plt.bar(conf["xdots"], conf["data"])
elif conf["type"] == "grouped_bar": elif conf["type"] == "grouped_bar":
@ -949,13 +950,12 @@ class Visualizor:
def plotSentData(self, result, plotPath): def plotSentData(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"]["TX builder mean"] vectors = { 0: result.metrics["progress"]["TX builder mean"] }
vector2 = result.metrics["progress"]["TX class1 mean"] for nc in result.shape.nodeClasses:
vector3 = result.metrics["progress"]["TX class2 mean"] if nc != 0: vectors[nc] = result.metrics["progress"][f"TX class{nc} mean"]
for i in range(len(vector1)): for _k in vectors.keys():
vector1[i] = (vector1[i] * 8 * (1000/self.config.stepDuration) * self.config.segmentSize) / 1000000 for i in range(len(vectors[0])):
vector2[i] = (vector2[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
vector3[i] = (vector3[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'])
@ -972,12 +972,16 @@ class Visualizor:
conf["type"] = "plot" conf["type"] = "plot"
conf["legLoc"] = 2 conf["legLoc"] = 2
conf["desLoc"] = 2 conf["desLoc"] = 2
conf["colors"] = ["y-", "c-", "m-"] # conf["colors"] = ["y-", "c-", "m-"]
conf["labels"] = ["Block Builder", "Solo stakers", "Staking pools"] conf["labels"] = ["Block Builder"]
conf["data"] = [vectors[0]]
for _k, _v in vectors.items():
if _k != 0:
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, vector3] conf["xdots"] = [x*self.config.stepDuration for x in range(len(vectors[0]))]
conf["xdots"] = [x*self.config.stepDuration for x in range(len(vector1))]
conf["path"] = plotPath+"/sentData.png" conf["path"] = plotPath+"/sentData.png"
maxi = 0 maxi = 0
for v in conf["data"]: for v in conf["data"]: