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

add validator.perNodeQueue conf option

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

4
DAS/validator.py
View File

@ -119,6 +119,7 @@ class Validator:
# TODO: this should be a parameter # TODO: this should be a parameter
self.bwUplink = 110 if not self.amIproposer else 2200 # approx. 10Mbps and 200Mbps self.bwUplink = 110 if not self.amIproposer else 2200 # approx. 10Mbps and 200Mbps
self.perNodeQueue = False # keep a global queue of incoming messages for later sequential dispatch
self.sched = self.nextToSend() self.sched = self.nextToSend()
def logIDs(self): def logIDs(self):
@ -230,7 +231,8 @@ class Validator:
neigh.receiving.setall(0) neigh.receiving.setall(0)
# add newly received segments to the send queue # add newly received segments to the send queue
self.sendQueue.extend(self.receivedQueue) if self.perNeighborQueue:
self.sendQueue.extend(self.receivedQueue)
self.receivedQueue.clear() self.receivedQueue.clear()
def updateStats(self): def updateStats(self):