Aligned pktin and pktout modes with renamed queue types in the following way:
ODP_PKTIN_MODE_RECV to ODP_PKTIN_MODE_DIRECT ODP_PKTIN_MODE_POLL to ODP_PKTIN_MODE_QUEUE ODP_PKTIN_MODE_SCHED was not renamed ODP_PKTOUT_MODE_SEND to ODP_PKTOUT_MODE_DIRECT Direct pktio modes (_RECV/_SEND) are renamed to _DIRECT, which is future proof to support additional direct calls for packet input/output. Signed-off-by: Petri Savolainen <[email protected]> --- example/ipsec/odp_ipsec.c | 2 +- example/packet/odp_pktio.c | 4 +- include/odp/api/packet_io.h | 26 ++++----- platform/linux-generic/odp_packet_io.c | 12 ++--- platform/linux-generic/pktio/netmap.c | 3 +- test/performance/odp_l2fwd.c | 10 ++-- test/performance/odp_pktio_perf.c | 2 +- .../classification/odp_classification_test_pmr.c | 3 +- test/validation/pktio/pktio.c | 62 +++++++++++----------- 9 files changed, 63 insertions(+), 61 deletions(-) diff --git a/example/ipsec/odp_ipsec.c b/example/ipsec/odp_ipsec.c index 938fe7d..a038dda 100644 --- a/example/ipsec/odp_ipsec.c +++ b/example/ipsec/odp_ipsec.c @@ -501,7 +501,7 @@ void initialize_intf(char *intf) odp_pktio_param_init(&pktio_param); if (getenv("ODP_IPSEC_USE_POLL_QUEUES")) - pktio_param.in_mode = ODP_PKTIN_MODE_POLL; + pktio_param.in_mode = ODP_PKTIN_MODE_QUEUE; else pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; diff --git a/example/packet/odp_pktio.c b/example/packet/odp_pktio.c index 13f044f..135caf3 100644 --- a/example/packet/odp_pktio.c +++ b/example/packet/odp_pktio.c @@ -122,10 +122,10 @@ static odp_pktio_t create_pktio(const char *dev, odp_pool_t pool, int mode) switch (mode) { case APPL_MODE_PKT_BURST: - pktio_param.in_mode = ODP_PKTIN_MODE_RECV; + pktio_param.in_mode = ODP_PKTIN_MODE_DIRECT; break; case APPL_MODE_PKT_QUEUE: - pktio_param.in_mode = ODP_PKTIN_MODE_POLL; + pktio_param.in_mode = ODP_PKTIN_MODE_QUEUE; break; case APPL_MODE_PKT_SCHED: pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; diff --git a/include/odp/api/packet_io.h b/include/odp/api/packet_io.h index 4971108..c2176c7 100644 --- a/include/odp/api/packet_io.h +++ b/include/odp/api/packet_io.h @@ -68,12 +68,12 @@ extern "C" { * Packet input mode */ typedef enum odp_pktio_input_mode_t { - /** Application polls packet input directly with odp_pktio_recv() */ - ODP_PKTIN_MODE_RECV = 0, - /** Packet input through scheduled queues */ + /** Direct packet input from the interface */ + ODP_PKTIN_MODE_DIRECT = 0, + /** Packet input through scheduler and scheduled queues */ ODP_PKTIN_MODE_SCHED, - /** Application polls packet input queues */ - ODP_PKTIN_MODE_POLL, + /** Packet input through plain queues */ + ODP_PKTIN_MODE_QUEUE, /** Application will never receive from this interface */ ODP_PKTIN_MODE_DISABLED } odp_pktio_input_mode_t; @@ -82,8 +82,8 @@ typedef enum odp_pktio_input_mode_t { * Packet output mode */ typedef enum odp_pktio_output_mode_t { - /** Direct packet output on the interface with odp_pktio_send() */ - ODP_PKTOUT_MODE_SEND = 0, + /** Direct packet output on the interface */ + ODP_PKTOUT_MODE_DIRECT = 0, /** Packet output through traffic manager API */ ODP_PKTOUT_MODE_TM, /** Application will never send to this interface */ @@ -143,7 +143,7 @@ typedef struct odp_pktio_input_queue_param_t { * input mode. */ unsigned num_queues; - /** Queue parameters for creating input queues in ODP_PKTIN_MODE_POLL + /** Queue parameters for creating input queues in ODP_PKTIN_MODE_QUEUE * or ODP_PKTIN_MODE_SCHED modes. Scheduler parameters are considered * only in ODP_PKTIN_MODE_SCHED mode. */ odp_queue_param_t queue_param; @@ -153,7 +153,7 @@ typedef struct odp_pktio_input_queue_param_t { /** * Packet output queue parameters * - * These parameters are used only in ODP_PKTOUT_MODE_SEND mode. + * These parameters are used only in ODP_PKTOUT_MODE_DIRECT mode. */ typedef struct odp_pktio_output_queue_param_t { /** Single thread per queue. Enable performance optimization when each @@ -287,8 +287,8 @@ int odp_pktio_output_queues_config(odp_pktio_t pktio, * Queues for packet input * * Returns the number of input queues configured for the interface in - * ODP_PKTIN_MODE_POLL and ODP_PKTIN_MODE_SCHED modes. Outputs up to 'num' queue - * handles when the 'queues' array pointer is not NULL. If return value is + * ODP_PKTIN_MODE_QUEUE and ODP_PKTIN_MODE_SCHED modes. Outputs up to 'num' + * queue handles when the 'queues' array pointer is not NULL. If return value is * larger than 'num', there are more queues than the function was allowed to * output. If return value (N) is less than 'num', only queues[0 ... N-1] have * been written. @@ -309,7 +309,7 @@ int odp_pktio_in_queues(odp_pktio_t pktio, odp_queue_t queues[], int num); * Direct packet input queues * * Returns the number of input queues configured for the interface in - * ODP_PKTIN_MODE_RECV mode. Outputs up to 'num' queue handles when the + * ODP_PKTIN_MODE_DIRECT mode. Outputs up to 'num' queue handles when the * 'queues' array pointer is not NULL. If return value is larger than 'num', * there are more queues than the function was allowed to output. If return * value (N) is less than 'num', only queues[0 ... N-1] have been written. @@ -330,7 +330,7 @@ int odp_pktio_pktin_queues(odp_pktio_t pktio, odp_pktin_queue_t queues[], * Direct packet output queues * * Returns the number of output queues configured for the interface in - * ODP_PKTOUT_MODE_SEND mode. Outputs up to 'num' queue handles when the + * ODP_PKTOUT_MODE_DIRECT mode. Outputs up to 'num' queue handles when the * 'queues' array pointer is not NULL. If return value is larger than 'num', * there are more queues than the function was allowed to output. If return * value (N) is less than 'num', only queues[0 ... N-1] have been written. diff --git a/platform/linux-generic/odp_packet_io.c b/platform/linux-generic/odp_packet_io.c index 49ee08c..1b42f81 100644 --- a/platform/linux-generic/odp_packet_io.c +++ b/platform/linux-generic/odp_packet_io.c @@ -1086,7 +1086,7 @@ int odp_pktio_input_queues_config(odp_pktio_t pktio, destroy_in_queues(entry, entry->s.num_in_queue); for (i = 0; i < num_queues; i++) { - if (mode == ODP_PKTIN_MODE_POLL || + if (mode == ODP_PKTIN_MODE_QUEUE || mode == ODP_PKTIN_MODE_SCHED) { odp_queue_type_t type = ODP_QUEUE_TYPE_PLAIN; @@ -1104,7 +1104,7 @@ int odp_pktio_input_queues_config(odp_pktio_t pktio, return -1; } - if (mode == ODP_PKTIN_MODE_POLL) { + if (mode == ODP_PKTIN_MODE_QUEUE) { queue_entry_t *qentry; qentry = queue_to_qentry(queue); @@ -1166,7 +1166,7 @@ int odp_pktio_output_queues_config(odp_pktio_t pktio, return -1; } - if (mode != ODP_PKTOUT_MODE_SEND) { + if (mode != ODP_PKTOUT_MODE_DIRECT) { ODP_DBG("pktio %s: bad packet output mode\n", entry->s.name); return -1; } @@ -1211,7 +1211,7 @@ int odp_pktio_in_queues(odp_pktio_t pktio, odp_queue_t queues[], int num) mode = entry->s.param.in_mode; - if (mode != ODP_PKTIN_MODE_POLL && + if (mode != ODP_PKTIN_MODE_QUEUE && mode != ODP_PKTIN_MODE_SCHED) return -1; @@ -1235,7 +1235,7 @@ int odp_pktio_pktin_queues(odp_pktio_t pktio, odp_pktin_queue_t queues[], mode = entry->s.param.in_mode; - if (mode != ODP_PKTIN_MODE_RECV) + if (mode != ODP_PKTIN_MODE_DIRECT) return -1; if (entry->s.ops->pktin_queues) @@ -1258,7 +1258,7 @@ int odp_pktio_pktout_queues(odp_pktio_t pktio, odp_pktout_queue_t queues[], mode = entry->s.param.out_mode; - if (mode != ODP_PKTOUT_MODE_SEND) + if (mode != ODP_PKTOUT_MODE_DIRECT) return -1; if (entry->s.ops->pktout_queues) diff --git a/platform/linux-generic/pktio/netmap.c b/platform/linux-generic/pktio/netmap.c index 16898ec..e406f69 100644 --- a/platform/linux-generic/pktio/netmap.c +++ b/platform/linux-generic/pktio/netmap.c @@ -392,7 +392,8 @@ static int netmap_start(pktio_entry_t *pktio_entry) ¶m)) return -1; } - if (!pktio_entry->s.num_out_queue && out_mode == ODP_PKTOUT_MODE_SEND) { + if (!pktio_entry->s.num_out_queue && + out_mode == ODP_PKTOUT_MODE_DIRECT) { odp_pktio_output_queue_param_t param; odp_pktio_output_queue_param_init(¶m); diff --git a/test/performance/odp_l2fwd.c b/test/performance/odp_l2fwd.c index 3179cd3..a9e2777 100644 --- a/test/performance/odp_l2fwd.c +++ b/test/performance/odp_l2fwd.c @@ -539,14 +539,14 @@ static int create_pktio(const char *dev, int idx, int num_rx, int num_tx, odp_pktio_param_init(&pktio_param); if (gbl_args->appl.mode == DIRECT_RECV) { - pktio_param.in_mode = ODP_PKTIN_MODE_RECV; - pktio_param.out_mode = ODP_PKTOUT_MODE_SEND; + pktio_param.in_mode = ODP_PKTIN_MODE_DIRECT; + pktio_param.out_mode = ODP_PKTOUT_MODE_DIRECT; } else if (gbl_args->appl.mode == POLL_QUEUE) { - pktio_param.in_mode = ODP_PKTIN_MODE_POLL; - pktio_param.out_mode = ODP_PKTOUT_MODE_SEND; + pktio_param.in_mode = ODP_PKTIN_MODE_QUEUE; + pktio_param.out_mode = ODP_PKTOUT_MODE_DIRECT; } else { pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; - pktio_param.out_mode = ODP_PKTOUT_MODE_SEND; + pktio_param.out_mode = ODP_PKTOUT_MODE_DIRECT; } pktio = odp_pktio_open(dev, pool, &pktio_param); diff --git a/test/performance/odp_pktio_perf.c b/test/performance/odp_pktio_perf.c index 8fb9977..59ddb98 100644 --- a/test/performance/odp_pktio_perf.c +++ b/test/performance/odp_pktio_perf.c @@ -712,7 +712,7 @@ static odp_pktio_t create_pktio(const char *iface, int schedule) if (schedule) pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; else - pktio_param.in_mode = ODP_PKTIN_MODE_POLL; + pktio_param.in_mode = ODP_PKTIN_MODE_QUEUE; pktio = odp_pktio_open(iface, pool, &pktio_param); diff --git a/test/validation/classification/odp_classification_test_pmr.c b/test/validation/classification/odp_classification_test_pmr.c index 2323497..7edfd90 100644 --- a/test/validation/classification/odp_classification_test_pmr.c +++ b/test/validation/classification/odp_classification_test_pmr.c @@ -39,8 +39,9 @@ odp_pktio_t create_pktio(odp_queue_type_t q_type) return ODP_PKTIO_INVALID; odp_pktio_param_init(&pktio_param); + if (q_type == ODP_QUEUE_TYPE_PLAIN) - pktio_param.in_mode = ODP_PKTIN_MODE_POLL; + pktio_param.in_mode = ODP_PKTIN_MODE_QUEUE; else pktio_param.in_mode = ODP_PKTIN_MODE_SCHED; diff --git a/test/validation/pktio/pktio.c b/test/validation/pktio/pktio.c index 5ad4024..7a9cf0a 100644 --- a/test/validation/pktio/pktio.c +++ b/test/validation/pktio/pktio.c @@ -380,11 +380,11 @@ static int get_packets(pktio_info_t *pktio_rx, odp_packet_t pkt_tbl[], int num_pkts = 0; int i; - if (pktio_rx->in_mode == ODP_PKTIN_MODE_RECV) + if (pktio_rx->in_mode == ODP_PKTIN_MODE_DIRECT) return odp_pktio_recv(pktio_rx->id, pkt_tbl, num); if (mode == TXRX_MODE_MULTI) { - if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) + if (pktio_rx->in_mode == ODP_PKTIN_MODE_QUEUE) num_evts = odp_queue_deq_multi(pktio_rx->inq, evt_tbl, num); else @@ -393,7 +393,7 @@ static int get_packets(pktio_info_t *pktio_rx, odp_packet_t pkt_tbl[], } else { odp_event_t evt_tmp; - if (pktio_rx->in_mode == ODP_PKTIN_MODE_POLL) + if (pktio_rx->in_mode == ODP_PKTIN_MODE_QUEUE) evt_tmp = odp_queue_deq(pktio_rx->inq); else evt_tmp = odp_schedule(NULL, ODP_SCHED_NO_WAIT); @@ -523,7 +523,7 @@ static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts, io = &pktios[i]; io->name = iface_name[i]; - io->id = create_pktio(i, in_mode, ODP_PKTOUT_MODE_SEND); + io->id = create_pktio(i, in_mode, ODP_PKTOUT_MODE_DIRECT); if (io->id == ODP_PKTIO_INVALID) { CU_FAIL("failed to open iface"); return; @@ -531,7 +531,7 @@ static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts, io->outq = odp_pktio_outq_getdef(io->id); io->in_mode = in_mode; - if (in_mode == ODP_PKTIN_MODE_POLL) { + if (in_mode == ODP_PKTIN_MODE_QUEUE) { create_inq(io->id, ODP_QUEUE_TYPE_PLAIN); io->inq = odp_pktio_inq_getdef(io->id); } else if (in_mode == ODP_PKTIN_MODE_SCHED) { @@ -553,7 +553,7 @@ static void test_txrx(odp_pktio_input_mode_t in_mode, int num_pkts, for (i = 0; i < num_ifaces; ++i) { ret = odp_pktio_stop(pktios[i].id); CU_ASSERT(ret == 0); - if (in_mode != ODP_PKTIN_MODE_RECV) + if (in_mode != ODP_PKTIN_MODE_DIRECT) destroy_inq(pktios[i].id); ret = odp_pktio_close(pktios[i].id); CU_ASSERT(ret == 0); @@ -562,14 +562,14 @@ 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, TXRX_MODE_SINGLE); - test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN, TXRX_MODE_SINGLE); + test_txrx(ODP_PKTIN_MODE_QUEUE, 1, TXRX_MODE_SINGLE); + test_txrx(ODP_PKTIN_MODE_QUEUE, TX_BATCH_LEN, TXRX_MODE_SINGLE); } void pktio_test_poll_multi(void) { - test_txrx(ODP_PKTIN_MODE_POLL, TX_BATCH_LEN, TXRX_MODE_MULTI); - test_txrx(ODP_PKTIN_MODE_POLL, 1, TXRX_MODE_MULTI); + test_txrx(ODP_PKTIN_MODE_QUEUE, TX_BATCH_LEN, TXRX_MODE_MULTI); + test_txrx(ODP_PKTIN_MODE_QUEUE, 1, TXRX_MODE_MULTI); } void pktio_test_sched_queue(void) @@ -586,12 +586,12 @@ void pktio_test_sched_multi(void) void pktio_test_recv(void) { - test_txrx(ODP_PKTIN_MODE_RECV, 1, TXRX_MODE_SINGLE); + test_txrx(ODP_PKTIN_MODE_DIRECT, 1, TXRX_MODE_SINGLE); } void pktio_test_recv_multi(void) { - test_txrx(ODP_PKTIN_MODE_RECV, TX_BATCH_LEN, TXRX_MODE_MULTI); + test_txrx(ODP_PKTIN_MODE_DIRECT, TX_BATCH_LEN, TXRX_MODE_MULTI); } void pktio_test_jumbo(void) @@ -607,7 +607,7 @@ void pktio_test_mtu(void) int mtu; odp_pktio_t pktio = create_pktio(0, ODP_PKTIN_MODE_SCHED, - ODP_PKTOUT_MODE_SEND); + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); mtu = odp_pktio_mtu(pktio); @@ -624,7 +624,7 @@ void pktio_test_promisc(void) int ret; odp_pktio_t pktio = create_pktio(0, ODP_PKTIN_MODE_SCHED, - ODP_PKTOUT_MODE_SEND); + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); ret = odp_pktio_promisc_mode_set(pktio, 1); @@ -653,7 +653,7 @@ void pktio_test_mac(void) odp_pktio_t pktio; pktio = create_pktio(0, ODP_PKTIN_MODE_SCHED, - ODP_PKTOUT_MODE_SEND); + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); printf("testing mac for %s\n", iface_name[0]); @@ -682,7 +682,7 @@ void pktio_test_inq_remdef(void) int i; pktio = create_pktio(0, ODP_PKTIN_MODE_SCHED, - ODP_PKTOUT_MODE_SEND); + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); CU_ASSERT(create_inq(pktio, ODP_QUEUE_TYPE_PLAIN) == 0); inq = odp_pktio_inq_getdef(pktio); @@ -711,7 +711,7 @@ void pktio_test_open(void) /* test the sequence open->close->open->close() */ for (i = 0; i < 2; ++i) { pktio = create_pktio(0, ODP_PKTIN_MODE_SCHED, - ODP_PKTOUT_MODE_SEND); + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); CU_ASSERT(odp_pktio_close(pktio) == 0); } @@ -752,8 +752,8 @@ static void pktio_test_print(void) int i; for (i = 0; i < num_ifaces; ++i) { - pktio = create_pktio(i, ODP_PKTIN_MODE_POLL, - ODP_PKTOUT_MODE_SEND); + pktio = create_pktio(i, ODP_PKTIN_MODE_QUEUE, + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); /* Print pktio debug info and test that the @@ -768,8 +768,8 @@ void pktio_test_inq(void) { odp_pktio_t pktio; - pktio = create_pktio(0, ODP_PKTIN_MODE_POLL, - ODP_PKTOUT_MODE_SEND); + pktio = create_pktio(0, ODP_PKTIN_MODE_QUEUE, + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio != ODP_PKTIO_INVALID); CU_ASSERT(create_inq(pktio, ODP_QUEUE_TYPE_PLAIN) == 0); @@ -844,7 +844,7 @@ void pktio_test_statistics_counters(void) for (i = 0; i < num_ifaces; i++) { pktio[i] = create_pktio(i, ODP_PKTIN_MODE_SCHED, - ODP_PKTOUT_MODE_SEND); + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio[i] != ODP_PKTIO_INVALID); create_inq(pktio[i], ODP_QUEUE_TYPE_SCHED); @@ -955,7 +955,7 @@ void pktio_test_start_stop(void) for (i = 0; i < num_ifaces; i++) { pktio[i] = create_pktio(i, ODP_PKTIN_MODE_SCHED, - ODP_PKTOUT_MODE_SEND); + ODP_PKTOUT_MODE_DIRECT); CU_ASSERT_FATAL(pktio[i] != ODP_PKTIO_INVALID); create_inq(pktio[i], ODP_QUEUE_TYPE_SCHED); } @@ -1096,7 +1096,7 @@ int pktio_check_send_failure(void) memset(&pktio_param, 0, sizeof(pktio_param)); - pktio_param.in_mode = ODP_PKTIN_MODE_RECV; + pktio_param.in_mode = ODP_PKTIN_MODE_DIRECT; pktio_tx = odp_pktio_open(iface, pool[iface_idx], &pktio_param); if (pktio_tx == ODP_PKTIO_INVALID) { @@ -1123,8 +1123,8 @@ void pktio_test_send_failure(void) int long_pkt_idx = TX_BATCH_LEN / 2; pktio_info_t info_rx; - pktio_tx = create_pktio(0, ODP_PKTIN_MODE_RECV, - ODP_PKTOUT_MODE_SEND); + pktio_tx = create_pktio(0, ODP_PKTIN_MODE_DIRECT, + ODP_PKTOUT_MODE_DIRECT); if (pktio_tx == ODP_PKTIO_INVALID) { CU_FAIL("failed to open pktio"); return; @@ -1149,8 +1149,8 @@ void pktio_test_send_failure(void) CU_ASSERT_FATAL(pkt_pool != ODP_POOL_INVALID); if (num_ifaces > 1) { - pktio_rx = create_pktio(1, ODP_PKTIN_MODE_RECV, - ODP_PKTOUT_MODE_SEND); + pktio_rx = create_pktio(1, ODP_PKTIN_MODE_DIRECT, + ODP_PKTOUT_MODE_DIRECT); ret = odp_pktio_start(pktio_rx); CU_ASSERT_FATAL(ret == 0); @@ -1199,7 +1199,7 @@ void pktio_test_send_failure(void) 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; + info_rx.in_mode = ODP_PKTIN_MODE_DIRECT; i = wait_for_packets(&info_rx, pkt_tbl, pkt_seq, ret, TXRX_MODE_MULTI, ODP_TIME_SEC_IN_NS); @@ -1258,7 +1258,7 @@ void pktio_test_recv_on_wonly(void) int ret; pktio = create_pktio(0, ODP_PKTIN_MODE_DISABLED, - ODP_PKTOUT_MODE_SEND); + ODP_PKTOUT_MODE_DIRECT); if (pktio == ODP_PKTIO_INVALID) { CU_FAIL("failed to open pktio"); @@ -1289,7 +1289,7 @@ void pktio_test_send_on_ronly(void) odp_packet_t pkt; int ret; - pktio = create_pktio(0, ODP_PKTIN_MODE_RECV, + pktio = create_pktio(0, ODP_PKTIN_MODE_DIRECT, ODP_PKTOUT_MODE_DISABLED); if (pktio == ODP_PKTIO_INVALID) { -- 2.6.3 _______________________________________________ lng-odp mailing list [email protected] https://lists.linaro.org/mailman/listinfo/lng-odp
