Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

feat: Extended integration test for socket TCP connection

Browse source 
Signed-off-by: Jitpanu Maneeratpongsuk <jitpanu.maneeratpongsuk@rwth-aachen.de>
This commit is contained in:
Jitpanu Maneeratpongsuk 2025-01-15 13:13:07 +00:00 • committed by al3xa23
parent b23c12aab1
commit c07679bc32
1 changed files with 82 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

82
tests/integration/node-loopback-socket.sh
View file

@ -87,3 +87,85 @@ wait %%
# Send / Receive data to node
VILLAS_LOG_PREFIX="[compare] " \
villas compare input.dat output.dat
sleep 1
cat > config.json <<EOF
{
"nodes": {
"node1": {
"type": "socket",
"layer": "tcp-server",
"in": {
"address": "127.0.0.1:12002",
"signals": {
"type": "float",
"count": 1
}
},
"out": {
"address": "127.0.0.1:12003"
}
},
"node2": {
"type": "socket",
"layer": "tcp-client",
"in": {
"address": "127.0.0.1:12003",
"signals": {
"type": "float",
"count": 1
}
},
"out": {
"address": "127.0.0.1:12002"
}
},
"siggen": {
"type": "signal",
"signal": "random",
"limit": 10
}
},
"paths": [
{
"in": "siggen",
"out": "node2",
"hooks": [
{
"type": "print",
"output": "input.dat"
}
]
},
{
"in": "node1",
"out": "node1"
},
{
"in": "node2",
"hooks": [
{
"type": "print",
"output": "output.dat"
}
]
}
]
}
EOF
VILLAS_LOG_PREFIX="[node] " \
villas node config.json &
# Wait for node to complete init
sleep 3
kill %%
wait %%
# Compare data
VILLAS_LOG_PREFIX="[compare] " \
villas compare input.dat output.dat