v0.2.0 release

* Implement TX_TOTAL counter for uplink U-plane packets
* Address code review feedback: add null check and clean up spacing
* Fix uninitiated UL U-plane packet issue
* Resolve merge conflicts tx_total and uplink cplane handling
* docs: update known issues

---------

Co-authored-by: khooi8913 <17496254+khooi8913@users.noreply.github.com>
Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>

Author: khooi8913

apps/examples/ofh/ru_emulator.cpp

@@ -545,7 +545,7 @@ class ru_emulator : public frame_notifier
 
     low_cfg.logger->set_level(cfg.phy_log_level);
 
-    ofh_transmitter = std::make_shared<ofh_transmitter_impl>(logger, cfg.timing_params, transceiver.get_transmitter(), ul_frame_pool);
+    ofh_transmitter = std::make_shared<ofh_transmitter_impl>(logger, cfg.timing_params, transceiver.get_transmitter(), ul_frame_pool, ul_context_repo, prach_cp_repo, &tx_total_counter);
 
     low_cfg.error_notifier = &error_adapter;
     low_cfg.metric_notifier = &metrics_adapter;

apps/examples/ofh/ru_ofh_transmitter.cpp

@@ -2,6 +2,7 @@
 #include "srsran/adt/static_vector.h"
 #include "srsran/adt/gps_clock.h"
 #include "srsran/instrumentation/traces/ofh_traces.h"
+#include "./support/uplink_context_repository.h"
 
 using namespace srsran;
 using namespace ofh;
@@ -17,14 +18,24 @@ static slot_symbol_point calculate_ofh_slot_symbol_point(slot_symbol_point symbo
   return {ofh_slot, symbol_point.get_symbol_index(), symbol_point.get_nof_symbols()};
 }
 
-ofh_transmitter_impl::ofh_transmitter_impl(srslog::basic_logger&                  logger_,
-                                                   const ru_window_timing_parameters&     timing_params_,
-                                                   std::shared_ptr<ether::gateway>        gw,
-                                                   std::shared_ptr<ether::eth_frame_pool> frame_pool) :
-  logger(logger_), pool(std::move(frame_pool)), gateway(gw), timing_params(timing_params_)
+ofh_transmitter_impl::ofh_transmitter_impl(srslog::basic_logger&                             logger_,
+                                           const ru_window_timing_parameters&                timing_params_,
+                                           std::shared_ptr<ether::gateway>                   gw,
+                                           std::shared_ptr<ether::eth_frame_pool>            frame_pool,
+                                           std::shared_ptr<uplink_cplane_context_repository> ul_context_repo_,
+                                           std::shared_ptr<uplink_cplane_context_repository> prach_context_repo_,
+                                          ru_emu_stats::kpi_counter*                         tx_counter_) :
+  logger(logger_),
+  pool(std::move(frame_pool)),
+  gateway(gw),
+  timing_params(timing_params_),
+  ul_context_repo(std::move(ul_context_repo_)),
+  prach_context_repo(std::move(prach_context_repo_)),
+  tx_counter(tx_counter_)
 {
   srsran_assert(gateway, "Invalid Ethernet gateway");
   srsran_assert(pool, "Invalid frame pool");
+  srsran_assert(tx_counter, "Invalid TX counter");
 }
 
 void ofh_transmitter_impl::transmit_frame_burst(span<span<const uint8_t>> frame_burst)
@@ -34,6 +45,8 @@ void ofh_transmitter_impl::transmit_frame_burst(span<span<const uint8_t>> frame_
   }
 
   gateway->send(frame_burst);
+  // Increment TX_TOTAL counter for uplink U-plane packets.
+  tx_counter->increment(frame_burst.size());
   logger.debug("Sending an Ethernet frame burst of size '{}'", frame_burst.size());
 }
 
@@ -95,5 +108,28 @@ void ofh_transmitter_impl::on_new_symbol(slot_symbol_point symbol_point)
   pool->clear_sent_frame_buffers(interval_up);
   pool->clear_sent_frame_buffers(interval_up_prach);
 
+  // Clear uplink C-Plane contexts for the transmitted slots to prevent stale contexts
+  // from generating new frames after DU stops.
+  if (ul_context_repo) {
+    slot_point start_slot = interval_up.start.get_slot();
+    slot_point end_slot   = interval_up.end.get_slot();
+    
+    // Clear contexts for all slots in the interval
+    for (slot_point slot = start_slot; slot <= end_slot; ++slot) {
+      ul_context_repo->clear_slot(slot);
+    }
+  }
+
+  // Clear PRACH C-Plane contexts for the transmitted slots.
+  if (prach_context_repo) {
+    slot_point start_slot = interval_up_prach.start.get_slot();
+    slot_point end_slot   = interval_up_prach.end.get_slot();
+    
+    // Clear contexts for all slots in the interval
+    for (slot_point slot = start_slot; slot <= end_slot; ++slot) {
+      prach_context_repo->clear_slot(slot);
+    }
+  }
+
   ofh_tracer << trace_event("ofh_ofh_transmitter", tp);
 }

apps/examples/ofh/ru_ofh_transmitter.h

@@ -1,6 +1,8 @@
 #pragma once
 
 #include "./helpers/timing_window_params.h"
+#include "./support/uplink_context_repository.h"
+#include "./helpers.h"
 #include "srsran/ofh/ethernet/ethernet_frame_pool.h"
 #include "srsran/ofh/ethernet/ethernet_gateway.h"
 #include "srsran/ofh/timing/ofh_ota_symbol_boundary_notifier.h"
@@ -24,12 +26,21 @@ class ofh_transmitter_impl : public ota_symbol_boundary_notifier
   std::shared_ptr<ether::gateway> gateway;
   /// Internal representation of timing parameters.
   const ru_window_timing_parameters timing_params;
+  /// Uplink context repository (for clearing contexts after transmission).
+  std::shared_ptr<uplink_cplane_context_repository> ul_context_repo;
+  /// PRACH context repository (for clearing contexts after transmission).
+  std::shared_ptr<uplink_cplane_context_repository> prach_context_repo;
+  /// TX total counter for uplink U-plane packets.
+  ru_emu_stats::kpi_counter* tx_counter;
 
 public:
-  ofh_transmitter_impl(srslog::basic_logger&                  logger_,
-                           const ru_window_timing_parameters&     timing_params_,
-                           std::shared_ptr<ether::gateway>        gw,
-                           std::shared_ptr<ether::eth_frame_pool> frame_pool);
+  ofh_transmitter_impl(srslog::basic_logger&                                 logger_,
+                       const ru_window_timing_parameters&                    timing_params_,
+                       std::shared_ptr<ether::gateway>                       gw,
+                       std::shared_ptr<ether::eth_frame_pool>                frame_pool,
+                       std::shared_ptr<uplink_cplane_context_repository>     ul_context_repo_,
+                       std::shared_ptr<uplink_cplane_context_repository>     prach_context_repo_,
+                       ru_emu_stats::kpi_counter*                            tx_counter_);
 
   // See interface for documentation.
   void on_new_symbol(slot_symbol_point symbol_point) override;

apps/examples/ofh/support/uplink_context_repository.h

@@ -27,6 +27,7 @@
 #include "srsran/ofh/ofh_constants.h"
 #include "srsran/ofh/serdes/ofh_cplane_message_properties.h"
 #include "srsran/ran/slot_pdu_capacity_constants.h"
+#include "srsran/srslog/srslog.h"
 #include <array>
 #include <mutex>
 #include <vector>
@@ -118,6 +119,26 @@ class uplink_cplane_context_repository
 
     return make_unexpected(default_error_t{});
   }
+
+  /// Clears the context for the given slot and eAxC by resetting the number of symbols to 0.
+  void clear(slot_point slot, unsigned eaxc)
+  {
+    std::lock_guard<std::mutex> lock(mutex);
+    ul_cplane_context& ctx = entry(slot, eaxc);
+    // Clear by setting nof_symbols to 0, which will cause future get() calls to fail
+    ctx.nof_symbols = 0;
+  }
+
+  /// Clears all contexts for the given slot across all eAxCs.
+  void clear_slot(slot_point slot)
+  {
+    std::lock_guard<std::mutex> lock(mutex);
+    unsigned index = calculate_repository_index(slot, repo.size());
+    // Reset all eAxC entries for this slot
+    for (auto& ctx : repo[index]) {
+      ctx.nof_symbols = 0;
+    }
+  }
 };
 
 } // namespace ofh

proto-ru/KNOWN_ISSUES.md

@@ -2,13 +2,6 @@
 
 This document lists known issues and limitations in ProtO-RU.
 
-1. Realtime KPI monitoring 
-    - TX_TOTAL counter is currently not (yet) implemented.
-
-1. Uninitiated uplink U-plane packets
-    - In some cases, ProtO-RU may be sending uplink U-plane packets even if there are no incoming C-plane packets from the DU/gNB after ProtO-RU is running for a while.
-    - Note that this does not affect the normal operation of ProtO-RU, and this issue is currently under investigation.
-
 1. T2a/Ta3 value validation
     - Currently, ProtO-RU does not validate the T2a/Ta3 values configured in the RU configuration file.
     - Users must ensure that the T2a/Ta3 values are sufficiently large to provide enough time for the RU to process and transmit the data within the required deadlines.