f1ap-du: defer delivery notifications to UE executor

frankist · frankist · commit bad01194b756 · 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
@@ -207,7 +207,10 @@ async_task<void> f1c_other_srb_du_bearer::handle_pdu_and_await_delivery(byte_buf
 
 void f1c_other_srb_du_bearer::handle_transmit_notification(uint32_t highest_pdcp_sn)
 {
-  handle_notification(highest_pdcp_sn, true);
+  if (not ue_exec.defer([this, highest_pdcp_sn]() { handle_notification(highest_pdcp_sn, true); })) {
+    logger.warning("Discarded transmit notification for SRB{} because the task executor queue is full.",
+                   srb_id_to_uint(srb_id));
+  }
 }
 
 void f1c_other_srb_du_bearer::handle_delivery_notification(uint32_t highest_pdcp_sn)

Original file line number	Diff line number	Diff line change
`@@ -207,7 +207,10 @@ async_task<void> f1c_other_srb_du_bearer::handle_pdu_and_await_delivery(byte_buf`
`207`	`207`
`208`	`208`	`void f1c_other_srb_du_bearer::handle_transmit_notification(uint32_t highest_pdcp_sn)`
`209`	`209`	`{`
`210`		`- handle_notification(highest_pdcp_sn, true);`
	`210`	`+ if (not ue_exec.defer([this, highest_pdcp_sn]() { handle_notification(highest_pdcp_sn, true); })) {`
	`211`	`+ logger.warning("Discarded transmit notification for SRB{} because the task executor queue is full.",`
	`212`	`+ srb_id_to_uint(srb_id));`
	`213`	`+ }`
`211`	`214`	`}`
`212`	`215`
`213`	`216`	`void f1c_other_srb_du_bearer::handle_delivery_notification(uint32_t highest_pdcp_sn)`