On 09/04/15 12:55, Stuart Haslam wrote:
Test that transmit errors are handled correctly by attempting to send a
packet larger than the MTU of the interface.
Signed-off-by: Stuart Haslam <[email protected]>
---
test/validation/pktio/pktio.c | 124 +++++++++++++++++++++++++++++++++++++++++-
1 file changed, 121 insertions(+), 3 deletions(-)
diff --git a/test/validation/pktio/pktio.c b/test/validation/pktio/pktio.c
index 95c3c34..fa146c5 100644
--- a/test/validation/pktio/pktio.c
+++ b/test/validation/pktio/pktio.c
@@ -21,6 +21,7 @@
#define MAX_NUM_IFACES 2
#define TEST_SEQ_INVALID ((uint32_t)~0)
#define TEST_SEQ_MAGIC 0x92749451
+#define TX_BATCH_LEN 4
/** interface names used for testing */
static const char *iface_name[MAX_NUM_IFACES];
@@ -507,7 +508,7 @@ void pktio_test_poll_queue(void)
void pktio_test_poll_multi(void)
{
- test_txrx(ODP_PKTIN_MODE_POLL, 4);
+ test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN);
}
void pktio_test_sched_queue(void)
@@ -517,7 +518,7 @@ void pktio_test_sched_queue(void)
void pktio_test_sched_multi(void)
{
- test_txrx(ODP_PKTIN_MODE_SCHED, 4);
+ test_txrx(ODP_PKTIN_MODE_SCHED, TX_BATCH_LEN);
}
void pktio_test_recv(void)
@@ -527,7 +528,7 @@ void pktio_test_recv(void)
void pktio_test_recv_multi(void)
{
- test_txrx(ODP_PKTIN_MODE_RECV, 4);
+ test_txrx(ODP_PKTIN_MODE_RECV, TX_BATCH_LEN);
}
void pktio_test_jumbo(void)
@@ -790,6 +791,121 @@ static void pktio_test_start_stop(void)
}
}
+static void pktio_test_send_failure(void)
+{
+ odp_pktio_t pktio_tx, pktio_rx;
+ odp_packet_t pkt_tbl[TX_BATCH_LEN];
+ uint32_t pkt_seq[TX_BATCH_LEN];
+ int ret, mtu, i, alloc_pkts;
+ odp_pool_param_t pool_params;
+ odp_pool_t pkt_pool;
+ int long_pkt_idx = TX_BATCH_LEN / 2;
+ pktio_info_t info_rx;
+
+ pktio_tx = create_pktio(0, ODP_PKTIN_MODE_RECV);
+ if (pktio_tx == ODP_PKTIO_INVALID) {
+ CU_FAIL("failed to open pktio");
+ return;
+ }
+
+ /* read the MTU from the transmit interface */
+ mtu = odp_pktio_mtu(pktio_tx);
+
+ /* if the interface MTU is larger that the biggest packet we can
+ * allocate then we can't use this method to test transmit failures */
+ if (mtu > ODP_CONFIG_PACKET_BUF_LEN_MAX - 32) {
+ CU_ASSERT(odp_pktio_close(pktio_tx) == 0);
should we have some print here or mark test as "skipped"? Just no
calling test case
and mark it as pass looks not really right thing to do.
Maxim.
+ return;
+ }
+
+ ret = odp_pktio_start(pktio_tx);
+ CU_ASSERT_FATAL(ret == 0);
+
+ /* configure the pool so that we can generate test packets larger
+ * than the interface MTU */
+ memset(&pool_params, 0, sizeof(pool_params));
+ pool_params.pkt.len = mtu + 32;
+ pool_params.pkt.seg_len = pool_params.pkt.len;
+ pool_params.pkt.num = TX_BATCH_LEN + 1;
+ pool_params.type = ODP_POOL_PACKET;
+ pkt_pool = odp_pool_create("pkt_pool_oversize", &pool_params);
+ CU_ASSERT_FATAL(pkt_pool != ODP_POOL_INVALID);
+
+ if (num_ifaces > 1) {
+ pktio_rx = create_pktio(1, ODP_PKTIN_MODE_RECV);
+ ret = odp_pktio_start(pktio_rx);
+ CU_ASSERT_FATAL(ret == 0);
+ } else {
+ pktio_rx = pktio_tx;
+ }
+
+ /* generate a batch of packets with a single overly long packet
+ * in the middle */
+ for (i = 0; i < TX_BATCH_LEN; ++i) {
+ uint32_t pkt_len;
+
+ if (i == long_pkt_idx)
+ pkt_len = pool_params.pkt.len;
+ else
+ pkt_len = PKT_LEN_NORMAL;
+
+ pkt_tbl[i] = odp_packet_alloc(pkt_pool, pkt_len);
+ if (pkt_tbl[i] == ODP_PACKET_INVALID)
+ break;
+
+ pkt_seq[i] = pktio_init_packet(pkt_tbl[i]);
+ if (pkt_seq[i] == TEST_SEQ_INVALID)
+ break;
+ }
+ alloc_pkts = i;
+
+ if (alloc_pkts == TX_BATCH_LEN) {
+ /* try to send the batch with the long packet in the middle,
+ * the initial short packets should be sent successfully */
+ odp_errno_zero();
+ ret = odp_pktio_send(pktio_tx, pkt_tbl, TX_BATCH_LEN);
+ CU_ASSERT(ret == long_pkt_idx);
+ CU_ASSERT(odp_errno() == 0);
+
+ info_rx.id = pktio_rx;
+ info_rx.outq = ODP_QUEUE_INVALID;
+ 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);
+ if (pkt_tbl[i] == ODP_PACKET_INVALID)
+ break;
+ }
+
+ if (i == ret) {
+ /* now try to send starting with the too-long packet
+ * and verify it fails */
+ odp_errno_zero();
+ ret = odp_pktio_send(pktio_tx,
+ &pkt_tbl[long_pkt_idx],
+ TX_BATCH_LEN - long_pkt_idx);
+ CU_ASSERT(ret == -1);
+ CU_ASSERT(odp_errno() != 0);
+ } else {
+ CU_FAIL("failed to receive transmitted packets\n");
+ }
+ } else {
+ CU_FAIL("failed to generate test packets\n");
+ }
+
+ for (i = 0; i < alloc_pkts; ++i) {
+ if (pkt_tbl[i] != ODP_PACKET_INVALID)
+ odp_packet_free(pkt_tbl[i]);
+ }
+
+ if (pktio_rx != pktio_tx)
+ CU_ASSERT(odp_pktio_close(pktio_rx) == 0);
+ CU_ASSERT(odp_pktio_close(pktio_tx) == 0);
+ CU_ASSERT(odp_pool_destroy(pkt_pool) == 0);
+}
+
static int create_pool(const char *iface, int num)
{
char pool_name[ODP_POOL_NAME_LEN];
@@ -897,6 +1013,7 @@ CU_TestInfo pktio_suite_unsegmented[] = {
_CU_TEST_INFO(pktio_test_recv),
_CU_TEST_INFO(pktio_test_recv_multi),
_CU_TEST_INFO(pktio_test_jumbo),
+ _CU_TEST_INFO(pktio_test_send_failure),
_CU_TEST_INFO(pktio_test_mtu),
_CU_TEST_INFO(pktio_test_promisc),
_CU_TEST_INFO(pktio_test_mac),
@@ -913,6 +1030,7 @@ CU_TestInfo pktio_suite_segmented[] = {
_CU_TEST_INFO(pktio_test_recv),
_CU_TEST_INFO(pktio_test_recv_multi),
_CU_TEST_INFO(pktio_test_jumbo),
+ _CU_TEST_INFO(pktio_test_send_failure),
CU_TEST_INFO_NULL
};
_______________________________________________
lng-odp mailing list
[email protected]
https://lists.linaro.org/mailman/listinfo/lng-odp
