paulmataruso/osmo-upf
1
0
Fork 0
mirror of https://gitea.osmocom.org/cellular-infrastructure/osmo-upf.git synced 2025-11-02 21:13:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

gtp_flood wip

Browse Source 
Change-Id: Ia9cf685081c91206198065619a4a6b30ed3deb7e
This commit is contained in:
Neels Janosch Hofmeyr
2024-09-13 05:18:12 +02:00
parent bb96fbb1c2
commit c73263f85f
1 changed files with 49 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
src/osmo-pfcp-tool/gtp_flood.c
View File

@@ -77,6 +77,11 @@ struct gtp_flood_worker {
struct io_uring ring;
pthread_t worker;
uint64_t tx_packets;
uint64_t tx_bytes;
uint64_t rx_packets;
uint64_t rx_bytes;
};
struct gtp_flood_flow {
@@ -310,10 +315,11 @@ static void *gtp_flood_tx_worker_thread(void *_worker)
osmo_ctx_init(__func__);
gtp_flood->tx_workers_started++;
int worker_id = gtp_flood->tx_workers_started++;
gtp_flood->tx_workers_running++;
LOGP(DLGLOBAL, LOGL_INFO, "gtp flood tx worker starting (%u started, %u running)\n",
LOGP(DLGLOBAL, LOGL_INFO, "gtp flood tx worker %d starting (%u started, %u running)\n",
worker_id,
gtp_flood->tx_workers_started,
gtp_flood->tx_workers_running);
@@ -388,14 +394,11 @@ static void *gtp_flood_tx_worker_thread(void *_worker)
num_submitted_total += num_submitted;
if (num_pending > 0)
num_pending_total += num_pending;
//printf("\nnum_submitted=%5d/%5d num_pending=%5d/%5d tx_flows_ended=%5d/%5d\n",
// num_submitted, num_submitted_total, num_pending, num_pending_total, tx_flows_ended, tx_flows_count);
}
printf("\nnum_submitted=%d,%d tx_flows_ended=%d/%d\n",
num_submitted_total, num_pending_total, tx_flows_ended, tx_flows_count);
gtp_flood->tx_workers_running--;
LOGP(DLGLOBAL, LOGL_INFO, "gtp flood tx worker done (%u started, %u running)\n",
LOGP(DLGLOBAL, LOGL_INFO, "gtp flood tx worker %d done (%u started, %u running)\n",
worker_id,
gtp_flood->tx_workers_started,
gtp_flood->tx_workers_running);
return NULL;
@@ -424,6 +427,8 @@ void rx_completion(struct gtp_flood_worker *worker, struct io_uring_cqe *cqe)
if (len > 0) {
flow->received_udp_packets++;
flow->received_udp_bytes += len;
worker->rx_packets++;
worker->rx_bytes += len;
}
io_uring_cqe_seen(&worker->ring, cqe);
@@ -438,7 +443,7 @@ static void *gtp_flood_rx_worker_thread(void *_worker)
osmo_ctx_init(__func__);
gtp_flood->rx_workers_started++;
int worker_id = gtp_flood->rx_workers_started++;
gtp_flood->rx_workers_running++;
LOGP(DLGLOBAL, LOGL_INFO, "gtp rx worker starting (%u started, %u running)\n",
@@ -471,6 +476,42 @@ static void *gtp_flood_rx_worker_thread(void *_worker)
completed++;
}
/* periodically log rx stats */
if (1) {
static time_t last_info_log = 0;
time_t now;
time_t diff_time;
now = time(NULL);
if (!last_info_log)
diff_time = 1;
else
diff_time = now - last_info_log;
/* the resolution is in seconds, output stats once per second. */
if (diff_time > 0) {
static uint64_t last_total_packets = 0;
static uint64_t last_total_bytes = 0;
uint64_t diff_packets;
uint64_t diff_bytes;
last_info_log = now;
diff_packets = worker->rx_packets - last_total_packets;
diff_bytes = worker->rx_bytes - last_total_bytes;
last_total_packets = worker->rx_packets;
last_total_bytes = worker->rx_bytes;
if (diff_packets) {
LOGP(DLGLOBAL, LOGL_INFO,
"%d: rx %"PRIu64" packets %"PRIu64"Mb (%"PRIu64"Mb/s)\n",
worker_id,
worker->rx_packets, worker->rx_bytes / (1024*1024),
(diff_bytes / diff_time) / (1024*1024));
/* mark that something happened to not enter the wait below */
completed++;
}
}
}
/* Nothing happened in this loop, wait for the next event */
if (!submitted && !completed) {
if (io_uring_wait_cqe_timeout(&worker->ring, &cqe, &ts_1s) == 0) {