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

Management framework: log additional node events

Browse source
This commit is contained in:
Christian Kreibich 2022-08-09 15:12:10 -07:00
parent 63291ba2df
commit 7d4dd22aba
2 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
scripts/policy/frameworks/management/agent/main.zeek
View file

@ -262,6 +262,8 @@ event Management::Agent::Runtime::trigger_log_archival(run_archival: bool)
event Management::Supervisor::API::notify_node_exit(node: string, outputs: Management::NodeOutputs) event Management::Supervisor::API::notify_node_exit(node: string, outputs: Management::NodeOutputs)
{ {
Management::Log::info(fmt("rx Management::Supervisor::API::notify_node_exit %s", node));
if ( node in g_nodes ) if ( node in g_nodes )
g_outputs[node] = outputs; g_outputs[node] = outputs;
} }

3
scripts/policy/frameworks/management/node/main.zeek
View file

@ -102,8 +102,11 @@ event Broker::peer_added(peer: Broker::EndpointInfo, msg: string)
# If this is the agent peering, notify it that we're ready # If this is the agent peering, notify it that we're ready
if ( peer$network$address == epi$network$address && if ( peer$network$address == epi$network$address &&
peer$network$bound_port == epi$network$bound_port ) peer$network$bound_port == epi$network$bound_port )
{
Management::Log::info(fmt("tx Management::Node::API::notify_node_hello %s", Cluster::node));
Broker::publish(node_topic, Management::Node::API::notify_node_hello, Cluster::node); Broker::publish(node_topic, Management::Node::API::notify_node_hello, Cluster::node);
} }
}
event zeek_init() event zeek_init()
{ {