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

btest/cluster/generic/publish-any: Apply Christian's fix from broker/publish-any

Browse source
This commit is contained in:
Arne Welzel 2025-05-07 17:17:57 +02:00
parent 82731992d9
commit 3ec3205074
1 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
testing/btest/cluster/generic/publish-any.zeek
View file

@ -57,8 +57,6 @@ event send_any()
local e = Cluster::make_event(ping, i, type_name(val), val); local e = Cluster::make_event(ping, i, type_name(val), val);
Cluster::publish_hrw(Cluster::worker_pool, cat(i), e); Cluster::publish_hrw(Cluster::worker_pool, cat(i), e);
++i; ++i;
schedule 0.05sec { send_any() };
} }
event pong(c: count, what: string, val: any) event pong(c: count, what: string, val: any)
@ -66,10 +64,16 @@ event pong(c: count, what: string, val: any)
++pongs; ++pongs;
print "got pong", pongs, "with", c, what, type_name(val), val; print "got pong", pongs, "with", c, what, type_name(val), val;
# We send 5 pings in 3 different variations and # The manager sends 5 types of pings, in 3 different ways. The worker
# get two pongs for each. # answers each ping in two ways, for a total of 30 expected pongs at the
# manager. Every batch of pings involves 6 pongs.
if ( pongs == 30 ) if ( pongs == 30 )
Cluster::publish(Cluster::worker_topic, finish); Cluster::publish(Cluster::worker_topic, finish);
else if ( pongs > 0 && pongs % 6 == 0 )
{
# Wait for a batch to complete before sending the next.
event send_any();
}
} }
event Cluster::node_up(name: string, id: string) event Cluster::node_up(name: string, id: string)