waku-org
/
nwaku
mirror of https://github.com/waku-org/nwaku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Setup starNetwork and multitail sim orchestration

This commit is contained in:
Oskar Thoren 2020-05-21 12:36:30 +08:00
parent 11575f5df3
commit 8ac686ea9e
No known key found for this signature in database
GPG Key ID: B2ECCFD3BC2EF77E
1 changed files with 23 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
waku/node/v2/start_network.nim
View File

@ -59,10 +59,27 @@ proc initNodeCmd(shift: int, staticNodes: seq[string] = @[], master = false, lab
info "Node command created.", cmd=result.cmd, address = result.address
# TODO: Setup diff topology, star, mesh, etc
let masterNode = initNodeCmd(portOffset, @[], "master node")
let otherNode = initNodeCmd(portOFfset + 1, @[masterNode.address], "other node")
proc starNetwork(amount: int): seq[NodeInfo] =
let masterNode = initNodeCmd(portOffset, master = true, label = "master node")
result.add(masterNode)
for i in 1..<amount:
result.add(initNodeCmd(portOffset + i, @[masterNode.address], label = "full node"))
echo masterNode
echo "---"
echo otherNode
when isMainModule:
# TODO: WakuNetworkConf
var nodes: seq[NodeInfo]
let amount = 2
nodes = starNetwork(amount)
var commandStr = "multitail -s 2 -M 0 -x \"Waku Simulation\""
var count = 0
var sleepDuration = 0
for node in nodes:
#if conf.topology in {Star, DiscoveryBased}:
sleepDuration = if node.master: 0
else: 1
commandStr &= &" -cT ansi -t 'node #{count} {node.label}' -l 'sleep {sleepDuration}; {node.cmd}; echo [node execution completed]; while true; do sleep 100; done'"
let errorCode = execCmd(commandStr)
if errorCode != 0:
error "launch command failed", command=commandStr