enh(engine/anomalydetection): Enable recheck for anomaly-detection se…

…rvices

REFS: MON-14158

bbdo/CMakeLists.txt

@@ -119,7 +119,7 @@ add_library(
   "storage/status.hh"
 )
 set_target_properties(bbdo_storage PROPERTIES POSITION_INDEPENDENT_CODE ON)
-target_precompile_headers(bbdo_storage PRIVATE precomp_inc/precomp.hpp)
+target_precompile_headers(bbdo_storage REUSE_FROM bbdo_bbdo)
 add_dependencies(bbdo_storage table_max_size)
 add_library(
   bbdo_bam STATIC
@@ -157,5 +157,5 @@ add_library(
   "bam/kpi_event.hh"
 )
 set_target_properties(bbdo_bam PROPERTIES POSITION_INDEPENDENT_CODE ON)
-target_precompile_headers(bbdo_bam PRIVATE precomp_inc/precomp.hpp)
+target_precompile_headers(bbdo_bam REUSE_FROM bbdo_bbdo)
 add_dependencies(bbdo_bam table_max_size)

broker/neb/CMakeLists.txt

@@ -1,20 +1,20 @@
-##
-## Copyright 2009-2013,2015 Centreon
-##
-## Licensed under the Apache License, Version 2.0 (the "License");
-## you may not use this file except in compliance with the License.
-## You may obtain a copy of the License at
-##
-##     http://www.apache.org/licenses/LICENSE-2.0
-##
-## Unless required by applicable law or agreed to in writing, software
-## distributed under the License is distributed on an "AS IS" BASIS,
-## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-## See the License for the specific language governing permissions and
-## limitations under the License.
-##
-## For more information : contact@centreon.com
-##
+# #
+# # Copyright 2009-2013,2015 Centreon
+# #
+# # Licensed under the Apache License, Version 2.0 (the "License");
+# # you may not use this file except in compliance with the License.
+# # You may obtain a copy of the License at
+# #
+# #     http://www.apache.org/licenses/LICENSE-2.0
+# #
+# # Unless required by applicable law or agreed to in writing, software
+# # distributed under the License is distributed on an "AS IS" BASIS,
+# # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# # See the License for the specific language governing permissions and
+# # limitations under the License.
+# #
+# # For more information : contact@centreon.com
+# #
 
 # Global options.
 set(INC_DIR "${PROJECT_SOURCE_DIR}/neb/inc")
@@ -24,6 +24,7 @@ include_directories("${INC_DIR}")
 
 # NEB sources.
 set(NEB_SOURCES
+
   # Sources.
   # Headers.
   ${SRC_DIR}/acknowledgement.cc
@@ -100,20 +101,21 @@ set(NEB_SOURCES
 add_library(nebbase STATIC ${NEB_SOURCES})
 add_dependencies(nebbase table_max_size target_service target_host target_severity target_tag)
 target_link_libraries(nebbase
-    CONAN_PKG::protobuf
-    pb_service_lib
-    pb_host_lib
-    pb_severity_lib
-    pb_tag_lib)
+  CONAN_PKG::protobuf
+  pb_service_lib
+  pb_host_lib
+  pb_severity_lib
+  pb_tag_lib)
 
 set(NEBBASE_CXXFLAGS "${NEBBASE_CXXFLAGS} -fPIC")
 set_property(TARGET nebbase PROPERTY COMPILE_FLAGS ${NEBBASE_CXXFLAGS})
-target_precompile_headers(nebbase PRIVATE precomp_inc/nebbase_precomp.hpp)
+target_precompile_headers(nebbase PRIVATE precomp_inc/precomp.hpp)
 
 # Centreon Broker module.
 set(NEB "10-neb")
 set(NEB "${NEB}" PARENT_SCOPE)
 add_library("${NEB}" SHARED
+
   # Main source.
   "${SRC_DIR}/broker.cc"
   "${SRC_DIR}/node_id.cc"
@@ -126,16 +128,18 @@ add_library("${NEB}" SHARED
 
 # Flags needed to include all symbols in binary.
 target_link_libraries(${NEB} nebbase CONAN_PKG::spdlog)
-#  "-Wl,--whole-archive" nebbase "-Wl,--no-whole-archive")
+
+# "-Wl,--whole-archive" nebbase "-Wl,--no-whole-archive")
 set_target_properties("${NEB}" PROPERTIES PREFIX "")
-target_precompile_headers(${NEB} PRIVATE precomp_inc/neb_precomp.hpp)
+target_precompile_headers(${NEB} REUSE_FROM nebbase)
 install(TARGETS "${NEB}"
   LIBRARY DESTINATION "${PREFIX_MODULES}"
 )
 
 # Centreon Engine/Nagios module.
 set(CBMOD "cbmod")
 add_library("${CBMOD}" SHARED
+
   # Sources.
   "${PROJECT_SOURCE_DIR}/core/src/config/applier/init.cc"
   "${SRC_DIR}/callback.cc"
@@ -144,6 +148,7 @@ add_library("${CBMOD}" SHARED
   "${SRC_DIR}/internal.cc"
   "${SRC_DIR}/neb.cc"
   "${SRC_DIR}/set_log_data.cc"
+
   # Headers.
   "${INC_DIR}/com/centreon/broker/neb/callback.hh"
   "${INC_DIR}/com/centreon/broker/neb/callbacks.hh"
@@ -157,52 +162,54 @@ get_property(CBMOD_DEFINES
 list(APPEND CBMOD_DEFINES CBMOD)
 set_property(TARGET "${CBMOD}"
   PROPERTY COMPILE_DEFINITIONS "${CBMOD_DEFINES}")
-if (CMAKE_COMPILER_IS_GNUCXX OR CMAKE_CXX_COMPILER_ID STREQUAL "Clang")
+
+if(CMAKE_COMPILER_IS_GNUCXX OR CMAKE_CXX_COMPILER_ID STREQUAL "Clang")
   # Flags needed to include all symbols in shared library.
   target_link_libraries("${CBMOD}"
     "-Wl,--whole-archive" "rokerbase" "-Wl,--no-whole-archive" CONAN_PKG::nlohmann_json CONAN_PKG::spdlog CONAN_PKG::asio)
-else ()
+else()
   target_link_libraries("${CBMOD}" "rokerbase" CONAN_PKG::nlohmann_json CONAN_PKG::spdlog CONAN_PKG::asio)
-endif ()
-set_target_properties("${CBMOD}" PROPERTIES PREFIX "")
-target_precompile_headers(${CBMOD} PRIVATE precomp_inc/precomp.hpp)
+endif()
 
+set_target_properties("${CBMOD}" PROPERTIES PREFIX "")
+target_precompile_headers(${CBMOD} REUSE_FROM nebbase)
 
 # Testing.
-if (WITH_TESTING)
+if(WITH_TESTING)
   set(
-      TESTS_SOURCES
-      ${TESTS_SOURCES}
-      ${SRC_DIR}/set_log_data.cc
-      #Actual tests
-      ${TEST_DIR}/custom_variable.cc
-      ${TEST_DIR}/custom_variable_status.cc
-      ${TEST_DIR}/event_handler.cc
-      ${TEST_DIR}/flapping_status.cc
-      ${TEST_DIR}/host.cc
-      ${TEST_DIR}/host_check.cc
-      ${TEST_DIR}/host_dependency.cc
-      ${TEST_DIR}/host_parent.cc
-      ${TEST_DIR}/host_status.cc
-      ${TEST_DIR}/instance.cc
-      ${TEST_DIR}/instance_status.cc
-      ${TEST_DIR}/log_entry.cc
-      ${TEST_DIR}/module.cc
-      ${TEST_DIR}/randomize.cc
-      ${TEST_DIR}/randomize.hh
-      ${TEST_DIR}/service.cc
-      ${TEST_DIR}/service_check.cc
-      ${TEST_DIR}/service_dependency.cc
-      ${TEST_DIR}/service_status.cc
-      ${TEST_DIR}/set_log_data.cc
-      PARENT_SCOPE
-     )
+    TESTS_SOURCES
+    ${TESTS_SOURCES}
+    ${SRC_DIR}/set_log_data.cc
+
+    # Actual tests
+    ${TEST_DIR}/custom_variable.cc
+    ${TEST_DIR}/custom_variable_status.cc
+    ${TEST_DIR}/event_handler.cc
+    ${TEST_DIR}/flapping_status.cc
+    ${TEST_DIR}/host.cc
+    ${TEST_DIR}/host_check.cc
+    ${TEST_DIR}/host_dependency.cc
+    ${TEST_DIR}/host_parent.cc
+    ${TEST_DIR}/host_status.cc
+    ${TEST_DIR}/instance.cc
+    ${TEST_DIR}/instance_status.cc
+    ${TEST_DIR}/log_entry.cc
+    ${TEST_DIR}/module.cc
+    ${TEST_DIR}/randomize.cc
+    ${TEST_DIR}/randomize.hh
+    ${TEST_DIR}/service.cc
+    ${TEST_DIR}/service_check.cc
+    ${TEST_DIR}/service_dependency.cc
+    ${TEST_DIR}/service_status.cc
+    ${TEST_DIR}/set_log_data.cc
+    PARENT_SCOPE
+  )
   set(
-      TESTS_LIBRARIES
-      ${TESTS_LIBRARIES}
-      ${NEB}
-      PARENT_SCOPE
-     )
+    TESTS_LIBRARIES
+    ${TESTS_LIBRARIES}
+    ${NEB}
+    PARENT_SCOPE
+  )
 endif()
 
 # Install rules.

broker/neb/precomp_inc/precomp.hpp

@@ -37,6 +37,7 @@
 #include <absl/strings/string_view.h>
 
 #include <boost/circular_buffer.hpp>
+#include <boost/container/flat_map.hpp>
 #include <boost/optional.hpp>
 
 #include <asio.hpp>

clib/inc/com/centreon/timestamp.hh

@@ -21,6 +21,7 @@
 
 #include <cstdint>
 #include <ctime>
+#include <ostream>
 #include "com/centreon/namespace.hh"
 
 CC_BEGIN()
@@ -39,6 +40,8 @@ class timestamp {
  public:
   timestamp(time_t secs = 0, int32_t usecs = 0);
   timestamp(const timestamp& right);
+  timestamp(const struct timeval& right)
+      : _secs(right.tv_sec), _usecs(right.tv_usec) {}
   ~timestamp() noexcept = default;
   timestamp& operator=(const timestamp& right);
   bool operator==(const timestamp& right) const noexcept;
@@ -66,6 +69,8 @@ class timestamp {
   int64_t to_useconds() const noexcept;
 };
 
+std::ostream& operator<<(std::ostream& s, const timestamp& to_dump);
+
 CC_END()
 
 #endif  // !CC_TIMESTAMP_HH

clib/src/timestamp.cc

@@ -319,3 +319,18 @@ time_t timestamp::to_seconds() const noexcept {
 int64_t timestamp::to_useconds() const noexcept {
   return _secs * 1000000ll + _usecs;
 }
+
+CC_BEGIN()
+
+std::ostream& operator<<(std::ostream& s, const timestamp& to_dump) {
+  struct tm tmp;
+  time_t seconds = to_dump.to_seconds();
+  localtime_r(&seconds, &tmp);
+  char buf[80];
+  strftime(buf, sizeof(buf), "%c: ", &tmp);
+  s << buf;
+
+  return s;
+}
+
+CC_END()