Implement F1/split case for UE Context Setup

openair2/LAYER2/NR_MAC_gNB/mac_rrc_ul_f1ap.c

@@ -19,16 +19,45 @@
  *      conmnc_digit_lengtht@openairinterface.org
  */
 
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+
 #include "nr_mac_gNB.h"
 #include "intertask_interface.h"
+#include "openair3/ocp-gtpu/gtp_itf.h"
 
 #include "mac_rrc_ul.h"
 
 static void ue_context_setup_response_f1ap(const f1ap_ue_context_setup_t *req, const f1ap_ue_context_setup_t *resp)
 {
-  AssertFatal(false, "not implemented\n");
+  DevAssert(req->drbs_to_be_setup_length == resp->drbs_to_be_setup_length);
+  AssertFatal(req->drbs_to_be_setup_length == 0, "not implmented\n");
+
+  DevAssert(req->srbs_to_be_setup_length == resp->srbs_to_be_setup_length);
+  MessageDef *msg = itti_alloc_new_message (TASK_MAC_GNB, 0, F1AP_UE_CONTEXT_SETUP_RESP);
+  f1ap_ue_context_setup_t *f1ap_msg = &F1AP_UE_CONTEXT_SETUP_RESP(msg);
+  /* copy all fields, but reallocate rrc_containers! */
+  *f1ap_msg = *resp;
+
+  if (resp->srbs_to_be_setup_length > 0) {
+    DevAssert(resp->srbs_to_be_setup != NULL);
+    f1ap_msg->srbs_to_be_setup_length = resp->srbs_to_be_setup_length;
+    f1ap_msg->srbs_to_be_setup = calloc(f1ap_msg->srbs_to_be_setup_length, sizeof(*f1ap_msg->srbs_to_be_setup));
+    for (int i = 0; i < f1ap_msg->srbs_to_be_setup_length; ++i)
+      f1ap_msg->srbs_to_be_setup[i] = resp->srbs_to_be_setup[i];
+  }
+
+  f1ap_msg->du_to_cu_rrc_information = malloc(sizeof(*resp->du_to_cu_rrc_information));
+  AssertFatal(f1ap_msg->du_to_cu_rrc_information != NULL, "out of memory\n");
+  f1ap_msg->du_to_cu_rrc_information_length = resp->du_to_cu_rrc_information_length;
+  du_to_cu_rrc_information_t *du2cu = f1ap_msg->du_to_cu_rrc_information;
+  du2cu->cellGroupConfig_length = resp->du_to_cu_rrc_information->cellGroupConfig_length;
+  du2cu->cellGroupConfig = calloc(du2cu->cellGroupConfig_length, sizeof(*du2cu->cellGroupConfig));
+  AssertFatal(du2cu->cellGroupConfig != NULL, "out of memory\n");
+  memcpy(du2cu->cellGroupConfig, resp->du_to_cu_rrc_information->cellGroupConfig, du2cu->cellGroupConfig_length);
 
-  /* TODO: set up GTP tunnel for DL, and fill UL TEID in resp */
+  itti_send_msg_to_task(TASK_DU_F1, 0, msg);
 }
 
 static void initial_ul_rrc_message_transfer_f1ap(module_id_t module_id, const f1ap_initial_ul_rrc_message_t *ul_rrc)

openair2/RRC/NR/mac_rrc_dl_f1ap.c

@@ -26,8 +26,18 @@
 
 static void ue_context_setup_request_f1ap(const f1ap_ue_context_setup_t *req)
 {
-  (void) req;
-  abort();
+  MessageDef *msg = itti_alloc_new_message(TASK_RRC_GNB, 0, F1AP_UE_CONTEXT_SETUP_REQ);
+  f1ap_ue_context_setup_t *f1ap_msg = &F1AP_UE_CONTEXT_SETUP_REQ(msg);
+  *f1ap_msg = *req;
+  AssertFatal(req->cu_to_du_rrc_information == NULL, "cu_to_du_rrc_information not supported yet\n");
+  f1ap_msg->cu_to_du_rrc_information = malloc(sizeof(*f1ap_msg->cu_to_du_rrc_information));
+  if (req->rrc_container_length > 0) {
+    f1ap_msg->rrc_container = calloc(req->rrc_container_length, sizeof(*f1ap_msg->rrc_container));
+    AssertFatal(f1ap_msg->rrc_container != NULL, "out of memory\n");
+    f1ap_msg->rrc_container_length = req->rrc_container_length;
+    memcpy(f1ap_msg->rrc_container, req->rrc_container, req->rrc_container_length);
+  }
+  itti_send_msg_to_task(TASK_CU_F1, 0, msg);
 }
 
 static void dl_rrc_message_transfer_f1ap(module_id_t module_id, const f1ap_dl_rrc_message_t *dl_rrc)