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

simplify dumbRandomScheduler code

Browse Source 
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2023-02-28 09:35:18 +01:00
parent f95a393068
commit 82ee2b5189
No known key found for this signature in database
GPG Key ID: 0FE274EE8C95166E
1 changed files with 2 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
DAS/validator.py
View File

@ -61,13 +61,6 @@ def sampleLine(line, limit):
limit -= 1
return r
class NextToSend:
def __init__(self, neigh, toSend, id, dim):
self.neigh = neigh
self.toSend = toSend
self.id = id
self.dim = dim
class SegmentToSend:
def __init__(self, dim, id, i):
self.dim = dim
@ -387,10 +380,7 @@ class Validator:
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.received[cID] :
neigh.sent[cID] = 1
neigh.node.receiveSegment(rID, cID, self.ID)
self.statsTxInSlot += 1
if self.sendSegmentToNeigh(rID, cID, neigh):
t = tries
if self.statsTxInSlot >= self.bwUplink:
return
@ -399,10 +389,7 @@ class Validator:
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.received[rID] :
neigh.sent[rID] = 1
neigh.node.receiveSegment(rID, cID, self.ID)
self.statsTxInSlot += 1
if self.sendSegmentToNeigh(rID, cID, neigh):
t = tries
t -= 1
if self.statsTxInSlot >= self.bwUplink: