diff --git a/tests/integration/node-multiple-sources.sh b/tests/integration/node-multiple-sources.sh index f3b60dd2f..ba8d7ba67 100755 --- a/tests/integration/node-multiple-sources.sh +++ b/tests/integration/node-multiple-sources.sh @@ -64,6 +64,12 @@ cat > config.json <. ################################################################################## -echo "Test is broken" -exit 99 +# echo "Test is broken" +# exit 99 set -e @@ -36,17 +36,22 @@ function finish { } trap finish EXIT -NUM_SAMPLES=${NUM_SAMPLES:-100} +NUM_SAMPLES=${NUM_SAMPLES:-10} -cat > config.json << EOF +cat > config1.json << EOF { + "http": { + "port": 8081 + }, "nodes": { "node1": { "type": "websocket", "destinations": [ "ws://127.0.0.1:8080/node2.protobuf" - ] + ], + + "wait_connected": true } } } @@ -65,14 +70,17 @@ cat > config2.json << EOF } EOF +VILLAS_LOG_PREFIX="[signal] " \ villas signal -l ${NUM_SAMPLES} -n random > input.dat -villas pipe -r -l ${NUM_SAMPLES} ${CONFIG_FILE2} node2 | tee output.dat & +VILLAS_LOG_PREFIX="[pipe2] " \ +villas pipe -d debug -l ${NUM_SAMPLES} -r config2.json node2 > output.dat & sleep 1 -villas pipe -s config.json node1 < <(sleep 1; cat input.dat) +VILLAS_LOG_PREFIX="[pipe1] " \ +villas pipe -d debug -L ${NUM_SAMPLES} -s config1.json node1 < input.dat -wait $! +wait %% villas compare input.dat output.dat