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

add random scheduler

Browse Source
This commit is contained in:
Csaba Kiraly 2023-02-14 02:18:37 +01:00
parent 0f4883bf26
commit 1403ca7ad0
No known key found for this signature in database
GPG Key ID: 0FE274EE8C95166E
1 changed files with 29 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
DAS/validator.py
View File

@ -321,6 +321,35 @@ class Validator:
self.sendQueue.popleft() self.sendQueue.popleft()
tries = 100
while tries:
if self.rowIDs:
rID = random.choice(self.rowIDs)
cID = random.randrange(0, self.shape.blockSize)
if self.block.getSegment(rID, cID) :
neigh = random.choice(list(self.rowNeighbors[rID].values()))
if not neigh.sent[cID] and not neigh.receiving[cID] :
neigh.sent[cID] = 1
neigh.node.receiveSegment(rID, cID, self.ID)
self.statsTxInSlot += 1
tries = 100
if self.statsTxInSlot >= self.bwUplink:
return
if self.columnIDs:
cID = random.choice(self.columnIDs)
rID = random.randrange(0, self.shape.blockSize)
if self.block.getSegment(rID, cID) :
neigh = random.choice(list(self.columnNeighbors[cID].values()))
if not neigh.sent[rID] and not neigh.receiving[rID] :
neigh.sent[rID] = 1
neigh.node.receiveSegment(rID, cID, self.ID)
self.statsTxInSlot += 1
tries = 100
tries -= 1
if self.statsTxInSlot >= self.bwUplink:
return
return
for n in self.sched: for n in self.sched:
neigh = n.neigh neigh = n.neigh
toSend = n.toSend toSend = n.toSend