Update main

Author: codebot

.gitlab/ci/e2e.yml

@@ -110,7 +110,7 @@ e2e request and config validation:
 
 .e2e-run:
   resource_group: e2e-${GROUP}
-  timeout: 2h
+  timeout: 3 hours
   image:
     name: ${RETINA_REGISTRY_PREFIX}/launcher:${RETINA_VERSION}
     entrypoint: ["/bin/sh", "-c"]
@@ -178,11 +178,32 @@ e2e request and config validation:
       find . -iname "test_metrics.csv" -exec \
         influx write --host $INFLUXDB_URL --token $INFLUXDB_TOKEN --org $INFLUXDB_ORG \
         --bucket ci --file {} \;
+    # Artifact size
+    - echo -e "\e[0Ksection_start:`date +%s`:e2e_folder_section[collapsed=true]\r\e[0KLog folder's tree"
+    - |
+      print_tree() {
+        local dir="$1"
+        local prefix="$2"
+
+        # List directories first
+        find "$dir" -mindepth 1 -maxdepth 1 -type d | while read -r subdir; do
+          local size=$(du -sh "$subdir" | awk '{print $1}')
+          echo "${prefix}├── $(basename "$subdir") [$size]"
+          print_tree "$subdir" "$prefix│   "
+        done
+
+        # List files afterwards
+        find "$dir" -mindepth 1 -maxdepth 1 -type f | while read -r file; do
+          local size=$(du -sh "$file" | awk '{print $1}')
+          echo "${prefix}├── $(basename "$file") [$size]"
+        done
+      }
+      print_tree "tests/e2e/log/" ""
+    - echo -e "\e[0Ksection_end:`date +%s`:e2e_folder_section\r\e[0K"
     - |
       echo "*******************************************************************************************************************************"
       echo "Test report ---> https://softwareradiosystems.gitlab.io/-/$CI_PROJECT_NAME/-/jobs/$CI_JOB_ID/artifacts/tests/e2e/log//report.html"
       echo "*******************************************************************************************************************************"
-    - du -hs tests/e2e/log/
   needs:
     - *retina-needs
 

.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.51.7
+RETINA_VERSION=0.51.8
 UBUNTU_VERSION=24.04
 AMARISOFT_VERSION=2023-09-08
 SRSUE_VERSION=23.11

.gitlab/ci/e2e/retina_request_viavi.yml

@@ -21,8 +21,8 @@
       requests: 4Gi
       limits: 4Gi
     ephemeral-storage:
-      requests: "20G"
-      limits: "20G"
+      requests: "50G"
+      limits: "50G"
   taints: ["purpose=ci-amd64-avx512-onprem"]
   resources:
     - type: emulator

apps/cu/cu.cpp

@@ -71,6 +71,7 @@
 
 #include "apps/services/application_message_banners.h"
 #include "apps/services/application_tracer.h"
+#include "apps/services/buffer_pool/buffer_pool_manager.h"
 #include "apps/services/stdin_command_dispatcher.h"
 #include "apps/units/cu_cp/cu_cp_unit_config_yaml_writer.h"
 #include "apps/units/cu_up/cu_up_unit_config_yaml_writer.h"
@@ -253,7 +254,7 @@ int main(int argc, char** argv)
   // TODO
 
   // Setup size of byte buffer pool.
-  init_byte_buffer_segment_pool(cu_cfg.buffer_pool_config.nof_segments, cu_cfg.buffer_pool_config.segment_size);
+  app_services::buffer_pool_manager buffer_pool_service(cu_cfg.buffer_pool_config);
 
   // Log CPU architecture.
   // TODO

apps/cu/cu_appconfig.h

@@ -23,6 +23,7 @@
 #pragma once
 
 #include "apps/gnb/gnb_appconfig.h"
+#include "apps/services/buffer_pool/buffer_pool_appconfig.h"
 #include "apps/services/logger/logger_appconfig.h"
 #include <string>
 

apps/cu/cu_appconfig_cli11_schema.cpp

@@ -21,6 +21,7 @@
  */
 
 #include "cu_appconfig_cli11_schema.h"
+#include "apps/services/buffer_pool/buffer_pool_appconfig_cli11_schema.h"
 #include "apps/services/logger/logger_appconfig_cli11_schema.h"
 #include "cu_appconfig.h"
 #include "srsran/support/cli11_utils.h"
@@ -43,19 +44,14 @@ static void configure_cli11_nru_args(CLI::App& app, srs_cu::cu_nru_appconfig& nr
   add_option(app, "--udp_max_rx_msgs", nru_cfg.udp_rx_max_msgs, "Maximum amount of messages RX in a single syscall");
 }
 
-static void configure_cli11_buffer_pool_args(CLI::App& app, buffer_pool_appconfig& config)
-{
-  app.add_option("--nof_segments", config.nof_segments, "Number of segments allocated by the buffer pool")
-      ->capture_default_str();
-  app.add_option("--segment_size", config.segment_size, "Size of each buffer pool segment in bytes")
-      ->capture_default_str();
-}
-
 void srsran::configure_cli11_with_cu_appconfig_schema(CLI::App& app, cu_appconfig& cu_cfg)
 {
   // Logging section.
   configure_cli11_with_logger_appconfig_schema(app, cu_cfg.log_cfg);
 
+  // Buffer pool section.
+  configure_cli11_with_buffer_pool_appconfig_schema(app, cu_cfg.buffer_pool_config);
+
   // F1AP section.
   CLI::App* cu_cp_subcmd = add_subcommand(app, "cu_cp", "CU-UP parameters")->configurable();
   CLI::App* f1ap_subcmd  = add_subcommand(*cu_cp_subcmd, "f1ap", "F1AP parameters")->configurable();
@@ -65,8 +61,4 @@ void srsran::configure_cli11_with_cu_appconfig_schema(CLI::App& app, cu_appconfi
   CLI::App* cu_up_subcmd = add_subcommand(app, "cu_up", "CU-UP parameters")->configurable();
   CLI::App* nru_subcmd   = add_subcommand(*cu_up_subcmd, "nru", "NR-U parameters")->configurable();
   configure_cli11_nru_args(*nru_subcmd, cu_cfg.nru_cfg);
-
-  // Buffer pool section.
-  CLI::App* buffer_pool_subcmd = app.add_subcommand("buffer_pool", "Buffer pool configuration")->configurable();
-  configure_cli11_buffer_pool_args(*buffer_pool_subcmd, cu_cfg.buffer_pool_config);
 }

apps/du/du.cpp

@@ -61,6 +61,7 @@
 
 #include "apps/services/application_message_banners.h"
 #include "apps/services/application_tracer.h"
+#include "apps/services/buffer_pool/buffer_pool_manager.h"
 #include "apps/services/core_isolation_manager.h"
 #include "apps/services/metrics_plotter_json.h"
 #include "apps/services/metrics_plotter_stdout.h"
@@ -240,7 +241,7 @@ int main(int argc, char** argv)
 #endif
 
   // Setup size of byte buffer pool.
-  init_byte_buffer_segment_pool(du_cfg.buffer_pool_config.nof_segments, du_cfg.buffer_pool_config.segment_size);
+  app_services::buffer_pool_manager buffer_pool_service(du_cfg.buffer_pool_config);
 
   // Log CPU architecture.
   cpu_architecture_info::get().print_cpu_info(du_logger);

apps/du/du_appconfig.h

@@ -23,9 +23,9 @@
 #pragma once
 
 #include "../gnb/gnb_appconfig.h" // TODO: Remove
+#include "apps/services/buffer_pool/buffer_pool_appconfig.h"
 #include "apps/services/logger/logger_appconfig.h"
 #include "apps/services/os_sched_affinity_manager.h"
-#include "srsran/adt/byte_buffer.h"
 #include "srsran/support/executors/unique_thread.h"
 #include <optional>
 

apps/du/du_appconfig_cli11_schema.cpp

@@ -21,8 +21,10 @@
  */
 
 #include "du_appconfig_cli11_schema.h"
+#include "apps/services/buffer_pool/buffer_pool_appconfig_cli11_schema.h"
 #include "apps/services/logger/logger_appconfig_cli11_schema.h"
 #include "du_appconfig.h"
+#include "srsran/adt/interval.h"
 #include "srsran/support/cli11_utils.h"
 
 using namespace srsran;
@@ -79,14 +81,6 @@ static void configure_cli11_e2_args(CLI::App& app, e2_appconfig& e2_params)
   add_option(app, "--e2sm_rc_enabled", e2_params.e2sm_rc_enabled, "Enable RC service module")->capture_default_str();
 }
 
-static void configure_cli11_buffer_pool_args(CLI::App& app, buffer_pool_appconfig& config)
-{
-  app.add_option("--nof_segments", config.nof_segments, "Number of segments allocated by the buffer pool")
-      ->capture_default_str();
-  app.add_option("--segment_size", config.segment_size, "Size of each buffer pool segment in bytes")
-      ->capture_default_str();
-}
-
 static error_type<std::string> is_valid_cpu_index(unsigned cpu_idx)
 {
   std::string error_message = fmt::format("Invalid CPU core selected '{}'. Valid CPU ids: {}",
@@ -268,6 +262,9 @@ void srsran::configure_cli11_with_du_appconfig_schema(CLI::App& app, du_appconfi
   // Loggers section.
   configure_cli11_with_logger_appconfig_schema(app, du_cfg.log_cfg);
 
+  // Buffer pool section.
+  configure_cli11_with_buffer_pool_appconfig_schema(app, du_cfg.buffer_pool_config);
+
   // F1-C section.
   CLI::App* f1ap_subcmd = app.add_subcommand("f1ap", "F1AP interface configuration")->configurable();
   configure_cli11_f1ap_args(*f1ap_subcmd, du_cfg.f1ap_cfg);
@@ -284,10 +281,6 @@ void srsran::configure_cli11_with_du_appconfig_schema(CLI::App& app, du_appconfi
   CLI::App* e2_subcmd = add_subcommand(app, "e2", "E2 parameters")->configurable();
   configure_cli11_e2_args(*e2_subcmd, du_cfg.e2_cfg);
 
-  // Buffer pool section.
-  CLI::App* buffer_pool_subcmd = app.add_subcommand("buffer_pool", "Buffer pool configuration")->configurable();
-  configure_cli11_buffer_pool_args(*buffer_pool_subcmd, du_cfg.buffer_pool_config);
-
   // Expert section.
   CLI::App* expert_subcmd = app.add_subcommand("expert_execution", "Expert execution configuration")->configurable();
   configure_cli11_expert_execution_args(*expert_subcmd, du_cfg.expert_execution_cfg);

apps/gnb/gnb.cpp

@@ -72,6 +72,7 @@
 #include <atomic>
 
 #include "apps/services/application_message_banners.h"
+#include "apps/services/buffer_pool/buffer_pool_manager.h"
 #include "apps/services/core_isolation_manager.h"
 #include "apps/services/metrics_plotter_json.h"
 #include "apps/services/metrics_plotter_stdout.h"
@@ -295,8 +296,8 @@ int main(int argc, char** argv)
   }
 #endif
 
-  // Setup size of byte buffer pool.
-  init_byte_buffer_segment_pool(gnb_cfg.buffer_pool_config.nof_segments, gnb_cfg.buffer_pool_config.segment_size);
+  // Buffer pool service.
+  app_services::buffer_pool_manager buffer_pool_service(gnb_cfg.buffer_pool_config);
 
   // Log CPU architecture.
   cpu_architecture_info::get().print_cpu_info(gnb_logger);