| Message ID | 1450440477-7017-1-git-send-email-stuart.haslam@linaro.org |
|---|---|
| State | New |
| Headers | show |
On Fri, Dec 18, 2015 at 12:07:57PM +0000, Stuart Haslam wrote: > Modify the tests that currently transmit packets in batches to also > receive packets in batches. This adds coverage of odp_queue_deq_multi() > and odp_schedule_multi() specifically against a packet input queue, > as this doesn't get tested anywhere else in the validation suite. > > Signed-off-by: Stuart Haslam <stuart.haslam@linaro.org> Ping - needs review.. > --- > Changes in v3 - test odp_queue_[enq|deq]_multi() and odp_schedule_multi() > APIs with batch length of 1. > > Changes in v2 - rebased and picked up new time API > > test/validation/pktio/pktio.c | 185 ++++++++++++++++++++++-------------------- > 1 file changed, 97 insertions(+), 88 deletions(-) > > diff --git a/test/validation/pktio/pktio.c b/test/validation/pktio/pktio.c > index 28bfd30..05ddd68 100644 > --- a/test/validation/pktio/pktio.c > +++ b/test/validation/pktio/pktio.c > @@ -58,8 +58,13 @@ typedef struct ODP_PACKED { > typedef enum { > PKT_POOL_UNSEGMENTED, > PKT_POOL_SEGMENTED, > -} pkt_segmented_e > -; > +} pkt_segmented_e; > + > +typedef enum { > + TXRX_MODE_SINGLE, > + TXRX_MODE_MULTI > +} txrx_mode_e; > + > /** size of transmitted packets */ > static uint32_t packet_len = PKT_LEN_NORMAL; > > @@ -142,7 +147,7 @@ static uint32_t pktio_pkt_seq(odp_packet_t pkt) > pkt_tail_t tail; > > if (pkt == ODP_PACKET_INVALID) > - return -1; > + return TEST_SEQ_INVALID; > > off = odp_packet_l4_offset(pkt); > if (off == ODP_PACKET_OFFSET_INVALID) > @@ -351,78 +356,86 @@ static int destroy_inq(odp_pktio_t pktio) > return odp_queue_destroy(inq); > } > > -static odp_event_t queue_deq_wait_time(odp_queue_t queue, uint64_t ns) > +static int get_packets(pktio_info_t *pktio_rx, odp_packet_t pkt_tbl[], > + int num, txrx_mode_e mode) > { > - odp_time_t start, now, diff; > - odp_event_t ev; > + odp_event_t evt_tbl[num]; > + int num_evts = 0; > + int num_pkts = 0; > + int i; > > - start = odp_time_local(); > + if (pktio_rx->in_mode == ODP_PKTIN_MODE_RECV) > + return odp_pktio_recv(pktio_rx->id, pkt_tbl, num); > > - do { > - ev = odp_queue_deq(queue); > - if (ev != ODP_EVENT_INVALID) > - return ev; > - now = odp_time_local(); > - diff = odp_time_diff(now, start); > - } while (odp_time_to_ns(diff) < ns); > + if (mode == TXRX_MODE_MULTI) { > + if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) > + num_evts = odp_queue_deq_multi(pktio_rx->inq, evt_tbl, > + num); > + else > + num_evts = odp_schedule_multi(NULL, ODP_SCHED_NO_WAIT, > + evt_tbl, num); > + } else { > + odp_event_t evt_tmp; > + > + if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) > + evt_tmp = odp_queue_deq(pktio_rx->inq); > + else > + evt_tmp = odp_schedule(NULL, ODP_SCHED_NO_WAIT); > > - return ODP_EVENT_INVALID; > + if (evt_tmp != ODP_EVENT_INVALID) > + evt_tbl[num_evts++] = evt_tmp; > + } > + > + /* convert events to packets, discarding any non-packet events */ > + for (i = 0; i < num_evts; ++i) { > + if (odp_event_type(evt_tbl[i]) == ODP_EVENT_PACKET) > + pkt_tbl[num_pkts++] = odp_packet_from_event(evt_tbl[i]); > + else > + odp_event_free(evt_tbl[i]); > + } > + > + return num_pkts; > } > > -static odp_packet_t wait_for_packet(pktio_info_t *pktio_rx, > - uint32_t seq, uint64_t ns) > +static int wait_for_packets(pktio_info_t *pktio_rx, odp_packet_t pkt_tbl[], > + uint32_t seq_tbl[], int num, txrx_mode_e mode, > + uint64_t ns) > { > odp_time_t start, now, diff; > - odp_event_t ev; > - odp_packet_t pkt; > - uint64_t wait; > + int num_rx = 0; > + int i; > + odp_packet_t pkt_tmp[num]; > > start = odp_time_local(); > - wait = odp_schedule_wait_time(ns); > > do { > - pkt = ODP_PACKET_INVALID; > - > - if (pktio_rx->in_mode == ODP_PKTIN_MODE_RECV) { > - odp_pktio_recv(pktio_rx->id, &pkt, 1); > - } else { > - if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) > - ev = queue_deq_wait_time(pktio_rx->inq, ns); > - else > - ev = odp_schedule(NULL, wait); > + int n = get_packets(pktio_rx, pkt_tmp, num - num_rx, mode); > > - if (ev != ODP_EVENT_INVALID) { > - if (odp_event_type(ev) == ODP_EVENT_PACKET) > - pkt = odp_packet_from_event(ev); > - else > - odp_event_free(ev); > - } > - } > - > - if (pkt != ODP_PACKET_INVALID) { > - if (pktio_pkt_seq(pkt) == seq) > - return pkt; > + if (n < 0) > + break; > > - odp_packet_free(pkt); > + for (i = 0; i < n; ++i) { > + if (pktio_pkt_seq(pkt_tmp[i]) == seq_tbl[num_rx]) > + pkt_tbl[num_rx++] = pkt_tmp[i]; > + else > + odp_packet_free(pkt_tmp[i]); > } > > now = odp_time_local(); > diff = odp_time_diff(now, start); > - } while (odp_time_to_ns(diff) < ns); > + } while (num_rx < num && odp_time_to_ns(diff) < ns); > > - CU_FAIL("failed to receive transmitted packet"); > - > - return ODP_PACKET_INVALID; > + return num_rx; > } > > static void pktio_txrx_multi(pktio_info_t *pktio_a, pktio_info_t *pktio_b, > - int num_pkts) > + int num_pkts, txrx_mode_e mode) > { > odp_packet_t tx_pkt[num_pkts]; > odp_event_t tx_ev[num_pkts]; > - odp_packet_t rx_pkt; > + odp_packet_t rx_pkt[num_pkts]; > uint32_t tx_seq[num_pkts]; > - int i, ret; > + int i, ret, num_rx; > > /* generate test packets to send */ > for (i = 0; i < num_pkts; ++i) { > @@ -451,12 +464,14 @@ static void pktio_txrx_multi(pktio_info_t *pktio_a, pktio_info_t *pktio_b, > } > > /* send packet(s) out */ > - if (num_pkts == 1) { > - ret = odp_queue_enq(pktio_a->outq, tx_ev[0]); > - if (ret != 0) { > - CU_FAIL("failed to enqueue test packet"); > - odp_packet_free(tx_pkt[0]); > - return; > + if (mode == TXRX_MODE_SINGLE) { > + for (i = 0; i < num_pkts; ++i) { > + ret = odp_queue_enq(pktio_a->outq, tx_ev[i]); > + if (ret != 0) { > + CU_FAIL("failed to enqueue test packet"); > + odp_packet_free(tx_pkt[i]); > + return; > + } > } > } else { > ret = odp_queue_enq_multi(pktio_a->outq, tx_ev, num_pkts); > @@ -470,21 +485,20 @@ static void pktio_txrx_multi(pktio_info_t *pktio_a, pktio_info_t *pktio_b, > } > > /* and wait for them to arrive back */ > - for (i = 0; i < num_pkts; ++i) { > - rx_pkt = wait_for_packet(pktio_b, tx_seq[i], > - ODP_TIME_SEC_IN_NS); > - > - if (rx_pkt == ODP_PACKET_INVALID) > - break; > - CU_ASSERT(odp_packet_input(rx_pkt) == pktio_b->id); > - CU_ASSERT(odp_packet_has_error(rx_pkt) == 0); > - odp_packet_free(rx_pkt); > + num_rx = wait_for_packets(pktio_b, rx_pkt, tx_seq, > + num_pkts, mode, ODP_TIME_SEC_IN_NS); > + CU_ASSERT(num_rx == num_pkts); > + > + for (i = 0; i < num_rx; ++i) { > + CU_ASSERT_FATAL(rx_pkt[i] != ODP_PACKET_INVALID); > + CU_ASSERT(odp_packet_input(rx_pkt[i]) == pktio_b->id); > + CU_ASSERT(odp_packet_has_error(rx_pkt[i]) == 0); > + odp_packet_free(rx_pkt[i]); > } > - > - CU_ASSERT(i == num_pkts); > } > > -static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts) > +static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts, > + txrx_mode_e mode) > { > int ret, i, if_b; > pktio_info_t pktios[MAX_NUM_IFACES]; > @@ -518,7 +532,7 @@ static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts) > /* if we have two interfaces then send through one and receive on > * another but if there's only one assume it's a loopback */ > if_b = (num_ifaces == 1) ? 0 : 1; > - pktio_txrx_multi(&pktios[0], &pktios[if_b], num_pkts); > + pktio_txrx_multi(&pktios[0], &pktios[if_b], num_pkts, mode); > > for (i = 0; i < num_ifaces; ++i) { > ret = odp_pktio_stop(pktios[i].id); > @@ -532,32 +546,36 @@ static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts) > > void pktio_test_poll_queue(void) > { > - test_txrx(ODP_PKTIN_MODE_POLL, 1); > + test_txrx(ODP_PKTIN_MODE_POLL, 1, TXRX_MODE_SINGLE); > + test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN, TXRX_MODE_SINGLE); > } > > void pktio_test_poll_multi(void) > { > - test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN); > + test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN, TXRX_MODE_MULTI); > + test_txrx(ODP_PKTIN_MODE_POLL, 1, TXRX_MODE_MULTI); > } > > void pktio_test_sched_queue(void) > { > - test_txrx(ODP_PKTIN_MODE_SCHED, 1); > + test_txrx(ODP_PKTIN_MODE_SCHED, 1, TXRX_MODE_SINGLE); > + test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN, TXRX_MODE_SINGLE); > } > > void pktio_test_sched_multi(void) > { > - test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN); > + test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN, TXRX_MODE_MULTI); > + test_txrx(ODP_PKTIN_MODE_SCHED, 1, TXRX_MODE_MULTI); > } > > void pktio_test_recv(void) > { > - test_txrx(ODP_PKTIN_MODE_RECV, 1); > + test_txrx(ODP_PKTIN_MODE_RECV, 1, TXRX_MODE_SINGLE); > } > > void pktio_test_recv_multi(void) > { > - test_txrx(ODP_PKTIN_MODE_RECV, TX_BATCH_LEN); > + test_txrx(ODP_PKTIN_MODE_RECV, TX_BATCH_LEN, TXRX_MODE_MULTI); > } > > void pktio_test_jumbo(void) > @@ -975,12 +993,8 @@ static void pktio_test_send_failure(void) > info_rx.inq = ODP_QUEUE_INVALID; > info_rx.in_mode = ODP_PKTIN_MODE_RECV; > > - for (i = 0; i < ret; ++i) { > - pkt_tbl[i] = wait_for_packet(&info_rx, pkt_seq[i], > - ODP_TIME_SEC_IN_NS); > - if (pkt_tbl[i] == ODP_PACKET_INVALID) > - break; > - } > + i = wait_for_packets(&info_rx, pkt_tbl, pkt_seq, ret, > + TXRX_MODE_MULTI, ODP_TIME_SEC_IN_NS); > > if (i == ret) { > /* now try to send starting with the too-long packet > @@ -1011,14 +1025,9 @@ static void pktio_test_send_failure(void) > ret = odp_pktio_send(pktio_tx, &pkt_tbl[i], TX_BATCH_LEN - i); > CU_ASSERT_FATAL(ret == (TX_BATCH_LEN - i)); > > - for (; i < TX_BATCH_LEN; ++i) { > - pkt_tbl[i] = wait_for_packet(&info_rx, > - pkt_seq[i], > - ODP_TIME_SEC_IN_NS); > - if (pkt_tbl[i] == ODP_PACKET_INVALID) > - break; > - } > - CU_ASSERT(i == TX_BATCH_LEN); > + i = wait_for_packets(&info_rx, &pkt_tbl[i], &pkt_seq[i], ret, > + TXRX_MODE_MULTI, ODP_TIME_SEC_IN_NS); > + CU_ASSERT(i == ret); > } else { > CU_FAIL("failed to generate test packets\n"); > } > -- > 2.1.1 >
Needs a rebase On 6 January 2016 at 06:46, Stuart Haslam <stuart.haslam@linaro.org> wrote: > On Fri, Dec 18, 2015 at 12:07:57PM +0000, Stuart Haslam wrote: > > Modify the tests that currently transmit packets in batches to also > > receive packets in batches. This adds coverage of odp_queue_deq_multi() > > and odp_schedule_multi() specifically against a packet input queue, > > as this doesn't get tested anywhere else in the validation suite. > > > > Signed-off-by: Stuart Haslam <stuart.haslam@linaro.org> > > Ping - needs review.. > > > --- > > Changes in v3 - test odp_queue_[enq|deq]_multi() and odp_schedule_multi() > > APIs with batch length of 1. > > > > Changes in v2 - rebased and picked up new time API > > > > test/validation/pktio/pktio.c | 185 > ++++++++++++++++++++++-------------------- > > 1 file changed, 97 insertions(+), 88 deletions(-) > > > > diff --git a/test/validation/pktio/pktio.c > b/test/validation/pktio/pktio.c > > index 28bfd30..05ddd68 100644 > > --- a/test/validation/pktio/pktio.c > > +++ b/test/validation/pktio/pktio.c > > @@ -58,8 +58,13 @@ typedef struct ODP_PACKED { > > typedef enum { > > PKT_POOL_UNSEGMENTED, > > PKT_POOL_SEGMENTED, > > -} pkt_segmented_e > > -; > > +} pkt_segmented_e; > > + > > +typedef enum { > > + TXRX_MODE_SINGLE, > > + TXRX_MODE_MULTI > > +} txrx_mode_e; > > + > > /** size of transmitted packets */ > > static uint32_t packet_len = PKT_LEN_NORMAL; > > > > @@ -142,7 +147,7 @@ static uint32_t pktio_pkt_seq(odp_packet_t pkt) > > pkt_tail_t tail; > > > > if (pkt == ODP_PACKET_INVALID) > > - return -1; > > + return TEST_SEQ_INVALID; > > > > off = odp_packet_l4_offset(pkt); > > if (off == ODP_PACKET_OFFSET_INVALID) > > @@ -351,78 +356,86 @@ static int destroy_inq(odp_pktio_t pktio) > > return odp_queue_destroy(inq); > > } > > > > -static odp_event_t queue_deq_wait_time(odp_queue_t queue, uint64_t ns) > > +static int get_packets(pktio_info_t *pktio_rx, odp_packet_t pkt_tbl[], > > + int num, txrx_mode_e mode) > > { > > - odp_time_t start, now, diff; > > - odp_event_t ev; > > + odp_event_t evt_tbl[num]; > > + int num_evts = 0; > > + int num_pkts = 0; > > + int i; > > > > - start = odp_time_local(); > > + if (pktio_rx->in_mode == ODP_PKTIN_MODE_RECV) > > + return odp_pktio_recv(pktio_rx->id, pkt_tbl, num); > > > > - do { > > - ev = odp_queue_deq(queue); > > - if (ev != ODP_EVENT_INVALID) > > - return ev; > > - now = odp_time_local(); > > - diff = odp_time_diff(now, start); > > - } while (odp_time_to_ns(diff) < ns); > > + if (mode == TXRX_MODE_MULTI) { > > + if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) > > + num_evts = odp_queue_deq_multi(pktio_rx->inq, > evt_tbl, > > + num); > > + else > > + num_evts = odp_schedule_multi(NULL, > ODP_SCHED_NO_WAIT, > > + evt_tbl, num); > > + } else { > > + odp_event_t evt_tmp; > > + > > + if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) > > + evt_tmp = odp_queue_deq(pktio_rx->inq); > > + else > > + evt_tmp = odp_schedule(NULL, ODP_SCHED_NO_WAIT); > > > > - return ODP_EVENT_INVALID; > > + if (evt_tmp != ODP_EVENT_INVALID) > > + evt_tbl[num_evts++] = evt_tmp; > > + } > > + > > + /* convert events to packets, discarding any non-packet events */ > > + for (i = 0; i < num_evts; ++i) { > > + if (odp_event_type(evt_tbl[i]) == ODP_EVENT_PACKET) > > + pkt_tbl[num_pkts++] = > odp_packet_from_event(evt_tbl[i]); > > + else > > + odp_event_free(evt_tbl[i]); > > + } > > + > > + return num_pkts; > > } > > > > -static odp_packet_t wait_for_packet(pktio_info_t *pktio_rx, > > - uint32_t seq, uint64_t ns) > > +static int wait_for_packets(pktio_info_t *pktio_rx, odp_packet_t > pkt_tbl[], > > + uint32_t seq_tbl[], int num, txrx_mode_e mode, > > + uint64_t ns) > > { > > odp_time_t start, now, diff; > > - odp_event_t ev; > > - odp_packet_t pkt; > > - uint64_t wait; > > + int num_rx = 0; > > + int i; > > + odp_packet_t pkt_tmp[num]; > > > > start = odp_time_local(); > > - wait = odp_schedule_wait_time(ns); > > > > do { > > - pkt = ODP_PACKET_INVALID; > > - > > - if (pktio_rx->in_mode == ODP_PKTIN_MODE_RECV) { > > - odp_pktio_recv(pktio_rx->id, &pkt, 1); > > - } else { > > - if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) > > - ev = queue_deq_wait_time(pktio_rx->inq, > ns); > > - else > > - ev = odp_schedule(NULL, wait); > > + int n = get_packets(pktio_rx, pkt_tmp, num - num_rx, mode); > > > > - if (ev != ODP_EVENT_INVALID) { > > - if (odp_event_type(ev) == ODP_EVENT_PACKET) > > - pkt = odp_packet_from_event(ev); > > - else > > - odp_event_free(ev); > > - } > > - } > > - > > - if (pkt != ODP_PACKET_INVALID) { > > - if (pktio_pkt_seq(pkt) == seq) > > - return pkt; > > + if (n < 0) > > + break; > > > > - odp_packet_free(pkt); > > + for (i = 0; i < n; ++i) { > > + if (pktio_pkt_seq(pkt_tmp[i]) == seq_tbl[num_rx]) > > + pkt_tbl[num_rx++] = pkt_tmp[i]; > > + else > > + odp_packet_free(pkt_tmp[i]); > > } > > > > now = odp_time_local(); > > diff = odp_time_diff(now, start); > > - } while (odp_time_to_ns(diff) < ns); > > + } while (num_rx < num && odp_time_to_ns(diff) < ns); > > > > - CU_FAIL("failed to receive transmitted packet"); > > - > > - return ODP_PACKET_INVALID; > > + return num_rx; > > } > > > > static void pktio_txrx_multi(pktio_info_t *pktio_a, pktio_info_t > *pktio_b, > > - int num_pkts) > > + int num_pkts, txrx_mode_e mode) > > { > > odp_packet_t tx_pkt[num_pkts]; > > odp_event_t tx_ev[num_pkts]; > > - odp_packet_t rx_pkt; > > + odp_packet_t rx_pkt[num_pkts]; > > uint32_t tx_seq[num_pkts]; > > - int i, ret; > > + int i, ret, num_rx; > > > > /* generate test packets to send */ > > for (i = 0; i < num_pkts; ++i) { > > @@ -451,12 +464,14 @@ static void pktio_txrx_multi(pktio_info_t > *pktio_a, pktio_info_t *pktio_b, > > } > > > > /* send packet(s) out */ > > - if (num_pkts == 1) { > > - ret = odp_queue_enq(pktio_a->outq, tx_ev[0]); > > - if (ret != 0) { > > - CU_FAIL("failed to enqueue test packet"); > > - odp_packet_free(tx_pkt[0]); > > - return; > > + if (mode == TXRX_MODE_SINGLE) { > > + for (i = 0; i < num_pkts; ++i) { > > + ret = odp_queue_enq(pktio_a->outq, tx_ev[i]); > > + if (ret != 0) { > > + CU_FAIL("failed to enqueue test packet"); > > + odp_packet_free(tx_pkt[i]); > > + return; > > + } > > } > > } else { > > ret = odp_queue_enq_multi(pktio_a->outq, tx_ev, num_pkts); > > @@ -470,21 +485,20 @@ static void pktio_txrx_multi(pktio_info_t > *pktio_a, pktio_info_t *pktio_b, > > } > > > > /* and wait for them to arrive back */ > > - for (i = 0; i < num_pkts; ++i) { > > - rx_pkt = wait_for_packet(pktio_b, tx_seq[i], > > - ODP_TIME_SEC_IN_NS); > > - > > - if (rx_pkt == ODP_PACKET_INVALID) > > - break; > > - CU_ASSERT(odp_packet_input(rx_pkt) == pktio_b->id); > > - CU_ASSERT(odp_packet_has_error(rx_pkt) == 0); > > - odp_packet_free(rx_pkt); > > + num_rx = wait_for_packets(pktio_b, rx_pkt, tx_seq, > > + num_pkts, mode, ODP_TIME_SEC_IN_NS); > > + CU_ASSERT(num_rx == num_pkts); > > + > > + for (i = 0; i < num_rx; ++i) { > > + CU_ASSERT_FATAL(rx_pkt[i] != ODP_PACKET_INVALID); > > + CU_ASSERT(odp_packet_input(rx_pkt[i]) == pktio_b->id); > > + CU_ASSERT(odp_packet_has_error(rx_pkt[i]) == 0); > > + odp_packet_free(rx_pkt[i]); > > } > > - > > - CU_ASSERT(i == num_pkts); > > } > > > > -static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts) > > +static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts, > > + txrx_mode_e mode) > > { > > int ret, i, if_b; > > pktio_info_t pktios[MAX_NUM_IFACES]; > > @@ -518,7 +532,7 @@ static void test_txrx(odp_pktio_input_mode_t > in_mode, int num_pkts) > > /* if we have two interfaces then send through one and receive on > > * another but if there's only one assume it's a loopback */ > > if_b = (num_ifaces == 1) ? 0 : 1; > > - pktio_txrx_multi(&pktios[0], &pktios[if_b], num_pkts); > > + pktio_txrx_multi(&pktios[0], &pktios[if_b], num_pkts, mode); > > > > for (i = 0; i < num_ifaces; ++i) { > > ret = odp_pktio_stop(pktios[i].id); > > @@ -532,32 +546,36 @@ static void test_txrx(odp_pktio_input_mode_t > in_mode, int num_pkts) > > > > void pktio_test_poll_queue(void) > > { > > - test_txrx(ODP_PKTIN_MODE_POLL, 1); > > + test_txrx(ODP_PKTIN_MODE_POLL, 1, TXRX_MODE_SINGLE); > > + test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN, TXRX_MODE_SINGLE); > > } > > > > void pktio_test_poll_multi(void) > > { > > - test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN); > > + test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN, TXRX_MODE_MULTI); > > + test_txrx(ODP_PKTIN_MODE_POLL, 1, TXRX_MODE_MULTI); > > } > > > > void pktio_test_sched_queue(void) > > { > > - test_txrx(ODP_PKTIN_MODE_SCHED, 1); > > + test_txrx(ODP_PKTIN_MODE_SCHED, 1, TXRX_MODE_SINGLE); > > + test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN, TXRX_MODE_SINGLE); > > } > > > > void pktio_test_sched_multi(void) > > { > > - test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN); > > + test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN, TXRX_MODE_MULTI); > > + test_txrx(ODP_PKTIN_MODE_SCHED, 1, TXRX_MODE_MULTI); > > } > > > > void pktio_test_recv(void) > > { > > - test_txrx(ODP_PKTIN_MODE_RECV, 1); > > + test_txrx(ODP_PKTIN_MODE_RECV, 1, TXRX_MODE_SINGLE); > > } > > > > void pktio_test_recv_multi(void) > > { > > - test_txrx(ODP_PKTIN_MODE_RECV, TX_BATCH_LEN); > > + test_txrx(ODP_PKTIN_MODE_RECV, TX_BATCH_LEN, TXRX_MODE_MULTI); > > } > > > > void pktio_test_jumbo(void) > > @@ -975,12 +993,8 @@ static void pktio_test_send_failure(void) > > info_rx.inq = ODP_QUEUE_INVALID; > > info_rx.in_mode = ODP_PKTIN_MODE_RECV; > > > > - for (i = 0; i < ret; ++i) { > > - pkt_tbl[i] = wait_for_packet(&info_rx, pkt_seq[i], > > - ODP_TIME_SEC_IN_NS); > > - if (pkt_tbl[i] == ODP_PACKET_INVALID) > > - break; > > - } > > + i = wait_for_packets(&info_rx, pkt_tbl, pkt_seq, ret, > > + TXRX_MODE_MULTI, ODP_TIME_SEC_IN_NS); > > > > if (i == ret) { > > /* now try to send starting with the too-long > packet > > @@ -1011,14 +1025,9 @@ static void pktio_test_send_failure(void) > > ret = odp_pktio_send(pktio_tx, &pkt_tbl[i], TX_BATCH_LEN - > i); > > CU_ASSERT_FATAL(ret == (TX_BATCH_LEN - i)); > > > > - for (; i < TX_BATCH_LEN; ++i) { > > - pkt_tbl[i] = wait_for_packet(&info_rx, > > - pkt_seq[i], > > - ODP_TIME_SEC_IN_NS); > > - if (pkt_tbl[i] == ODP_PACKET_INVALID) > > - break; > > - } > > - CU_ASSERT(i == TX_BATCH_LEN); > > + i = wait_for_packets(&info_rx, &pkt_tbl[i], &pkt_seq[i], > ret, > > + TXRX_MODE_MULTI, ODP_TIME_SEC_IN_NS); > > + CU_ASSERT(i == ret); > > } else { > > CU_FAIL("failed to generate test packets\n"); > > } > > -- > > 2.1.1 > > > -- Mike Holmes Technical Manager - Linaro Networking Group Linaro.org <http://www.linaro.org/> *│ *Open source software for ARM SoCs
On Wed, Jan 06, 2016 at 07:30:42AM -0500, Mike Holmes wrote: > Needs a rebase > Awh man, more time API changes. v4 coming up.
diff --git a/test/validation/pktio/pktio.c b/test/validation/pktio/pktio.c index 28bfd30..05ddd68 100644 --- a/test/validation/pktio/pktio.c +++ b/test/validation/pktio/pktio.c @@ -58,8 +58,13 @@ typedef struct ODP_PACKED { typedef enum { PKT_POOL_UNSEGMENTED, PKT_POOL_SEGMENTED, -} pkt_segmented_e -; +} pkt_segmented_e; + +typedef enum { + TXRX_MODE_SINGLE, + TXRX_MODE_MULTI +} txrx_mode_e; + /** size of transmitted packets */ static uint32_t packet_len = PKT_LEN_NORMAL; @@ -142,7 +147,7 @@ static uint32_t pktio_pkt_seq(odp_packet_t pkt) pkt_tail_t tail; if (pkt == ODP_PACKET_INVALID) - return -1; + return TEST_SEQ_INVALID; off = odp_packet_l4_offset(pkt); if (off == ODP_PACKET_OFFSET_INVALID) @@ -351,78 +356,86 @@ static int destroy_inq(odp_pktio_t pktio) return odp_queue_destroy(inq); } -static odp_event_t queue_deq_wait_time(odp_queue_t queue, uint64_t ns) +static int get_packets(pktio_info_t *pktio_rx, odp_packet_t pkt_tbl[], + int num, txrx_mode_e mode) { - odp_time_t start, now, diff; - odp_event_t ev; + odp_event_t evt_tbl[num]; + int num_evts = 0; + int num_pkts = 0; + int i; - start = odp_time_local(); + if (pktio_rx->in_mode == ODP_PKTIN_MODE_RECV) + return odp_pktio_recv(pktio_rx->id, pkt_tbl, num); - do { - ev = odp_queue_deq(queue); - if (ev != ODP_EVENT_INVALID) - return ev; - now = odp_time_local(); - diff = odp_time_diff(now, start); - } while (odp_time_to_ns(diff) < ns); + if (mode == TXRX_MODE_MULTI) { + if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) + num_evts = odp_queue_deq_multi(pktio_rx->inq, evt_tbl, + num); + else + num_evts = odp_schedule_multi(NULL, ODP_SCHED_NO_WAIT, + evt_tbl, num); + } else { + odp_event_t evt_tmp; + + if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) + evt_tmp = odp_queue_deq(pktio_rx->inq); + else + evt_tmp = odp_schedule(NULL, ODP_SCHED_NO_WAIT); - return ODP_EVENT_INVALID; + if (evt_tmp != ODP_EVENT_INVALID) + evt_tbl[num_evts++] = evt_tmp; + } + + /* convert events to packets, discarding any non-packet events */ + for (i = 0; i < num_evts; ++i) { + if (odp_event_type(evt_tbl[i]) == ODP_EVENT_PACKET) + pkt_tbl[num_pkts++] = odp_packet_from_event(evt_tbl[i]); + else + odp_event_free(evt_tbl[i]); + } + + return num_pkts; } -static odp_packet_t wait_for_packet(pktio_info_t *pktio_rx, - uint32_t seq, uint64_t ns) +static int wait_for_packets(pktio_info_t *pktio_rx, odp_packet_t pkt_tbl[], + uint32_t seq_tbl[], int num, txrx_mode_e mode, + uint64_t ns) { odp_time_t start, now, diff; - odp_event_t ev; - odp_packet_t pkt; - uint64_t wait; + int num_rx = 0; + int i; + odp_packet_t pkt_tmp[num]; start = odp_time_local(); - wait = odp_schedule_wait_time(ns); do { - pkt = ODP_PACKET_INVALID; - - if (pktio_rx->in_mode == ODP_PKTIN_MODE_RECV) { - odp_pktio_recv(pktio_rx->id, &pkt, 1); - } else { - if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) - ev = queue_deq_wait_time(pktio_rx->inq, ns); - else - ev = odp_schedule(NULL, wait); + int n = get_packets(pktio_rx, pkt_tmp, num - num_rx, mode); - if (ev != ODP_EVENT_INVALID) { - if (odp_event_type(ev) == ODP_EVENT_PACKET) - pkt = odp_packet_from_event(ev); - else - odp_event_free(ev); - } - } - - if (pkt != ODP_PACKET_INVALID) { - if (pktio_pkt_seq(pkt) == seq) - return pkt; + if (n < 0) + break; - odp_packet_free(pkt); + for (i = 0; i < n; ++i) { + if (pktio_pkt_seq(pkt_tmp[i]) == seq_tbl[num_rx]) + pkt_tbl[num_rx++] = pkt_tmp[i]; + else + odp_packet_free(pkt_tmp[i]); } now = odp_time_local(); diff = odp_time_diff(now, start); - } while (odp_time_to_ns(diff) < ns); + } while (num_rx < num && odp_time_to_ns(diff) < ns); - CU_FAIL("failed to receive transmitted packet"); - - return ODP_PACKET_INVALID; + return num_rx; } static void pktio_txrx_multi(pktio_info_t *pktio_a, pktio_info_t *pktio_b, - int num_pkts) + int num_pkts, txrx_mode_e mode) { odp_packet_t tx_pkt[num_pkts]; odp_event_t tx_ev[num_pkts]; - odp_packet_t rx_pkt; + odp_packet_t rx_pkt[num_pkts]; uint32_t tx_seq[num_pkts]; - int i, ret; + int i, ret, num_rx; /* generate test packets to send */ for (i = 0; i < num_pkts; ++i) { @@ -451,12 +464,14 @@ static void pktio_txrx_multi(pktio_info_t *pktio_a, pktio_info_t *pktio_b, } /* send packet(s) out */ - if (num_pkts == 1) { - ret = odp_queue_enq(pktio_a->outq, tx_ev[0]); - if (ret != 0) { - CU_FAIL("failed to enqueue test packet"); - odp_packet_free(tx_pkt[0]); - return; + if (mode == TXRX_MODE_SINGLE) { + for (i = 0; i < num_pkts; ++i) { + ret = odp_queue_enq(pktio_a->outq, tx_ev[i]); + if (ret != 0) { + CU_FAIL("failed to enqueue test packet"); + odp_packet_free(tx_pkt[i]); + return; + } } } else { ret = odp_queue_enq_multi(pktio_a->outq, tx_ev, num_pkts); @@ -470,21 +485,20 @@ static void pktio_txrx_multi(pktio_info_t *pktio_a, pktio_info_t *pktio_b, } /* and wait for them to arrive back */ - for (i = 0; i < num_pkts; ++i) { - rx_pkt = wait_for_packet(pktio_b, tx_seq[i], - ODP_TIME_SEC_IN_NS); - - if (rx_pkt == ODP_PACKET_INVALID) - break; - CU_ASSERT(odp_packet_input(rx_pkt) == pktio_b->id); - CU_ASSERT(odp_packet_has_error(rx_pkt) == 0); - odp_packet_free(rx_pkt); + num_rx = wait_for_packets(pktio_b, rx_pkt, tx_seq, + num_pkts, mode, ODP_TIME_SEC_IN_NS); + CU_ASSERT(num_rx == num_pkts); + + for (i = 0; i < num_rx; ++i) { + CU_ASSERT_FATAL(rx_pkt[i] != ODP_PACKET_INVALID); + CU_ASSERT(odp_packet_input(rx_pkt[i]) == pktio_b->id); + CU_ASSERT(odp_packet_has_error(rx_pkt[i]) == 0); + odp_packet_free(rx_pkt[i]); } - - CU_ASSERT(i == num_pkts); } -static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts) +static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts, + txrx_mode_e mode) { int ret, i, if_b; pktio_info_t pktios[MAX_NUM_IFACES]; @@ -518,7 +532,7 @@ static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts) /* if we have two interfaces then send through one and receive on * another but if there's only one assume it's a loopback */ if_b = (num_ifaces == 1) ? 0 : 1; - pktio_txrx_multi(&pktios[0], &pktios[if_b], num_pkts); + pktio_txrx_multi(&pktios[0], &pktios[if_b], num_pkts, mode); for (i = 0; i < num_ifaces; ++i) { ret = odp_pktio_stop(pktios[i].id); @@ -532,32 +546,36 @@ static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts) void pktio_test_poll_queue(void) { - test_txrx(ODP_PKTIN_MODE_POLL, 1); + test_txrx(ODP_PKTIN_MODE_POLL, 1, TXRX_MODE_SINGLE); + test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN, TXRX_MODE_SINGLE); } void pktio_test_poll_multi(void) { - test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN); + test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN, TXRX_MODE_MULTI); + test_txrx(ODP_PKTIN_MODE_POLL, 1, TXRX_MODE_MULTI); } void pktio_test_sched_queue(void) { - test_txrx(ODP_PKTIN_MODE_SCHED, 1); + test_txrx(ODP_PKTIN_MODE_SCHED, 1, TXRX_MODE_SINGLE); + test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN, TXRX_MODE_SINGLE); } void pktio_test_sched_multi(void) { - test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN); + test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN, TXRX_MODE_MULTI); + test_txrx(ODP_PKTIN_MODE_SCHED, 1, TXRX_MODE_MULTI); } void pktio_test_recv(void) { - test_txrx(ODP_PKTIN_MODE_RECV, 1); + test_txrx(ODP_PKTIN_MODE_RECV, 1, TXRX_MODE_SINGLE); } void pktio_test_recv_multi(void) { - test_txrx(ODP_PKTIN_MODE_RECV, TX_BATCH_LEN); + test_txrx(ODP_PKTIN_MODE_RECV, TX_BATCH_LEN, TXRX_MODE_MULTI); } void pktio_test_jumbo(void) @@ -975,12 +993,8 @@ static void pktio_test_send_failure(void) info_rx.inq = ODP_QUEUE_INVALID; info_rx.in_mode = ODP_PKTIN_MODE_RECV; - for (i = 0; i < ret; ++i) { - pkt_tbl[i] = wait_for_packet(&info_rx, pkt_seq[i], - ODP_TIME_SEC_IN_NS); - if (pkt_tbl[i] == ODP_PACKET_INVALID) - break; - } + i = wait_for_packets(&info_rx, pkt_tbl, pkt_seq, ret, + TXRX_MODE_MULTI, ODP_TIME_SEC_IN_NS); if (i == ret) { /* now try to send starting with the too-long packet @@ -1011,14 +1025,9 @@ static void pktio_test_send_failure(void) ret = odp_pktio_send(pktio_tx, &pkt_tbl[i], TX_BATCH_LEN - i); CU_ASSERT_FATAL(ret == (TX_BATCH_LEN - i)); - for (; i < TX_BATCH_LEN; ++i) { - pkt_tbl[i] = wait_for_packet(&info_rx, - pkt_seq[i], - ODP_TIME_SEC_IN_NS); - if (pkt_tbl[i] == ODP_PACKET_INVALID) - break; - } - CU_ASSERT(i == TX_BATCH_LEN); + i = wait_for_packets(&info_rx, &pkt_tbl[i], &pkt_seq[i], ret, + TXRX_MODE_MULTI, ODP_TIME_SEC_IN_NS); + CU_ASSERT(i == ret); } else { CU_FAIL("failed to generate test packets\n"); }
Modify the tests that currently transmit packets in batches to also receive packets in batches. This adds coverage of odp_queue_deq_multi() and odp_schedule_multi() specifically against a packet input queue, as this doesn't get tested anywhere else in the validation suite. Signed-off-by: Stuart Haslam <stuart.haslam@linaro.org> --- Changes in v3 - test odp_queue_[enq|deq]_multi() and odp_schedule_multi() APIs with batch length of 1. Changes in v2 - rebased and picked up new time API test/validation/pktio/pktio.c | 185 ++++++++++++++++++++++-------------------- 1 file changed, 97 insertions(+), 88 deletions(-)