yigid/openairinterface5g
1
0
Fork 0
mirror of https://gitlab.eurecom.fr/oai/openairinterface5g.git synced 2026-07-13 04:30:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix packet rx window wrap-around

Browse Source 
Add histogram for rx packets
This commit is contained in:
Bartosz Podrygajlo
2026-05-20 10:59:36 +02:00
parent 1720267638
commit 8890ec7387
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
radio/fhi_72/oaioran_ru.c
View File

@@ -109,6 +109,7 @@ typedef struct {
_Atomic(uint64_t) up_late;
_Atomic(uint64_t) up_early;
_Atomic(uint64_t) up_malformed;
_Atomic(uint64_t) up_arrival_histogram[128];
} packet_processor_context_t;
static packet_processor_context_t packet_processor_context;
@@ -245,6 +246,19 @@ static void print_statistics(packet_processor_context_t *context)
LOG_I(HW, "RU: packets received %lu\n", context->up_received);
LOG_I(HW, "RU: packets processed %lu\n", context->up_processed);
LOG_I(HW, "RU: packets dropped %lu\n", context->up_dropped);
bool printed_header = false;
for (int i = 0; i < 128; i++) {
uint64_t count = context->up_arrival_histogram[i];
if (count > 0) {
if (!printed_header) {
LOG_I(HW, "RU: packet arrival histogram (diff in symbols):\n");
printed_header = true;
}
LOG_I(HW, " %3d symbols early: %lu\n", i, count);
context->up_arrival_histogram[i] = 0;
}
}
}
typedef struct {
@@ -488,8 +502,12 @@ int process_ru_uplane(struct rte_mbuf *pkt,
int max_sym = NR_SYMBOLS_PER_SLOT * NR_NUMBER_OF_SUBFRAMES_PER_FRAME * slots_per_subframe;
if (diff < -max_sym / 2) {
diff += max_sym;
} else if (diff > max_sym / 2) {
diff -= max_sym;
}
packet_processor_context.up_arrival_histogram[min(max(diff, 0), 127)]++;
int slot_duration_uS = 1000 / (1 << mu);
int symbol_duration_uS = slot_duration_uS / NR_SYMBOLS_PER_SLOT;
int rx_window_start = fh_cfg->T2a_max_up / symbol_duration_uS;