f1ap-du: defer transmit notifications to UE executor

frankist · frankist · commit 7e03996ce606 · 2024-07-17T10:00:47.000+02:00
diff --git a/lib/f1ap/du/ue_context/f1c_du_bearer_impl.cpp b/lib/f1ap/du/ue_context/f1c_du_bearer_impl.cpp
@@ -212,7 +212,10 @@ void f1c_other_srb_du_bearer::handle_transmit_notification(uint32_t highest_pdcp
 
 void f1c_other_srb_du_bearer::handle_delivery_notification(uint32_t highest_pdcp_sn)
 {
-  handle_notification(highest_pdcp_sn, false);
+  if (not ue_exec.defer([this, highest_pdcp_sn]() { handle_notification(highest_pdcp_sn, false); })) {
+    logger.warning("Discarded delivery notification for SRB{} because the task executor queue is full.",
+                   srb_id_to_uint(srb_id));
+  }
 }
 
 async_task<void> f1c_other_srb_du_bearer::handle_pdu_and_await(byte_buffer pdu, bool tx_or_delivery)

Original file line number	Diff line number	Diff line change
`@@ -212,7 +212,10 @@ void f1c_other_srb_du_bearer::handle_transmit_notification(uint32_t highest_pdcp`
`212`	`212`
`213`	`213`	`void f1c_other_srb_du_bearer::handle_delivery_notification(uint32_t highest_pdcp_sn)`
`214`	`214`	`{`
`215`		`- handle_notification(highest_pdcp_sn, false);`
	`215`	`+ if (not ue_exec.defer([this, highest_pdcp_sn]() { handle_notification(highest_pdcp_sn, false); })) {`
	`216`	`+ logger.warning("Discarded delivery notification for SRB{} because the task executor queue is full.",`
	`217`	`+ srb_id_to_uint(srb_id));`
	`218`	`+ }`
`216`	`219`	`}`
`217`	`220`
`218`	`221`	`async_task<void> f1c_other_srb_du_bearer::handle_pdu_and_await(byte_buffer pdu, bool tx_or_delivery)`