mirror of
https://github.com/logos-storage/codex-factory.git
synced 2026-01-07 15:33:11 +00:00
feat: queen waits for worker connections (#12)
This commit is contained in:
parent
6aa40f09f0
commit
2feb3b35a7
@ -56,6 +56,12 @@ log_queen() {
|
|||||||
docker logs --tail 25 -f "$QUEEN_CONTAINER_NAME"
|
docker logs --tail 25 -f "$QUEEN_CONTAINER_NAME"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
count_connected_peers() {
|
||||||
|
COUNT=$( curl -s http://localhost:1635/peers | python -c 'import json,sys; obj=json.load(sys.stdin); print len(obj["peers"]);' )
|
||||||
|
|
||||||
|
echo "$COUNT"
|
||||||
|
}
|
||||||
|
|
||||||
MY_PATH=$(dirname "$0") # relative
|
MY_PATH=$(dirname "$0") # relative
|
||||||
MY_PATH=$( cd "$MY_PATH" && pwd ) # absolutized and normalized
|
MY_PATH=$( cd "$MY_PATH" && pwd ) # absolutized and normalized
|
||||||
# Check used system variable set
|
# Check used system variable set
|
||||||
@ -222,6 +228,14 @@ for i in $(seq 1 1 "$WORKERS"); do
|
|||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
|
|
||||||
|
echo "Check whether the queen node has been connected to every worker..."
|
||||||
|
while : ; do
|
||||||
|
COUNT=$(count_connected_peers)
|
||||||
|
[[ $COUNT < $WORKERS ]] || break
|
||||||
|
echo "Only $COUNT peers have been connected to the Queen Bee node yet. Waiting until $WORKERS"
|
||||||
|
sleep 2
|
||||||
|
done
|
||||||
|
|
||||||
# log Bee Queen
|
# log Bee Queen
|
||||||
if $LOG ; then
|
if $LOG ; then
|
||||||
log_queen
|
log_queen
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user