cu_up,f1u: added stop flag to CU F1-U bearer

Author: alvasMan

lib/f1u/cu_up/f1u_bearer_impl.cpp

@@ -55,6 +55,9 @@ void f1u_bearer_impl::handle_pdu(nru_ul_message msg)
 
 void f1u_bearer_impl::handle_pdu_impl(nru_ul_message msg)
 {
+  if (stopped) {
+    return;
+  }
   logger.log_debug("F1-U bearer received PDU");
 
   // handle T-PDU
@@ -124,6 +127,10 @@ void f1u_bearer_impl::handle_pdu_impl(nru_ul_message msg)
 
 void f1u_bearer_impl::handle_sdu(byte_buffer sdu, bool is_retx)
 {
+  if (stopped) {
+    return;
+  }
+
   logger.log_debug("F1-U bearer received SDU. size={} is_retx={}", sdu.length(), is_retx);
   nru_dl_message msg = {};
 
@@ -186,6 +193,9 @@ void f1u_bearer_impl::fill_discard_blocks(nru_dl_message& msg)
 
 void f1u_bearer_impl::on_expired_dl_notif_timer()
 {
+  if (stopped) {
+    return;
+  }
   logger.log_debug("DL notification timer expired");
   flush_discard_blocks();
 }

lib/f1u/cu_up/f1u_bearer_impl.h

@@ -43,7 +43,14 @@ class f1u_bearer_impl final : public f1u_bearer, public f1u_rx_pdu_handler, publ
   f1u_rx_pdu_handler& get_rx_pdu_handler() override { return *this; }
   f1u_tx_sdu_handler& get_tx_sdu_handler() override { return *this; }
 
-  void stop() override { dl_notif_timer.stop(); }
+  void stop() override
+  {
+    if (stopped) {
+      return;
+    }
+    stopped = true;
+    dl_notif_timer.stop();
+  }
 
   void handle_pdu(nru_ul_message msg) override;
   void handle_sdu(byte_buffer sdu, bool is_retx) override;
@@ -73,6 +80,8 @@ class f1u_bearer_impl final : public f1u_bearer, public f1u_rx_pdu_handler, publ
   task_executor&            dl_exec;
   task_executor&            ul_exec;
 
+  bool stopped = false;
+
   /// Sentinel value representing a not-yet set PDCP SN
   static constexpr uint32_t unset_pdcp_sn = UINT32_MAX;