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: a bit of debug-level logging for troubleshooting

Browse source
This commit is contained in:
Christian Kreibich 2022-05-30 14:40:00 -07:00
parent 93bed5a261
commit c922f749c5
1 changed files with 9 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

9
scripts/policy/frameworks/management/controller/main.zeek
View file

@ -169,6 +169,8 @@ function add_instance(inst: Management::Instance)
Broker::publish(Management::Agent::topic_prefix + "/" + inst$name, Broker::publish(Management::Agent::topic_prefix + "/" + inst$name,
Management::Agent::API::agent_welcome_request, req$id); Management::Agent::API::agent_welcome_request, req$id);
} }
else
Management::Log::debug(fmt("instance %s not known to us, skipping", inst$name));
} }
function drop_instance(inst: Management::Instance) function drop_instance(inst: Management::Instance)
@ -281,6 +283,7 @@ event Management::Agent::API::notify_agent_hello(instance: string, host: addr, a
} }
add g_instances_known[instance]; add g_instances_known[instance];
Management::Log::debug(fmt("instance %s now known to us", instance));
if ( instance in g_instances && instance !in g_instances_ready ) if ( instance in g_instances && instance !in g_instances_ready )
{ {
@ -485,9 +488,15 @@ event Management::Controller::API::set_configuration_request(reqid: string, conf
# case we need to re-establish connectivity with an agent. # case we need to re-establish connectivity with an agent.
for ( inst_name in insts_to_drop ) for ( inst_name in insts_to_drop )
{
Management::Log::debug(fmt("dropping instance %s", inst_name));
drop_instance(g_instances[inst_name]); drop_instance(g_instances[inst_name]);
}
for ( inst_name in insts_to_peer ) for ( inst_name in insts_to_peer )
{
Management::Log::debug(fmt("adding instance %s", inst_name));
add_instance(insts_to_peer[inst_name]); add_instance(insts_to_peer[inst_name]);
}
# Updates to out instance tables are complete, now check if we're already # Updates to out instance tables are complete, now check if we're already
# able to send the config to the agents: # able to send the config to the agents: