fix(broker/engine): unused code removed

broker/bam/test/ba/kpi_ba.cc

@@ -41,9 +41,9 @@ class KpiBA : public ::testing::Test {
     // Initialization.
     config::applier::init(0, "test_broker", 0);
 
-    _aply_state.reset(new bam::configuration::applier::state);
-    _state.reset(new bam::configuration::state);
-    _visitor.reset(new test_visitor("test-visitor"));
+    _aply_state = std::make_unique<bam::configuration::applier::state>();
+    _state = std::make_unique<bam::configuration::state>();
+    _visitor = std::make_unique<test_visitor>("test-visitor");
   }
 
   void TearDown() override {

broker/core/inc/com/centreon/broker/multiplexing/engine.hh

@@ -85,20 +85,18 @@ class engine {
   uint32_t _unprocessed_events;
 
   std::atomic_bool _sending_to_subscribers;
-  const size_t _event_queues_total_size;
 
-  engine(size_t event_queues_total_size);
+  engine();
   std::string _cache_file_path() const;
   void _send_to_subscribers();
 
   void (engine::*_write_func)(std::shared_ptr<io::data> const&);
 
  public:
-  static void load(size_t event_queues_total_size);
+  static void load();
   static void unload();
   static engine& instance();
 
-  engine() = delete;
   engine(const engine&) = delete;
   engine& operator=(const engine&) = delete;
   ~engine() noexcept;

broker/core/src/config/applier/init.cc

@@ -62,7 +62,7 @@ void config::applier::init(size_t n_thread,
   mysql_manager::load();
   config::applier::state::load();
   file::disk_accessor::load(event_queues_total_size);
-  multiplexing::engine::load(event_queues_total_size);
+  multiplexing::engine::load();
   io::protocols::load();
   io::events::load();
   config::applier::endpoint::load();

broker/core/src/multiplexing/engine.cc

@@ -48,14 +48,12 @@ engine& engine::instance() {
 /**
  * @brief Load engine instance. The argument is the total size allowed for
  * queue files.
- *
- * @param event_queues_total_size A size in bytes.
  */
-void engine::load(size_t event_queues_total_size) {
+void engine::load() {
   log_v2::core()->trace("multiplexing: loading engine");
   std::lock_guard<std::mutex> lk(_load_m);
   if (!_instance)
-    _instance = new engine(event_queues_total_size);
+    _instance = new engine();
 }
 
 /**
@@ -264,17 +262,14 @@ void engine::unsubscribe(muxer* subscriber) {
 /**
  * @brief Constructor of the multiplexing engine. The argument is the total
  * size allowed for the queue files. If 0 is specified, no limit is given.
- *
- * @param event_queues_total_size A size in bytes.
  */
-engine::engine(size_t event_queues_total_size)
+engine::engine()
     : _state{not_started},
       _strand(pool::instance().io_context()),
       _muxers{},
       _stats{stats::center::instance().register_engine()},
       _unprocessed_events{0u},
-      _sending_to_subscribers{false},
-      _event_queues_total_size{event_queues_total_size} {
+      _sending_to_subscribers{false} {
   stats::center::instance().update(&EngineStats::set_mode, _stats,
                                    EngineStats::NOT_STARTED);
 }

broker/core/test/processing/feeder.cc

@@ -48,7 +48,7 @@ class TestFeeder : public ::testing::Test {
     stats::center::load();
     config::applier::state::load();
     file::disk_accessor::load(10000);
-    multiplexing::engine::load(0);
+    multiplexing::engine::load();
     io::protocols::load();
     io::events::load();
 

broker/stats/test/stats.cc

@@ -50,7 +50,7 @@ class StatsTest : public ::testing::Test {
     mysql_manager::load();
     config::applier::state::load();
     file::disk_accessor::load(10000);
-    multiplexing::engine::load(0);
+    multiplexing::engine::load();
     io::protocols::load();
     io::events::load();
     config::applier::endpoint::load();