Re: [lng-odp] [PATCHv3 3/3] test: pktio: add tests for segmented packets

[Stuart Haslam]

On Mon, Jul 20, 2015 at 04:18:44PM +0200, Nicolas Morey-Chaisemartin wrote:
> Signed-off-by: Nicolas Morey-Chaisemartin <nmo...@kalray.eu>
> ---
>  test/validation/pktio/pktio.c | 71 
> +++++++++++++++++++++++++++++++++++++------
>  1 file changed, 61 insertions(+), 10 deletions(-)
> 
> diff --git a/test/validation/pktio/pktio.c b/test/validation/pktio/pktio.c
> index 6650568..1e48f87 100644
> --- a/test/validation/pktio/pktio.c
> +++ b/test/validation/pktio/pktio.c
> @@ -47,6 +47,12 @@ typedef struct ODP_PACKED {
>       uint32be_t magic;
>  } pkt_tail_t;
>  
> +/** Run mode */
> +typedef enum {
> +     PKT_POOL_UNSEGMENTED,
> +     PKT_POOL_SEGMENTED,
> +} pkt_segmented_e
> +;
>  /** size of transmitted packets */
>  static uint32_t packet_len = PKT_LEN_NORMAL;
>  
> @@ -56,8 +62,27 @@ odp_pool_t default_pkt_pool = ODP_POOL_INVALID;
>  /** sequence number of IP packets */
>  odp_atomic_u32_t ip_seq;
>  
> +/** Type of pool segmentation */
> +pkt_segmented_e pool_segmentation = PKT_POOL_UNSEGMENTED;
> +
>  odp_pool_t pool[MAX_NUM_IFACES] = {ODP_POOL_INVALID, ODP_POOL_INVALID};
>  
> +static void set_pool_len(odp_pool_param_t *params)
> +{
> +     switch (pool_segmentation) {
> +     case PKT_POOL_SEGMENTED:
> +             /* Force segment to minimum size */
> +             params->pkt.seg_len = 0;
> +             params->pkt.len = PKT_BUF_SIZE;
> +             break;
> +     case PKT_POOL_UNSEGMENTED:
> +     default:
> +             params->pkt.seg_len = PKT_BUF_SIZE;
> +             params->pkt.len = PKT_BUF_SIZE;
> +             break;
> +     }
> +}
> +
>  static void pktio_pkt_set_macs(odp_packet_t pkt,
>                              pktio_info_t *src, pktio_info_t *dst)
>  {
> @@ -203,17 +228,19 @@ static int pktio_fixup_checksums(odp_packet_t pkt)
>  static int default_pool_create(void)
>  {
>       odp_pool_param_t params;
> +     char pool_name[ODP_POOL_NAME_LEN];
>  
>       if (default_pkt_pool != ODP_POOL_INVALID)
>               return -1;
>  
>       memset(&params, 0, sizeof(params));
> -     params.pkt.seg_len = PKT_BUF_SIZE;
> -     params.pkt.len     = PKT_BUF_SIZE;
> +     set_pool_len(&params);
>       params.pkt.num     = PKT_BUF_NUM;
>       params.type        = ODP_POOL_PACKET;
>  
> -     default_pkt_pool = odp_pool_create("pkt_pool_default",
> +     snprintf(pool_name, sizeof(pool_name),
> +              "pkt_pool_default_%d", pool_segmentation);
> +     default_pkt_pool = odp_pool_create(pool_name,
>                                          ODP_SHM_NULL, &params);
>       if (default_pkt_pool == ODP_POOL_INVALID)
>               return -1;
> @@ -612,12 +639,12 @@ static int create_pool(const char *iface, int num)
>       odp_pool_param_t params;
>  
>       memset(&params, 0, sizeof(params));
> -     params.pkt.seg_len = PKT_BUF_SIZE;
> -     params.pkt.len     = PKT_BUF_SIZE;
> +     set_pool_len(&params);
>       params.pkt.num     = PKT_BUF_NUM;
>       params.type        = ODP_POOL_PACKET;
>  
> -     snprintf(pool_name, sizeof(pool_name), "pkt_pool_%s", iface);
> +     snprintf(pool_name, sizeof(pool_name), "pkt_pool_%s_%d",
> +              iface, pool_segmentation);
>  
>       pool[num] = odp_pool_create(pool_name, ODP_SHM_NULL, &params);
>       if (ODP_POOL_INVALID == pool[num]) {
> @@ -660,6 +687,18 @@ static int pktio_suite_init(void)
>       return 0;
>  }
>  
> +static int pktio_suite_init_unsegmented(void)
> +{
> +     pool_segmentation = PKT_POOL_UNSEGMENTED;
> +     return pktio_suite_init();
> +}
> +
> +static int pktio_suite_init_segmented(void)
> +{
> +     pool_segmentation = PKT_POOL_SEGMENTED;
> +     return pktio_suite_init();
> +}
> +
>  static int pktio_suite_term(void)
>  {
>       char pool_name[ODP_POOL_NAME_LEN];
> @@ -669,7 +708,7 @@ static int pktio_suite_term(void)
>  
>       for (i = 0; i < num_ifaces; ++i) {
>               snprintf(pool_name, sizeof(pool_name),
> -                      "pkt_pool_%s", iface_name[i]);
> +                      "pkt_pool_%s_%d", iface_name[i], pool_segmentation);
>               pool = odp_pool_lookup(pool_name);
>               if (pool == ODP_POOL_INVALID)
>                       continue;
> @@ -685,11 +724,12 @@ static int pktio_suite_term(void)
>               fprintf(stderr, "error: failed to destroy default pool\n");
>               ret = -1;
>       }
> +     default_pkt_pool = ODP_POOL_INVALID;
>  
>       return ret;
>  }
>  
> -static CU_TestInfo pktio_suite[] = {
> +static CU_TestInfo pktio_suite_unsegmented[] = {
>       {"pktio open",          pktio_test_open},
>       {"pktio lookup",        pktio_test_lookup},
>       {"pktio inq",           pktio_test_inq},
> @@ -705,9 +745,20 @@ static CU_TestInfo pktio_suite[] = {
>       CU_TEST_INFO_NULL
>  };
>  
> +static CU_TestInfo pktio_suite_segmented[] = {
> +     {"pktio poll queues",   pktio_test_poll_queue},
> +     {"pktio poll multi",    pktio_test_poll_multi},
> +     {"pktio sched queues",  pktio_test_sched_queue},
> +     {"pktio sched multi",   pktio_test_sched_multi},
> +     {"pktio jumbo frames",  pktio_test_jumbo},
> +     CU_TEST_INFO_NULL
> +};
> +
>  static CU_SuiteInfo pktio_suites[] = {
> -     {"Packet I/O",
> -             pktio_suite_init, pktio_suite_term, NULL, NULL, pktio_suite},
> +     {"Packet I/O Unsegmented", pktio_suite_init_unsegmented, 
> pktio_suite_term,
> +      NULL, NULL, pktio_suite_unsegmented},

checkpatch warns on long line here.

> +     {"Packet I/O Segmented", pktio_suite_init_segmented,
> +      pktio_suite_term, NULL, NULL, pktio_suite_segmented},
>       CU_SUITE_INFO_NULL
>  };

-- 
Stuart.
_______________________________________________
lng-odp mailing list
lng-odp@lists.linaro.org
https://lists.linaro.org/mailman/listinfo/lng-odp