Skip to content

Commit

Permalink
validation: pktio: separate and reduce packet and rx counts
Browse files Browse the repository at this point in the history 
Replace the magic number 1000 used for test packet counts and rx attempt
counts with two macros. Lower the test packet count to 100 since the used
pool configuration did not allow allocating more than 128 packets anyway.
Make the rx attempt count twice the test packet count to leave room for
a few possible non-test packets and to allow almost 100 ms for the first
sent test packet to come back.

The previous code had a higher rx attempt count than the test packet count
but that was apparently accidental due to the pool config limiting the test
packet count. The 1000 used for the rx attempt count was higher than
necessary and slowed down the test slightly.

Signed-off-by: Janne Peltonen <janne.peltonen@nokia.com>
Reviewed-by: Jere Leppänen <jere.leppanen@nokia.com>
  • Loading branch information
@JannePeltonen @MatiasElo
JannePeltonen authored and MatiasElo committed Nov 7, 2024
1 parent 8d6871a commit 77b456b
Showing 1 changed file with 22 additions and 20 deletions.
42 changes: 22 additions & 20 deletions test/validation/api/pktio/pktio.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,9 @@
#define PKT_LEN_MAX (PKT_BUF_SIZE - ODPH_ETHHDR_LEN - \
ODPH_IPV4HDR_LEN - ODPH_UDPHDR_LEN)

#define NUM_TEST_PKTS 100
#define NUM_RX_ATTEMPTS 200

#define USE_MTU 0
#define MAX_NUM_IFACES 2
#define TEST_SEQ_INVALID ((uint32_t)~0)
Expand Down Expand Up @@ -2350,8 +2353,8 @@ static void pktio_test_statistics_counters(void)
ODP_PKTIO_INVALID, ODP_PKTIO_INVALID
};
odp_packet_t pkt;
odp_packet_t tx_pkt[1000];
uint32_t pkt_seq[1000];
odp_packet_t tx_pkt[NUM_TEST_PKTS];
uint32_t pkt_seq[NUM_TEST_PKTS];
odp_event_t ev;
int i, pkts, tx_pkts, ret, alloc = 0;
odp_pktout_queue_t pktout;
Expand Down Expand Up @@ -2381,7 +2384,7 @@ static void pktio_test_statistics_counters(void)
CU_ASSERT(ret == 0);
}

alloc = create_packets(tx_pkt, pkt_seq, 1000, pktio_tx, pktio_rx);
alloc = create_packets(tx_pkt, pkt_seq, NUM_TEST_PKTS, pktio_tx, pktio_rx);

ret = odp_pktio_stats_reset(pktio_tx);
CU_ASSERT(ret == 0);
Expand All @@ -2402,7 +2405,7 @@ static void pktio_test_statistics_counters(void)
tx_pkts = pkts;

/* get */
for (i = 0, pkts = 0; i < 1000 && pkts != tx_pkts; i++) {
for (i = 0, pkts = 0; i < NUM_RX_ATTEMPTS && pkts != tx_pkts; i++) {
ev = odp_schedule(NULL, wait);
if (ev != ODP_EVENT_INVALID) {
if (odp_event_type(ev) == ODP_EVENT_PACKET) {
Expand Down Expand Up @@ -2640,8 +2643,8 @@ static void pktio_test_queue_statistics_counters(void)
odp_pktio_t pktio[MAX_NUM_IFACES] = {
ODP_PKTIO_INVALID, ODP_PKTIO_INVALID
};
odp_packet_t tx_pkt[1000];
uint32_t pkt_seq[1000];
odp_packet_t tx_pkt[NUM_TEST_PKTS];
uint32_t pkt_seq[NUM_TEST_PKTS];
int i, pkts, tx_pkts, ret, alloc = 0;
odp_pktout_queue_t pktout;
odp_pktin_queue_t pktin;
Expand Down Expand Up @@ -2669,7 +2672,7 @@ static void pktio_test_queue_statistics_counters(void)
if (num_ifaces > 1)
CU_ASSERT_FATAL(odp_pktio_start(pktio_rx) == 0);

alloc = create_packets(tx_pkt, pkt_seq, 1000, pktio_tx, pktio_rx);
alloc = create_packets(tx_pkt, pkt_seq, NUM_TEST_PKTS, pktio_tx, pktio_rx);

CU_ASSERT(odp_pktio_stats_reset(pktio_tx) == 0);
if (num_ifaces > 1)
Expand All @@ -2685,7 +2688,7 @@ static void pktio_test_queue_statistics_counters(void)
}
tx_pkts = pkts;

for (i = 0, pkts = 0; i < 1000 && pkts != tx_pkts; i++) {
for (i = 0, pkts = 0; i < NUM_RX_ATTEMPTS && pkts != tx_pkts; i++) {
odp_packet_t pkt;

if (odp_pktin_recv_tmo(pktin, &pkt, 1, wait) != 1)
Expand Down Expand Up @@ -2763,8 +2766,8 @@ static void pktio_test_event_queue_statistics_counters(void)
ODP_PKTIO_INVALID, ODP_PKTIO_INVALID
};
odp_packet_t pkt;
odp_packet_t tx_pkt[1000];
uint32_t pkt_seq[1000];
odp_packet_t tx_pkt[NUM_TEST_PKTS];
uint32_t pkt_seq[NUM_TEST_PKTS];
odp_event_t ev;
int i, pkts, tx_pkts;
odp_queue_t pktout;
Expand Down Expand Up @@ -2793,7 +2796,7 @@ static void pktio_test_event_queue_statistics_counters(void)
if (num_ifaces > 1)
CU_ASSERT_FATAL(odp_pktio_start(pktio_rx) == 0);

tx_pkts = create_packets(tx_pkt, pkt_seq, 1000, pktio_tx, pktio_rx);
tx_pkts = create_packets(tx_pkt, pkt_seq, NUM_TEST_PKTS, pktio_tx, pktio_rx);

CU_ASSERT(odp_pktio_stats_reset(pktio_tx) == 0);
if (num_ifaces > 1)
Expand All @@ -2802,7 +2805,7 @@ static void pktio_test_event_queue_statistics_counters(void)
CU_ASSERT_FATAL(send_packet_events(pktout, tx_pkt, tx_pkts) == 0);

/* Receive */
for (i = 0, pkts = 0; i < 1000 && pkts != tx_pkts; i++) {
for (i = 0, pkts = 0; i < NUM_RX_ATTEMPTS && pkts != tx_pkts; i++) {
ev = odp_schedule(NULL, wait);
if (ev != ODP_EVENT_INVALID) {
if (odp_event_type(ev) == ODP_EVENT_PACKET) {
Expand Down Expand Up @@ -3094,8 +3097,8 @@ static void pktio_test_start_stop(void)
odp_pktio_t pktio[MAX_NUM_IFACES];
odp_pktio_t pktio_in;
odp_packet_t pkt;
odp_packet_t tx_pkt[1000];
uint32_t pkt_seq[1000];
odp_packet_t tx_pkt[NUM_TEST_PKTS];
uint32_t pkt_seq[NUM_TEST_PKTS];
odp_event_t ev;
int i, pkts, ret, alloc = 0;
odp_pktout_queue_t pktout;
Expand Down Expand Up @@ -3125,7 +3128,7 @@ static void pktio_test_start_stop(void)

/* Test Rx on a stopped interface. Only works if there are 2 */
if (num_ifaces > 1) {
alloc = create_packets(tx_pkt, pkt_seq, 1000, pktio[0],
alloc = create_packets(tx_pkt, pkt_seq, NUM_TEST_PKTS, pktio[0],
pktio[1]);

for (pkts = 0; pkts != alloc; ) {
Expand All @@ -3138,7 +3141,7 @@ static void pktio_test_start_stop(void)
pkts += ret;
}
/* check that packets did not arrive */
for (i = 0, pkts = 0; i < 1000; i++) {
for (i = 0, pkts = 0; i < NUM_RX_ATTEMPTS; i++) {
ev = odp_schedule(NULL, wait);
if (ev == ODP_EVENT_INVALID)
continue;
Expand All @@ -3159,9 +3162,8 @@ static void pktio_test_start_stop(void)
CU_ASSERT(ret == 0);

_pktio_wait_linkup(pktio[1]);

/* flush packets with magic number in pipes */
for (i = 0; i < 1000; i++) {
for (i = 0; i < NUM_RX_ATTEMPTS; i++) {
ev = odp_schedule(NULL, wait);
if (ev != ODP_EVENT_INVALID)
odp_event_free(ev);
Expand All @@ -3173,7 +3175,7 @@ static void pktio_test_start_stop(void)
else
pktio_in = pktio[0];

alloc = create_packets(tx_pkt, pkt_seq, 1000, pktio[0], pktio_in);
alloc = create_packets(tx_pkt, pkt_seq, NUM_TEST_PKTS, pktio[0], pktio_in);

/* send */
for (pkts = 0; pkts != alloc; ) {
Expand All @@ -3186,7 +3188,7 @@ static void pktio_test_start_stop(void)
}

/* get */
for (i = 0, pkts = 0; i < 1000; i++) {
for (i = 0, pkts = 0; i < NUM_RX_ATTEMPTS; i++) {
ev = odp_schedule(NULL, wait);
if (ev != ODP_EVENT_INVALID) {
if (odp_event_type(ev) == ODP_EVENT_PACKET) {
Expand Down

0 comments on commit 77b456b

Please sign in to comment.