Commit Graph

298 Commits

Author SHA1 Message Date
Csaba Kiraly af72e58d08
collect receivedQueue only if it is used later
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:27:52 +01:00
Csaba Kiraly 1669ec9236
more debug logging
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:27:49 +01:00
Csaba Kiraly 5383c59f6f
add shuffleLines and shuffleNeighbors params
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:25:15 +01:00
Csaba Kiraly d0641e4568
add repairOnTheFly parameter
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:25:09 +01:00
Csaba Kiraly f05c3cd233
fix queuing: should queue after repair
If operation is based on send queues, segments should
be queued after successful repair.

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:21:56 +01:00
Csaba Kiraly dff0e5523a
factorize addToSendQueue
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:15:45 +01:00
Csaba Kiraly 0c91eff67b
add dumbRandomScheduler parameter
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:15:45 +01:00
Csaba Kiraly b7dab5bad9
fix sendSegmentToNeigh: specify dimension
Specify along which dimension (row/column) a segment was
sent.

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:15:39 +01:00
Csaba Kiraly 23e40693f1
add perNeighborQueue option
If enabled, queue incoming messages to outgoing connections on arrival,
as typical in some GossipSub implementations.

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:13:39 +01:00
Csaba Kiraly 7c0fcaba78
add validator.perNodeQueue conf option
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:13:39 +01:00
Csaba Kiraly f67c70896c
add to receivedQueue also in row/column receive code
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:13:39 +01:00
Csaba Kiraly 9ab51278c8
add shuffledDict helper
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:13:39 +01:00
Csaba Kiraly 1403ca7ad0
add random scheduler 2023-02-23 21:13:39 +01:00
Csaba Kiraly 0f4883bf26
add node level send queue
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:13:35 +01:00
Csaba Kiraly 382954de02
add segment level send/receive
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:09:59 +01:00
Csaba Kiraly 3fc7455c0b
reduce default BW to more interesting values
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:09:59 +01:00
Csaba Kiraly 3917001e6a
send one segment at a time
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:09:59 +01:00
Csaba Kiraly eb277d9b43
limit batchsize of sending from a line
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:09:59 +01:00
Csaba Kiraly 07437ddde8
fixup bwUplink check (still approximate)
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:08:26 +01:00
Csaba Kiraly bb8d05257b
WIP: initial implementation of uplink bandwidth limit
- approximate: BW is not handled strict, entire rows are sent and can go over limit
- WIP: work in progress implementation

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 21:08:17 +01:00
HajarZaiz 7ae66810f7 vis class 2023-02-23 14:37:45 +01:00
Leo b7877f6130
Merge pull request #16 from status-im/more-config
Add some more configuration parameters and some more testing
2023-02-23 14:36:59 +01:00
Leonardo Bautista-Gomez 6e42055cb9 Add some more configuration parameters and some more testing 2023-02-23 12:17:57 +01:00
Leo c3a9eb6b4d
Merge pull request #15 from status-im/fix-small-graph
set up complete graph if n<=d
2023-02-23 10:18:09 +01:00
Leo edb4912dd5
Merge pull request #14 from status-im/log-steps
Log steps
2023-02-23 09:46:55 +01:00
Leo a26ccf5c9f
Merge pull request #13 from status-im/fix-columnid
Fix column IDs
2023-02-23 09:38:25 +01:00
Csaba Kiraly 763ebfe136
set up complete graph if n<=d
If the number of nodes in a channel is smaller or equal than the
requested degree, a fully connected graph is used. For n>d, a random
d-regular graph is set up. (For n=d+1, the two are the same.)

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 09:06:57 +01:00
Csaba Kiraly e5c657e31e
more debug logging
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 09:04:51 +01:00
Csaba Kiraly 91a4b48947
log number of steps as well
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-23 09:04:47 +01:00
Csaba Kiraly 2775d180f1
debug log neighborhood of producer as well
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-22 21:48:11 +01:00
Csaba Kiraly 8c9ddcca55
add debug logging of topology
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-22 21:48:03 +01:00
Csaba Kiraly 22e4c89989
fix: column IDs matching row IDs
Fixes a simple copy paste error.

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-22 21:46:36 +01:00
Leonardo Bautista-Gomez 93c318028b Add visualizer class 2023-02-22 16:45:39 +01:00
Leonardo Bautista-Gomez 8b763b2425 Passing execID in parameter and moving heatmaps directory inside the execID directory 2023-02-22 15:52:55 +01:00
Leonardo Bautista-Gomez d5e7ae7ea7 Fix net degree bug 2023-02-22 14:49:46 +01:00
HajarZaiz a6896a60dd Fixed Plots 2023-02-22 13:47:52 +01:00
HajarZaiz 2b7302de64 Delete folder 2023-02-19 22:27:13 +01:00
HajarZaiz 54b0284abb Minor display improvements 2023-02-19 22:17:50 +01:00
HajarZaiz c312d6447d Heatmaps generation 2023-02-16 23:38:47 +01:00
Leo 8f2052e1ac
Merge pull request #11 from status-im/doc
Documentation with Sphinx
2023-02-16 11:41:48 +01:00
Leonardo Bautista-Gomez 09569422ab Documenting the DAS package for automatic generation with sphinx. First version. 2023-02-15 15:06:42 +01:00
Leo d20f83595d
Merge pull request #10 from status-im/results
Results class and avoid static variables
2023-02-09 13:59:16 +01:00
Leonardo Bautista-Gomez 9888d96e43 Update gitignore 2023-02-08 22:46:12 +01:00
Leonardo Bautista-Gomez cf780b3ca3 Starting code documentation 2023-02-08 22:45:01 +01:00
Leonardo Bautista-Gomez 5c55fd7854 Add documentation files 2023-02-08 22:33:16 +01:00
Leonardo Bautista-Gomez 17b97c37c0 Update gitignore 2023-02-08 22:31:51 +01:00
Leonardo Bautista-Gomez 6334d1c779 Removing static variables 2023-02-08 20:10:26 +01:00
Leonardo Bautista-Gomez b64fe7b383 Merging changes from 'develop' branch into 'results' branch 2023-02-08 15:01:50 +01:00
Leo 0a0e63b718
Merge pull request #9 from status-im/throughput
measure throughput
2023-02-08 14:20:16 +01:00
Csaba Kiraly 03813b36bc
fix receive info propagation
Make sure info about what is being sent is not propagated too fast.
In this base model, a node knows that something was sent after one
timestep. This requires keeping separating receiving from received and
updating only once per timestep.

Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
2023-02-03 12:44:26 +01:00