Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-02 06:38:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

btest/cluster/websocket: Update tests for new event signature

Browse source
This commit is contained in:
Arne Welzel 2025-05-09 16:34:42 +02:00
parent a61aff010f
commit 6d2bd93f1f
15 changed files with 17 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

6
testing/btest/Baseline/cluster.websocket.cluster-log/..manager.cluster.log.cannonified
View file

@ -2,6 +2,6 @@
manager WebSocket client <nodeid> (127.0.0.1:<port>) subscribed to [/topic/ws/1, /topic/ws/all] manager WebSocket client <nodeid> (127.0.0.1:<port>) subscribed to [/topic/ws/1, /topic/ws/all]
manager WebSocket client <nodeid> (127.0.0.1:<port>) subscribed to [/topic/ws/2, /topic/ws/all] manager WebSocket client <nodeid> (127.0.0.1:<port>) subscribed to [/topic/ws/2, /topic/ws/all]
manager WebSocket client <nodeid> (127.0.0.1:<port>) subscribed to [/topic/ws/3, /topic/ws/all] manager WebSocket client <nodeid> (127.0.0.1:<port>) subscribed to [/topic/ws/3, /topic/ws/all]
manager WebSocket client <nodeid> (127.0.0.1:<port>) gone manager WebSocket client <nodeid> (127.0.0.1:<port>) gone with code 1000
manager WebSocket client <nodeid> (127.0.0.1:<port>) gone manager WebSocket client <nodeid> (127.0.0.1:<port>) gone with code 1000
manager WebSocket client <nodeid> (127.0.0.1:<port>) gone manager WebSocket client <nodeid> (127.0.0.1:<port>) gone with code 1000

2
testing/btest/cluster/websocket/bad-event-args.zeek
View file

@ -50,7 +50,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "Cluster::websocket_client_added", subscriptions; print "Cluster::websocket_client_added", subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
print "Cluster::websocket_client_lost"; print "Cluster::websocket_client_lost";
terminate(); terminate();

2
testing/btest/cluster/websocket/bad-subscriptions.zeek
View file

@ -47,7 +47,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "Cluster::websocket_client_added", added, subscriptions; print "Cluster::websocket_client_added", added, subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
++lost; ++lost;
print "Cluster::websocket_client_lost", lost; print "Cluster::websocket_client_lost", lost;

2
testing/btest/cluster/websocket/bad-url.zeek
View file

@ -53,7 +53,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "Cluster::websocket_client_added", subscriptions; print "Cluster::websocket_client_added", subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
print "Cluster::websocket_client_lost"; print "Cluster::websocket_client_lost";
terminate(); terminate();

2
testing/btest/cluster/websocket/broker/manager-recvs.zeek
View file

@ -63,7 +63,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print fmt("%s: Cluster::websocket_client_added %s %s", current_time(), added, subscriptions); print fmt("%s: Cluster::websocket_client_added %s %s", current_time(), added, subscriptions);
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
++lost; ++lost;
print fmt("%s: Cluster::websocket_client_lost %s", current_time(), lost); print fmt("%s: Cluster::websocket_client_lost %s", current_time(), lost);

2
testing/btest/cluster/websocket/broker/manager-sends.zeek
View file

@ -66,7 +66,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
event send_ping(); event send_ping();
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
++lost; ++lost;
print fmt("%s: Cluster::websocket_client_lost %s", current_time(), lost); print fmt("%s: Cluster::websocket_client_lost %s", current_time(), lost);

2
testing/btest/cluster/websocket/broker/manager-worker-ping-pong.zeek
View file

@ -94,7 +94,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print fmt("%s: Cluster::websocket_client_added %s %s", current_time(), added, subscriptions); print fmt("%s: Cluster::websocket_client_added %s %s", current_time(), added, subscriptions);
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
++lost; ++lost;
print fmt("%s: Cluster::websocket_client_lost %s", current_time(), lost); print fmt("%s: Cluster::websocket_client_lost %s", current_time(), lost);

2
testing/btest/cluster/websocket/cluster-log.zeek
View file

@ -63,7 +63,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "Cluster::websocket_client_added", added, subscriptions; print "Cluster::websocket_client_added", added, subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
++lost; ++lost;
print "Cluster::websocket_client_lost", lost; print "Cluster::websocket_client_lost", lost;

2
testing/btest/cluster/websocket/one-pipelining.zeek
View file

@ -53,7 +53,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "Cluster::websocket_client_added", subscriptions; print "Cluster::websocket_client_added", subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
print "Cluster::websocket_client_lost"; print "Cluster::websocket_client_lost";
terminate(); terminate();

2
testing/btest/cluster/websocket/one.zeek
View file

@ -53,7 +53,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "Cluster::websocket_client_added", subscriptions; print "Cluster::websocket_client_added", subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
print "Cluster::websocket_client_lost"; print "Cluster::websocket_client_lost";
terminate(); terminate();

2
testing/btest/cluster/websocket/terminate-while-queuing.zeek
View file

@ -46,7 +46,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "B Cluster::websocket_client_added", subscriptions; print "B Cluster::websocket_client_added", subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
print "E Cluster::websocket_client_lost"; print "E Cluster::websocket_client_lost";
} }

2
testing/btest/cluster/websocket/three.zeek
View file

@ -52,7 +52,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "B Cluster::websocket_client_added", subscriptions; print "B Cluster::websocket_client_added", subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
++lost; ++lost;
print "D Cluster::websocket_client_lost", lost; print "D Cluster::websocket_client_lost", lost;

2
testing/btest/cluster/websocket/tls.zeek
View file

@ -67,7 +67,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print "Cluster::websocket_client_added", subscriptions; print "Cluster::websocket_client_added", subscriptions;
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
print "Cluster::websocket_client_lost"; print "Cluster::websocket_client_lost";
terminate(); terminate();

2
testing/btest/cluster/websocket/two-pipelining.zeek
View file

@ -84,7 +84,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
drain_if_ready(); drain_if_ready();
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
++lost; ++lost;
print "C Cluster::websocket_client_lost"; print "C Cluster::websocket_client_lost";

2
testing/btest/cluster/websocket/zeromq/manager-worker-ping-pong.zeek
View file

@ -93,7 +93,7 @@ event Cluster::websocket_client_added(info: Cluster::EndpointInfo, subscriptions
print fmt("%s: Cluster::websocket_client_added %s %s", current_time(), added, subscriptions); print fmt("%s: Cluster::websocket_client_added %s %s", current_time(), added, subscriptions);
} }
event Cluster::websocket_client_lost(info: Cluster::EndpointInfo) event Cluster::websocket_client_lost(info: Cluster::EndpointInfo, code: count, reason: string)
{ {
++lost; ++lost;
print fmt("%s: Cluster::websocket_client_lost %s", current_time(), lost); print fmt("%s: Cluster::websocket_client_lost %s", current_time(), lost);