mirror of
https://github.com/logos-messaging/logos-messaging-simulator.git
synced 2026-01-05 23:43:11 +00:00
Enabling RLN, using correctly NUM_NWAKU_NODES variable
This commit is contained in:
parent
c43c07c449
commit
a8c8bbd09f
@ -66,7 +66,7 @@ services:
|
|||||||
dockerfile: Dockerfile.rest-traffic
|
dockerfile: Dockerfile.rest-traffic
|
||||||
command: >
|
command: >
|
||||||
python /opt/traffic.py
|
python /opt/traffic.py
|
||||||
-mn=${TRAFFIC_MULTIPLE_NODES:-http://waku-simulator_nwaku_[1..5]:8645}
|
-mn=${TRAFFIC_MULTIPLE_NODES:-http://waku-simulator_nwaku_[1..$NUM_NWAKU_NODES]:8645}
|
||||||
-s=${TRAFFIC_MESSAGE_SIZE_KB:-10}
|
-s=${TRAFFIC_MESSAGE_SIZE_KB:-10}
|
||||||
-d=${TRAFFIC_DELAY_SECONDS:-15}
|
-d=${TRAFFIC_DELAY_SECONDS:-15}
|
||||||
volumes:
|
volumes:
|
||||||
|
|||||||
@ -4,12 +4,11 @@ IP=$(ip a | grep "inet " | grep -Fv 127.0.0.1 | sed 's/.*inet \([^/]*\).*/\1/')
|
|||||||
|
|
||||||
echo "My container name is: $HOSTNAME"
|
echo "My container name is: $HOSTNAME"
|
||||||
|
|
||||||
|
# Get an unique node index based on the container's IP
|
||||||
FOURTH_OCTET=${IP##*.}
|
FOURTH_OCTET=${IP##*.}
|
||||||
THIRD_OCTET="${IP%.*}"; THIRD_OCTET="${THIRD_OCTET##*.}"
|
THIRD_OCTET="${IP%.*}"; THIRD_OCTET="${THIRD_OCTET##*.}"
|
||||||
NODE_INDEX=$((FOURTH_OCTET + 256 * THIRD_OCTET))
|
NODE_INDEX=$((FOURTH_OCTET + 256 * THIRD_OCTET))
|
||||||
|
|
||||||
echo "FOURTH_OCTET $FOURTH_OCTET"
|
|
||||||
echo "THIRD_OCTET $THIRD_OCTET"
|
|
||||||
echo "NODE_INDEX $NODE_INDEX"
|
echo "NODE_INDEX $NODE_INDEX"
|
||||||
echo "$IP"
|
echo "$IP"
|
||||||
|
|
||||||
@ -38,9 +37,9 @@ exec /usr/bin/wakunode\
|
|||||||
--rest-admin=true\
|
--rest-admin=true\
|
||||||
--rest-private=true\
|
--rest-private=true\
|
||||||
--rest-address=0.0.0.0\
|
--rest-address=0.0.0.0\
|
||||||
#--rln-relay=true\
|
--rln-relay=true\
|
||||||
#--rln-relay-dynamic=false\
|
--rln-relay-dynamic=false\
|
||||||
#--rln-relay-membership-index=${NODE_INDEX}\
|
--rln-relay-membership-index=${NODE_INDEX}\
|
||||||
--dns-discovery=true\
|
--dns-discovery=true\
|
||||||
--discv5-discovery=true\
|
--discv5-discovery=true\
|
||||||
--discv5-enr-auto-update=True\
|
--discv5-enr-auto-update=True\
|
||||||
|
|||||||
@ -38,7 +38,6 @@ def send_waku_msg(node_address, kbytes, pubsub_topic, content_topic):
|
|||||||
|
|
||||||
if(response != None):
|
if(response != None):
|
||||||
elapsed_ms = (time.time() - s_time) * 1000
|
elapsed_ms = (time.time() - s_time) * 1000
|
||||||
print(response.status_code, response.text)
|
|
||||||
print('Response from %s: status:%s content:%s [%.4f ms.]' % (node_address, \
|
print('Response from %s: status:%s content:%s [%.4f ms.]' % (node_address, \
|
||||||
response.status_code, response.text, elapsed_ms))
|
response.status_code, response.text, elapsed_ms))
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user