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

Merge ea349816171674591584d5e0ac494ede62fe4e4e into f36c3c85ba31ed0fd27c3650794a511ad994a661

Browse Source
This commit is contained in:
Csaba Kiraly 2024-05-24 16:18:18 +02:00 committed by GitHub
commit a0bb8fecea
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
smallConf.py
View File

@ -119,15 +119,27 @@ sendLineUntilR = "shape.nbColsK" # stop sending on a p2p link if at least this a
sendLineUntilC = lambda shape : shape.nbRowsK # stop sending on a p2p link if at least this amount of samples passed
perNeighborQueue = True # queue incoming messages to outgoing connections on arrival (as typical GossipSub impl)
shuffleQueues = True # shuffle the order of picking from active queues of a sender node
perNodeQueue = False # keep a global queue of incoming messages for later sequential dispatch
shuffleLines = True # shuffle the order of rows/columns in each iteration while trying to send
shuffleNeighbors = True # shuffle the order of neighbors when sending the same segment to each neighbor
dumbRandomScheduler = False # dumb random scheduler
segmentShuffleScheduler = True # send each segment that's worth sending once in shuffled order, then repeat
segmentShuffleSchedulerPersist = True # Persist scheduler state between timesteps
queueAllOnInit = False # queue up everything in the block producer, without shuffling, at the very beginning
forwardOnReceive = True # forward segments as soon as received
forwardWhenLineReceived = False # forward all segments when full line available (repaired segments are always forwarded)
messageIsLine = False
if messageIsLine:
# Message is line
perNodeQueue = "self.amIproposer" # keep a global queue of incoming messages for later sequential dispatch
segmentShuffleScheduler = False # send each segment that's worth sending once in shuffled order, then repeat
segmentShuffleSchedulerPersist = True # Persist scheduler state between timesteps
queueAllOnInit = True # queue up everything in the block producer, without shuffling, at the very beginning
forwardOnReceive = False # forward segments as soon as received
forwardWhenLineReceived = True # forward all segments when full line available (repaired segments are always forwarded)
else:
## Message is segment
perNodeQueue = False # keep a global queue of incoming messages for later sequential dispatch
segmentShuffleScheduler = True # send each segment that's worth sending once in shuffled order, then repeat
segmentShuffleSchedulerPersist = True # Persist scheduler state between timesteps
queueAllOnInit = False # queue up everything in the block producer, without shuffling, at the very beginning
forwardOnReceive = True # forward segments as soon as received
forwardWhenLineReceived = False # forward all segments when full line available (repaired segments are always forwarded)
cols = range(64, 113, 128)
rows = range(32, 113, 128)