cu-cp: avoid that cu-cp stop task runs more than once

Author: frankist

lib/cu_cp/cu_cp_impl.cpp

@@ -114,19 +114,24 @@ void cu_cp_impl::start()
 
 void cu_cp_impl::stop()
 {
+  bool already_stopped = stopped.exchange(true);
+  if (already_stopped) {
+    return;
+  }
+
   logger.info("Stopping CU-CP...");
   std::promise<void> p;
   std::future<void>  fut = p.get_future();
 
   // Shut down components from within CU-CP executor.
   while (not cfg.cu_cp_executor->execute([this, &p]() {
+    // Stop statistics gathering.
     statistics_report_timer.stop();
 
-    routine_mng.reset();
-
     // Signal back that CU-CP is stopped.
     p.set_value();
   })) {
+    logger.debug("Failed to dispatch CU-CP stop task. Retrying...");
     // Keep dispatching until the task is accepted.
     std::this_thread::sleep_for(std::chrono::milliseconds(100));
   }

lib/cu_cp/cu_cp_impl.h

@@ -170,6 +170,8 @@ class cu_cp_impl final : public cu_cp_interface, public cu_cp_impl_interface
   std::atomic<bool> amf_connected = {false};
 
   unique_timer statistics_report_timer;
+
+  std::atomic<bool> stopped{false};
 };
 
 } // namespace srs_cu_cp