Update main

Author: codebot

.gitlab/ci/build.yml

@@ -727,6 +727,7 @@ smoke valgrind update cache:
   artifacts:
     <<: *build_artifacts
     when: on_failure
+    expire_in: 1 day
   cache:
     - *cache_build_set
 
@@ -1710,6 +1711,7 @@ basic avx512 dpdk:
     FORCE_DEBUG_INFO: "True"
     ASSERT_LEVEL: AUTO
     INFRASTRUCTURE_TAG: amd64-avx2-avx512
+    BUILD_ARGS: -DEXIT_TIMEOUT=15
   after_script:
     - *build_after_script
   artifacts:

.gitlab/ci/e2e/.env

@@ -1,6 +1,6 @@
 SRSGNB_REGISTRY_URI=registry.gitlab.com/softwareradiosystems/srsgnb
 RETINA_REGISTRY_PREFIX=registry.gitlab.com/softwareradiosystems/ci/retina
-RETINA_VERSION=0.59.5
+RETINA_VERSION=0.60.5
 UBUNTU_VERSION=24.04
 AMARISOFT_VERSION=2023-09-08
 SRSUE_VERSION=23.11

.gitlab/ci/e2e/retina_request_test_mode.yml

@@ -36,11 +36,14 @@
     arch: amd64
     cpu:
       requests: 1
+      limits: 1
     memory:
-      requests: "4G"
+      requests: "8G"
+      limits: "8G"
     ephemeral-storage:
       requests: "6G"
       limits: "6G"
   image: ${RETINA_REGISTRY_PREFIX}/open5gs:${OPEN5GS_VERSION}_${RETINA_VERSION}
   labels:
     - ${ZMQ_HOSTLABEL_0}
+

.gitlab/ci/e2e/retina_request_test_mode_acc100.yml

@@ -18,8 +18,8 @@
       requests: "60G"
       limits: "60G"
     ephemeral-storage:
-      requests: "6G"
-      limits: "6G"
+      requests: "50G"
+      limits: "50G"
     hugepages-1Gi:
       requests: 8Gi
       limits: 8Gi
@@ -39,11 +39,12 @@
     arch: amd64
     cpu:
       requests: 1
+      limits: 1
     memory:
-      requests: "4G"
+      requests: "8G"
+      limits: "8G"
     ephemeral-storage:
       requests: "6G"
       limits: "6G"
   image: ${RETINA_REGISTRY_PREFIX}/open5gs:${OPEN5GS_VERSION}_${RETINA_VERSION}
-  labels:
-    - ${ZMQ_HOSTLABEL_0}
+  labels: ["kubernetes.io/hostname=k8s-worker-uhd1"]

.gitlab/ci/release.yml

@@ -303,7 +303,9 @@ publish matlab:
     - job: publish main
     - job: builder version
   inherit:
-    variables: false
+    variables:
+      - PUBLIC_PUSH_TOKEN
+      - PUBLIC_REPO
   trigger:
     project: softwareradiosystems/srsgnb_matlab
     branch: master

.gitlab/ci/schedules.yml

@@ -43,7 +43,7 @@ Nightly Build Unit Tests Plugin:
       raw: false
 
 Nightly E2E Tests Plugin:
-  cron: "30 22 * * 1-5"
+  cron: "00 22 * * 1-5"
   cron_timezone: "Europe/Madrid"
   ref: refs/heads/dev
   variables:
@@ -127,7 +127,7 @@ Nightly Build Unit Tests OpenSource:
       raw: false
 
 Nightly E2E Tests OpenSource:
-  cron: "30 22 * * 0"
+  cron: "00 22 * * 0"
   cron_timezone: "Europe/Madrid"
   ref: refs/heads/dev
   variables:

apps/cu/cu.cpp

@@ -38,6 +38,7 @@
 #include "cu_appconfig.h"
 #include "cu_appconfig_validator.h"
 #include "cu_appconfig_yaml_writer.h"
+#include "srsran/cu_cp/cu_cp_operation_controller.h"
 #include "srsran/e1ap/gateways/e1_local_connector_factory.h"
 #include "srsran/e2/e2ap_config_translators.h"
 #include "srsran/f1ap/gateways/f1c_network_server_factory.h"
@@ -312,7 +313,7 @@ int main(int argc, char** argv)
   cu_f1u_gtpu_msg.gtpu_pcap                     = cu_up_dlt_pcaps.f1u.get();
   std::unique_ptr<gtpu_demux> cu_f1u_gtpu_demux = create_gtpu_demux(cu_f1u_gtpu_msg);
   // > Create UDP gateway(s).
-  std::vector<std::unique_ptr<gtpu_gateway>> cu_f1u_gws;
+  srs_cu_up::gtpu_gateway_maps f1u_gw_maps;
   for (const srs_cu::cu_f1u_socket_appconfig& sock_cfg : cu_cfg.f1u_cfg.f1u_socket_cfg) {
     udp_network_gateway_config cu_f1u_gw_config = {};
     cu_f1u_gw_config.bind_address               = sock_cfg.bind_addr;
@@ -321,12 +322,17 @@ int main(int argc, char** argv)
     cu_f1u_gw_config.reuse_addr                 = false;
     cu_f1u_gw_config.pool_occupancy_threshold   = sock_cfg.udp_config.pool_threshold;
     cu_f1u_gw_config.rx_max_mmsg                = sock_cfg.udp_config.rx_max_msgs;
+    cu_f1u_gw_config.dscp                       = sock_cfg.udp_config.dscp;
     std::unique_ptr<gtpu_gateway> cu_f1u_gw     = create_udp_gtpu_gateway(
         cu_f1u_gw_config, *epoll_broker, workers.cu_up_exec_mapper->io_ul_executor(), *workers.non_rt_low_prio_exec);
-    cu_f1u_gws.push_back(std::move(cu_f1u_gw));
+    if (not sock_cfg.five_qi.has_value()) {
+      f1u_gw_maps.default_gws.push_back(std::move(cu_f1u_gw));
+    } else {
+      f1u_gw_maps.five_qi_gws[sock_cfg.five_qi.value()].push_back(std::move(cu_f1u_gw));
+    }
   }
   std::unique_ptr<f1u_cu_up_udp_gateway> cu_f1u_conn =
-      srs_cu_up::create_split_f1u_gw({cu_f1u_gws, *cu_f1u_gtpu_demux, *cu_up_dlt_pcaps.f1u, GTPU_PORT});
+      srs_cu_up::create_split_f1u_gw({f1u_gw_maps, *cu_f1u_gtpu_demux, *cu_up_dlt_pcaps.f1u, GTPU_PORT});
 
   // Create E1AP local connector
   std::unique_ptr<e1_local_connector> e1_gw =
@@ -377,7 +383,7 @@ int main(int argc, char** argv)
 
   // start O-CU-CP
   cu_logger.info("Starting CU-CP...");
-  o_cucp_obj.get_cu_cp().start();
+  o_cucp_obj.get_operation_controller().start();
   cu_logger.info("CU-CP started successfully");
 
   // Check connection to AMF
@@ -409,7 +415,7 @@ int main(int argc, char** argv)
   // Connect the forwarder to the metrics manager.
   metrics_notifier_forwarder.connect(metrics_mngr);
 
-  o_cuup_unit.unit->get_power_controller().start();
+  o_cuup_unit.unit->get_operation_controller().start();
   {
     app_services::application_message_banners app_banner(app_name);
 
@@ -419,10 +425,10 @@ int main(int argc, char** argv)
   }
 
   // Stop O-CU-UP activity.
-  o_cuup_unit.unit->get_power_controller().stop();
+  o_cuup_unit.unit->get_operation_controller().stop();
 
   // Stop O-CU-CP activity.
-  o_cucp_obj.get_cu_cp().stop();
+  o_cucp_obj.get_operation_controller().stop();
 
   // Stop the timer source before stopping the workers.
   time_source.reset();

apps/cu/cu_appconfig.h

@@ -26,15 +26,17 @@
 #include "apps/services/logger/logger_appconfig.h"
 #include "apps/services/network/udp_cli11_schema.h"
 #include "apps/services/worker_manager/worker_manager_appconfig.h"
+#include "srsran/ran/qos/five_qi.h"
 #include <string>
 
 namespace srsran {
 namespace srs_cu {
 
 /// F1-U sockets configuration
 struct cu_f1u_socket_appconfig {
-  std::string   bind_addr = "127.0.10.1"; // Bind address used by the F1-U interface
-  udp_appconfig udp_config;
+  std::string              bind_addr = "127.0.10.1"; // Bind address used by the F1-U interface
+  std::optional<five_qi_t> five_qi;
+  udp_appconfig            udp_config;
 };
 
 /// F1-U configuration

apps/cu/cu_appconfig_cli11_schema.cpp

@@ -42,6 +42,7 @@ static void configure_cli11_f1u_socket_args(CLI::App& app, srs_cu::cu_f1u_socket
              f1u_cfg.bind_addr,
              "Default local IP address interfaces bind to, unless a specific bind address is specified")
       ->check(CLI::ValidIPV4);
+  add_option(app, "--five_qi", f1u_cfg.five_qi, "Assign this socket to a specific 5QI")->check(CLI::Range(0, 255));
 
   configure_cli11_with_udp_config_schema(app, f1u_cfg.udp_config);
 }

apps/du/du.cpp

@@ -37,7 +37,7 @@
 #include "du_appconfig_translators.h"
 #include "du_appconfig_validators.h"
 #include "du_appconfig_yaml_writer.h"
-#include "srsran/du/du_power_controller.h"
+#include "srsran/du/du_operation_controller.h"
 #include "srsran/e2/e2ap_config_translators.h"
 #include "srsran/e2/gateways/e2_connection_client.h"
 #include "srsran/e2/gateways/e2_network_client_factory.h"
@@ -333,7 +333,7 @@ int main(int argc, char** argv)
       *epoll_broker, *workers.non_rt_low_prio_exec, du_inst_and_cmds.commands);
 
   // Start processing.
-  du_inst.get_power_controller().start();
+  du_inst.get_operation_controller().start();
   {
     app_services::application_message_banners app_banner(app_name);
 
@@ -343,7 +343,7 @@ int main(int argc, char** argv)
   }
 
   // Stop DU activity.
-  du_inst.get_power_controller().stop();
+  du_inst.get_operation_controller().stop();
 
   du_logger.info("Closing PCAP files...");
   du_pcaps.reset();