On Mon, Mar 30, 2015 at 12:23 PM, Petri Savolainen < petri.savolai...@nokia.com> wrote:
> Packet IO interface level parameters are needed e.g. to > select input mode. User must select and use one input mode > (sched, poll or recv) per pktio interface. > > Signed-off-by: Petri Savolainen <petri.savolai...@nokia.com> > --- > example/generator/odp_generator.c | 6 +++- > example/ipsec/odp_ipsec.c | 11 +++++- > example/l2fwd/odp_l2fwd.c | 10 +++++- > example/packet/odp_pktio.c | 19 +++++++++- > include/odp/api/packet_io.h | 28 ++++++++++++++- > .../linux-generic/include/odp_packet_io_internal.h | 1 + > platform/linux-generic/odp_packet_io.c | 10 ++++-- > .../classification/odp_classification_tests.c | 6 +++- > test/validation/odp_pktio.c | 41 > +++++++++++++++------- > 9 files changed, 111 insertions(+), 21 deletions(-) > > diff --git a/example/generator/odp_generator.c > b/example/generator/odp_generator.c > index 3870fd1..953ae4b 100644 > --- a/example/generator/odp_generator.c > +++ b/example/generator/odp_generator.c > @@ -307,9 +307,13 @@ static odp_pktio_t create_pktio(const char *dev, > odp_pool_t pool) > odp_pktio_t pktio; > int ret; > odp_queue_t inq_def; > + odp_pktio_param_t pktio_param; > + > + memset(&pktio_param, 0, sizeof(pktio_param)); > + pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; > > /* Open a packet IO instance */ > - pktio = odp_pktio_open(dev, pool); > + pktio = odp_pktio_open(dev, pool, &pktio_param); > > if (pktio == ODP_PKTIO_INVALID) > EXAMPLE_ABORT("Error: pktio create failed for %s\n", dev); > diff --git a/example/ipsec/odp_ipsec.c b/example/ipsec/odp_ipsec.c > index 82ed0cb..5f622a4 100644 > --- a/example/ipsec/odp_ipsec.c > +++ b/example/ipsec/odp_ipsec.c > @@ -504,11 +504,20 @@ void initialize_intf(char *intf) > int ret; > uint8_t src_mac[ODPH_ETHADDR_LEN]; > char src_mac_str[MAX_STRING]; > + odp_pktio_param_t pktio_param; > + > + memset(&pktio_param, 0, sizeof(pktio_param)); > + > +#ifdef IPSEC_POLL_QUEUES > + pktio_param.in_mode = ODP_PKTIN_MODE_POLL; > +#else > + pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; > +#endif > > /* > * Open a packet IO instance for thread and get default output > queue > */ > - pktio = odp_pktio_open(intf, pkt_pool); > + pktio = odp_pktio_open(intf, pkt_pool, &pktio_param); > if (ODP_PKTIO_INVALID == pktio) { > EXAMPLE_ERR("Error: pktio create failed for %s\n", intf); > exit(EXIT_FAILURE); > diff --git a/example/l2fwd/odp_l2fwd.c b/example/l2fwd/odp_l2fwd.c > index a6ce478..4105961 100644 > --- a/example/l2fwd/odp_l2fwd.c > +++ b/example/l2fwd/odp_l2fwd.c > @@ -258,8 +258,16 @@ static odp_pktio_t create_pktio(const char *dev, > odp_pool_t pool, > odp_queue_t inq_def; > odp_pktio_t pktio; > int ret; > + odp_pktio_param_t pktio_param; > > - pktio = odp_pktio_open(dev, pool); > + memset(&pktio_param, 0, sizeof(pktio_param)); > + > + if (mode == APPL_MODE_PKT_BURST) > + pktio_param.in_mode = ODP_PKTIN_MODE_RECV; > + else > + pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; > + > + pktio = odp_pktio_open(dev, pool, &pktio_param); > if (pktio == ODP_PKTIO_INVALID) { > EXAMPLE_ERR("Error: failed to open %s\n", dev); > return ODP_PKTIO_INVALID; > diff --git a/example/packet/odp_pktio.c b/example/packet/odp_pktio.c > index 61af855..6f638c6 100644 > --- a/example/packet/odp_pktio.c > +++ b/example/packet/odp_pktio.c > @@ -122,9 +122,26 @@ static odp_pktio_t create_pktio(const char *dev, > odp_pool_t pool, int mode) > odp_queue_param_t qparam; > char inq_name[ODP_QUEUE_NAME_LEN]; > int ret; > + odp_pktio_param_t pktio_param; > + > + memset(&pktio_param, 0, sizeof(pktio_param)); > + > + switch (mode) { > + case APPL_MODE_PKT_BURST: > + pktio_param.in_mode = ODP_PKTIN_MODE_RECV; > + break; > + case APPL_MODE_PKT_QUEUE: > + pktio_param.in_mode = ODP_PKTIN_MODE_POLL; > + break; > + case APPL_MODE_PKT_SCHED: > + pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; > + break; > + default: > + EXAMPLE_ABORT("invalid mode %d\n", mode); > + } > > Since you're standardizing terms in this patch series, why not APPL_MODE_PKT_RECV to pair with ODP_PKTIN_MODE_RECV, etc.? Having BURST ==> RECV and QUEUE ==> POLL seems non-intuitive. > /* Open a packet IO instance */ > - pktio = odp_pktio_open(dev, pool); > + pktio = odp_pktio_open(dev, pool, &pktio_param); > if (pktio == ODP_PKTIO_INVALID) > EXAMPLE_ABORT("Error: pktio create failed for %s\n", dev); > > diff --git a/include/odp/api/packet_io.h b/include/odp/api/packet_io.h > index 8f10863..d34041c 100644 > --- a/include/odp/api/packet_io.h > +++ b/include/odp/api/packet_io.h > @@ -44,6 +44,27 @@ extern "C" { > * Actual MAC address sizes may be different. > */ > > + > +/** > + * Packet input mode > + */ > +enum odp_pktio_input_mode { > + /** Application polls packet input directly with odp_pktio_recv() > */ > + ODP_PKTIN_MODE_RECV = 0, > + /** Packet input through scheduled queues */ > + ODP_PKTIN_MODE_SCHED, > + /** Application polls packet input queues */ > + ODP_PKTIN_MODE_POLL > +}; > + > +/** > + * Packet IO parameters > + */ > +typedef struct odp_pktio_param_t { > + /** Packet input mode */ > + enum odp_pktio_input_mode in_mode; > +} odp_pktio_param_t; > + > /** > * Open a packet IO interface > * > @@ -52,9 +73,13 @@ extern "C" { > * errno set. Use odp_pktio_lookup() to obtain a handle to an already open > * device. > * > + * Packet IO parameters provide interface level configuration options. > + * In minimum, user must select the input mode. Use 0 for defaults. > + * > * @param dev Packet IO device name > * @param pool Pool from which to allocate buffers for storing packets > * received over this packet IO > + * @param param Packet IO parameters > * > * @return Packet IO handle > * @retval ODP_PKTIO_INVALID on failure > @@ -63,7 +88,8 @@ extern "C" { > * device used for testing. Usually it's loop back > * interface. > */ > -odp_pktio_t odp_pktio_open(const char *dev, odp_pool_t pool); > +odp_pktio_t odp_pktio_open(const char *dev, odp_pool_t pool, > + const odp_pktio_param_t *param); > > /** > * Close a packet IO interface > diff --git a/platform/linux-generic/include/odp_packet_io_internal.h > b/platform/linux-generic/include/odp_packet_io_internal.h > index 47b8992..116b4d9 100644 > --- a/platform/linux-generic/include/odp_packet_io_internal.h > +++ b/platform/linux-generic/include/odp_packet_io_internal.h > @@ -50,6 +50,7 @@ struct pktio_entry { > char name[IFNAMSIZ]; /**< name of pktio provided to > pktio_open() */ > odp_bool_t promisc; /**< promiscuous mode state */ > + odp_pktio_param_t param; > }; > > typedef union { > diff --git a/platform/linux-generic/odp_packet_io.c > b/platform/linux-generic/odp_packet_io.c > index 21f0c17..a14c9df 100644 > --- a/platform/linux-generic/odp_packet_io.c > +++ b/platform/linux-generic/odp_packet_io.c > @@ -234,7 +234,8 @@ static int init_loop(pktio_entry_t *entry, odp_pktio_t > id) > return 0; > } > > -static odp_pktio_t setup_pktio_entry(const char *dev, odp_pool_t pool) > +static odp_pktio_t setup_pktio_entry(const char *dev, odp_pool_t pool, > + const odp_pktio_param_t *param) > { > odp_pktio_t id; > pktio_entry_t *pktio_entry; > @@ -258,6 +259,8 @@ static odp_pktio_t setup_pktio_entry(const char *dev, > odp_pool_t pool) > if (!pktio_entry) > return ODP_PKTIO_INVALID; > > + memcpy(&pktio_entry->s.param, param, sizeof(odp_pktio_param_t)); > + > if (strcmp(dev, "loop") == 0) > ret = init_loop(pktio_entry, id); > else > @@ -276,7 +279,8 @@ static odp_pktio_t setup_pktio_entry(const char *dev, > odp_pool_t pool) > return id; > } > > -odp_pktio_t odp_pktio_open(const char *dev, odp_pool_t pool) > +odp_pktio_t odp_pktio_open(const char *dev, odp_pool_t pool, > + const odp_pktio_param_t *param) > { > odp_pktio_t id; > > @@ -288,7 +292,7 @@ odp_pktio_t odp_pktio_open(const char *dev, odp_pool_t > pool) > } > > odp_spinlock_lock(&pktio_tbl->lock); > - id = setup_pktio_entry(dev, pool); > + id = setup_pktio_entry(dev, pool, param); > odp_spinlock_unlock(&pktio_tbl->lock); > > return id; > diff --git a/test/validation/classification/odp_classification_tests.c > b/test/validation/classification/odp_classification_tests.c > index 0530f99..7dcc447 100644 > --- a/test/validation/classification/odp_classification_tests.c > +++ b/test/validation/classification/odp_classification_tests.c > @@ -275,6 +275,7 @@ int classification_tests_init(void) > char queuename[ODP_QUEUE_NAME_LEN]; > int i; > int ret; > + odp_pktio_param_t pktio_param; > > memset(¶m, 0, sizeof(param)); > param.pkt.seg_len = SHM_PKT_BUF_SIZE; > @@ -293,7 +294,10 @@ int classification_tests_init(void) > if (pool_default == ODP_POOL_INVALID) > return -1; > > - pktio_loop = odp_pktio_open("loop", pool_default); > + memset(&pktio_param, 0, sizeof(pktio_param)); > + pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; > + > + pktio_loop = odp_pktio_open("loop", pool_default, &pktio_param); > if (pktio_loop == ODP_PKTIO_INVALID) { > ret = odp_pool_destroy(pool_default); > if (ret) > diff --git a/test/validation/odp_pktio.c b/test/validation/odp_pktio.c > index e022c33..4eeac7c 100644 > --- a/test/validation/odp_pktio.c > +++ b/test/validation/odp_pktio.c > @@ -236,12 +236,13 @@ static int default_pool_create(void) > return 0; > } > > -static odp_pktio_t create_pktio(const char *iface) > +static odp_pktio_t create_pktio(const char *iface, odp_queue_type_t > q_type) > { > odp_pool_t pool; > odp_pktio_t pktio; > char pool_name[ODP_POOL_NAME_LEN]; > odp_pool_param_t params; > + odp_pktio_param_t pktio_param; > > memset(¶ms, 0, sizeof(params)); > if (test_jumbo) { > @@ -264,7 +265,14 @@ static odp_pktio_t create_pktio(const char *iface) > pool = odp_pool_create(pool_name, ODP_SHM_NULL, ¶ms); > CU_ASSERT(pool != ODP_POOL_INVALID); > > - pktio = odp_pktio_open(iface, pool); > + memset(&pktio_param, 0, sizeof(pktio_param)); > + > + if (q_type == ODP_QUEUE_TYPE_POLL) > + pktio_param.in_mode = ODP_PKTIN_MODE_POLL; > + else > + pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; > + > + pktio = odp_pktio_open(iface, pool, &pktio_param); > if (pktio == ODP_PKTIO_INVALID) > pktio = odp_pktio_lookup(iface); > CU_ASSERT(pktio != ODP_PKTIO_INVALID); > @@ -452,7 +460,7 @@ static void pktio_test_txrx(odp_queue_type_t q_type, > int num_pkts) > io = &pktios[i]; > > io->name = iface_name[i]; > - io->id = create_pktio(iface_name[i]); > + io->id = create_pktio(iface_name[i], q_type); > if (io->id == ODP_PKTIO_INVALID) { > CU_FAIL("failed to open iface"); > return; > @@ -508,7 +516,7 @@ static void test_odp_pktio_mtu(void) > { > int ret; > int mtu; > - odp_pktio_t pktio = create_pktio(iface_name[0]); > + odp_pktio_t pktio = create_pktio(iface_name[0], > ODP_QUEUE_TYPE_SCHED); > > mtu = odp_pktio_mtu(pktio); > CU_ASSERT(mtu > 0); > @@ -524,7 +532,7 @@ static void test_odp_pktio_mtu(void) > static void test_odp_pktio_promisc(void) > { > int ret; > - odp_pktio_t pktio = create_pktio(iface_name[0]); > + odp_pktio_t pktio = create_pktio(iface_name[0], > ODP_QUEUE_TYPE_SCHED); > > ret = odp_pktio_promisc_mode_set(pktio, 1); > CU_ASSERT(0 == ret); > @@ -551,7 +559,7 @@ static void test_odp_pktio_mac(void) > unsigned char mac_addr[ODPH_ETHADDR_LEN]; > int mac_len; > int ret; > - odp_pktio_t pktio = create_pktio(iface_name[0]); > + odp_pktio_t pktio = create_pktio(iface_name[0], > ODP_QUEUE_TYPE_SCHED); > > printf("testing mac for %s\n", iface_name[0]); > > @@ -574,7 +582,7 @@ static void test_odp_pktio_mac(void) > > static void test_odp_pktio_inq_remdef(void) > { > - odp_pktio_t pktio = create_pktio(iface_name[0]); > + odp_pktio_t pktio = create_pktio(iface_name[0], > ODP_QUEUE_TYPE_SCHED); > odp_queue_t inq; > odp_event_t ev; > int i; > @@ -599,29 +607,38 @@ static void test_odp_pktio_inq_remdef(void) > static void test_odp_pktio_open(void) > { > odp_pktio_t pktio; > + odp_pktio_param_t pktio_param; > int i; > > /* test the sequence open->close->open->close() */ > for (i = 0; i < 2; ++i) { > - pktio = create_pktio(iface_name[0]); > + pktio = create_pktio(iface_name[0], ODP_QUEUE_TYPE_SCHED); > CU_ASSERT(pktio != ODP_PKTIO_INVALID); > CU_ASSERT(odp_pktio_close(pktio) == 0); > } > > - pktio = odp_pktio_open("nothere", default_pkt_pool); > + memset(&pktio_param, 0, sizeof(pktio_param)); > + pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; > + > + pktio = odp_pktio_open("nothere", default_pkt_pool, &pktio_param); > CU_ASSERT(pktio == ODP_PKTIO_INVALID); > } > > static void test_odp_pktio_lookup(void) > { > odp_pktio_t pktio, pktio_inval; > + odp_pktio_param_t pktio_param; > > - pktio = odp_pktio_open(iface_name[0], default_pkt_pool); > + memset(&pktio_param, 0, sizeof(pktio_param)); > + pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; > + > + pktio = odp_pktio_open(iface_name[0], default_pkt_pool, > &pktio_param); > CU_ASSERT(pktio != ODP_PKTIO_INVALID); > > CU_ASSERT(odp_pktio_lookup(iface_name[0]) == pktio); > > - pktio_inval = odp_pktio_open(iface_name[0], default_pkt_pool); > + pktio_inval = odp_pktio_open(iface_name[0], default_pkt_pool, > + &pktio_param); > CU_ASSERT(odp_errno() != 0); > CU_ASSERT(pktio_inval == ODP_PKTIO_INVALID); > > @@ -634,7 +651,7 @@ static void test_odp_pktio_inq(void) > { > odp_pktio_t pktio; > > - pktio = create_pktio(iface_name[0]); > + pktio = create_pktio(iface_name[0], ODP_QUEUE_TYPE_SCHED); > CU_ASSERT(pktio != ODP_PKTIO_INVALID); > > CU_ASSERT(create_inq(pktio) == 0); > -- > 2.3.4 > > _______________________________________________ > lng-odp mailing list > lng-odp@lists.linaro.org > https://lists.linaro.org/mailman/listinfo/lng-odp >
_______________________________________________ lng-odp mailing list lng-odp@lists.linaro.org https://lists.linaro.org/mailman/listinfo/lng-odp