wip(broker)

centreon · Oct 17, 2023 · c3973ff · c3973ff
1 parent ca41797
commit c3973ff
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/broker/core/src/processing/feeder.cc b/broker/core/src/processing/feeder.cc
@@ -376,8 +376,8 @@ void feeder::_read_from_stream_timer_handler(
   std::shared_ptr<io::data> event;
   std::chrono::system_clock::time_point timeout_read =
       std::chrono::system_clock::now() + std::chrono::milliseconds(100);
+  std::unique_lock<std::timed_mutex> l(_protect);
   try {
-    std::unique_lock<std::timed_mutex> l(_protect);
     if (_state != state::running)
       return;
     while (std::chrono::system_clock::now() < timeout_read &&
@@ -413,22 +413,22 @@ void feeder::_read_from_stream_timer_handler(
     SPDLOG_LOGGER_INFO(log_v2::processing(), "feeder '{}', connection closed",
                        _name);
     _muxer->write(events_to_publish);
-    stop();
+    _stop_no_lock();
     return;
   } catch (const std::exception& e) {
     set_last_error(e.what());
     SPDLOG_LOGGER_ERROR(log_v2::processing(),
                         "from client feeder '{}' error:{} ", _name, e.what());
     _muxer->write(events_to_publish);
-    stop();
+    _stop_no_lock();
     return;
   } catch (...) {
     SPDLOG_LOGGER_ERROR(log_v2::processing(),
                         "from client feeder: unknown error occured while "
                         "processing client '{}'",
                         _name);
     _muxer->write(events_to_publish);
-    stop();
+    _stop_no_lock();
     return;
   }
   _muxer->write(events_to_publish);