github/falco
1
0
Fork 0
mirror of https://github.com/falcosecurity/falco.git synced 2025-08-13 03:46:14 +00:00
Code Issues Projects Releases Wiki Activity

fix(userspace/falco): change outputs_queue_num_drops to atomic

Browse Source 
Co-authored-by: Jason Dellaluce <jasondellaluce@gmail.com>
Signed-off-by: Melissa Kilby <melissa.kilby.oss@gmail.com>
This commit is contained in:
Melissa Kilby 2023-09-05 20:58:36 +00:00 committed by poiana
parent 88a5e1bf45
commit dad2762ed6
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
userspace/falco/falco_outputs.cpp
View File

@ -65,7 +65,7 @@ falco_outputs::falco_outputs(
{
add_output(output);
}
m_outputs_queue_num_drops = 0UL;
m_outputs_queue_num_drops = {0};
m_outputs_queue_recovery = outputs_queue_recovery;
#ifndef __EMSCRIPTEN__
m_queue.set_capacity(outputs_queue_capacity);
@ -371,5 +371,5 @@ inline void falco_outputs::process_msg(falco::outputs::abstract_output* o, const
uint64_t falco_outputs::get_outputs_queue_num_drops()
{
return m_outputs_queue_num_drops;
return m_outputs_queue_num_drops.load();
}

2
userspace/falco/falco_outputs.h
View File

@ -121,7 +121,7 @@ private:
#endif
falco_common::outputs_queue_recovery_type m_outputs_queue_recovery;
uint64_t m_outputs_queue_num_drops;
std::atomic<uint64_t> m_outputs_queue_num_drops;
std::thread m_worker_thread;
inline void push(const ctrl_msg& cmsg);
inline void push_ctrl(ctrl_msg_type cmt);