diff --git a/userspace/engine/falco_common.h b/userspace/engine/falco_common.h index b62c24ff..acc1030e 100644 --- a/userspace/engine/falco_common.h +++ b/userspace/engine/falco_common.h @@ -25,7 +25,7 @@ limitations under the License. // equivalent to an "unbounded queue" in TBB terms or largest long value // https://github.com/oneapi-src/oneTBB/blob/b2474bfc636937052d05daf8b3f4d6b76e20273a/include/oneapi/tbb/concurrent_queue.h#L554 // -#define DEFAULT_OUTPUTS_QUEUE_CAPACITY std::ptrdiff_t(~size_t(0) / 2) +#define DEFAULT_OUTPUTS_QUEUE_CAPACITY_UNBOUNDED_MAX_LONG_VALUE std::ptrdiff_t(~size_t(0) / 2) // // Most falco_* classes can throw exceptions. Unless directly related diff --git a/userspace/falco/configuration.cpp b/userspace/falco/configuration.cpp index 5dfd2b7d..3e45b19e 100644 --- a/userspace/falco/configuration.cpp +++ b/userspace/falco/configuration.cpp @@ -40,7 +40,7 @@ falco_configuration::falco_configuration(): m_rule_matching(falco_common::rule_matching::FIRST), m_watch_config_files(true), m_buffered_outputs(false), - m_outputs_queue_capacity(DEFAULT_OUTPUTS_QUEUE_CAPACITY), + m_outputs_queue_capacity(DEFAULT_OUTPUTS_QUEUE_CAPACITY_UNBOUNDED_MAX_LONG_VALUE), m_outputs_queue_recovery(falco_common::RECOVERY_EXIT), m_time_format_iso_8601(false), m_output_timeout(2000), @@ -283,11 +283,11 @@ void falco_configuration::load_yaml(const std::string& config_name, const yaml_h } m_buffered_outputs = config.get_scalar("buffered_outputs", false); - m_outputs_queue_capacity = config.get_scalar("outputs_queue.capacity", DEFAULT_OUTPUTS_QUEUE_CAPACITY); + m_outputs_queue_capacity = config.get_scalar("outputs_queue.capacity", DEFAULT_OUTPUTS_QUEUE_CAPACITY_UNBOUNDED_MAX_LONG_VALUE); // We use 0 in falco.yaml to indicate an unbounded queue; equivalent to the largest long value if (m_outputs_queue_capacity == 0) { - m_outputs_queue_capacity = DEFAULT_OUTPUTS_QUEUE_CAPACITY; + m_outputs_queue_capacity = DEFAULT_OUTPUTS_QUEUE_CAPACITY_UNBOUNDED_MAX_LONG_VALUE; } std::string recovery = config.get_scalar("outputs_queue.recovery", "exit"); if (!falco_common::parse_queue_recovery(recovery, m_outputs_queue_recovery))