github/falco
1
0
Fork 0
mirror of https://github.com/falcosecurity/falco.git synced 2025-07-17 16:21:31 +00:00
Code Issues Projects Releases Wiki Activity

update(userspace/falco): watchdog for outputs

Browse Source 
Signed-off-by: Leonardo Grasso <me@leonardograsso.com>
This commit is contained in:
Leonardo Grasso 2020-11-03 18:24:13 +01:00 committed by poiana
parent 3b7401c2e5
commit 5b558cd600
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
userspace/falco/falco_outputs.cpp
View File

@ -24,6 +24,7 @@ limitations under the License.
#include "formats.h" #include "formats.h"
#include "logger.h" #include "logger.h"
#include "watchdog.h"
#include "outputs_file.h" #include "outputs_file.h"
#include "outputs_program.h" #include "outputs_program.h"
@ -273,6 +274,12 @@ inline void falco_outputs::push(ctrl_msg_type cmt)
void falco_outputs::worker() void falco_outputs::worker()
{ {
Watchdog<std::string> wd;
wd.start([&](std::string payload) -> void {
falco_logger::log(LOG_CRIT, "\"" + payload + "\" output deadline exceeded, all output channels are blocked.\n");
});
falco_outputs::ctrl_msg cmsg; falco_outputs::ctrl_msg cmsg;
while(true) while(true)
{ {
@ -284,7 +291,9 @@ void falco_outputs::worker()
for(auto it = m_outputs.cbegin(); it != m_outputs.cend(); ++it) for(auto it = m_outputs.cbegin(); it != m_outputs.cend(); ++it)
{ {
try { wd.set_timeout(std::chrono::milliseconds(2000), (*it)->get_name());
try
{
switch(cmsg.type) switch(cmsg.type)
{ {
case ctrl_msg_type::CTRL_MSG_OUTPUT: case ctrl_msg_type::CTRL_MSG_OUTPUT:
@ -299,9 +308,12 @@ void falco_outputs::worker()
default: default:
falco_logger::log(LOG_DEBUG, "Outputs worker received an unknown message type\n"); falco_logger::log(LOG_DEBUG, "Outputs worker received an unknown message type\n");
} }
} catch(const exception &e) { }
catch(const exception &e)
{
falco_logger::log(LOG_ERR, (*it)->get_name() + ": " + string(e.what()) + "\n"); falco_logger::log(LOG_ERR, (*it)->get_name() + ": " + string(e.what()) + "\n");
} }
} }
wd.cancel_timeout();
} }
} }