diff --git a/userspace/falco/falco_outputs.cpp b/userspace/falco/falco_outputs.cpp index f9ca7b2a..1ae2b2e3 100644 --- a/userspace/falco/falco_outputs.cpp +++ b/userspace/falco/falco_outputs.cpp @@ -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(); } diff --git a/userspace/falco/falco_outputs.h b/userspace/falco/falco_outputs.h index 55492085..45d93141 100644 --- a/userspace/falco/falco_outputs.h +++ b/userspace/falco/falco_outputs.h @@ -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 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);