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

cluster_started: No Broker::auto_publish() use

Browse source
This commit is contained in:
Arne Welzel 2024-11-05 22:58:52 +01:00
parent b32153037a
commit 416887157c
1 changed files with 5 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

12
scripts/policy/frameworks/cluster/experimental.zeek
View file

@ -48,11 +48,6 @@ global is_cluster_started = F;
@load ./nodes-experimental/manager @load ./nodes-experimental/manager
@endif @endif
event zeek_init() &priority=4
{
Broker::auto_publish(Cluster::manager_topic, Cluster::Experimental::node_fully_connected);
}
hook Cluster::connect_node_hook(connectee: Cluster::NamedNode) hook Cluster::connect_node_hook(connectee: Cluster::NamedNode)
{ {
add connectees_pending[connectee$name]; add connectees_pending[connectee$name];
@ -71,8 +66,11 @@ event Cluster::node_up(name: string, id: string) &priority=-10
# pending connectee is left. # pending connectee is left.
delete connectees_pending[name]; delete connectees_pending[name];
if ( |connectees_pending| == 0 ) if ( |connectees_pending| == 0 )
event Cluster::Experimental::node_fully_connected(Cluster::node, Broker::node_id(), {
is_cluster_started); event node_fully_connected(Cluster::node, Broker::node_id(), is_cluster_started);
Broker::publish(Cluster::manager_topic, node_fully_connected,
Cluster::node, Broker::node_id(), is_cluster_started);
}
} }
event Cluster::Experimental::node_fully_connected(name: string, id: string, resending: bool) event Cluster::Experimental::node_fully_connected(name: string, id: string, resending: bool)