| Message ID | 1489490058-24397-1-git-send-email-bogdan.pricope@linaro.org |
|---|---|
| State | Superseded |
| Headers | show |
| Series | None | expand |
On 03/14/17 14:14, Bogdan Pricope wrote: > Signed-off-by: Bogdan Pricope <bogdan.pricope@linaro.org> > --- > example/generator/odp_generator.c | 29 +++++++++++++++++++---------- > 1 file changed, 19 insertions(+), 10 deletions(-) > > diff --git a/example/generator/odp_generator.c b/example/generator/odp_generator.c > index 2d95ba8..e14c62f 100644 > --- a/example/generator/odp_generator.c > +++ b/example/generator/odp_generator.c > @@ -27,6 +27,7 @@ > #define POOL_PKT_LEN 1856 /* Max packet length */ > #define DEFAULT_PKT_INTERVAL 1000 /* Interval between each packet */ > #define MAX_UDP_TX_BURST 32 > +#define MAX_RX_BURST 32 > > #define APPL_MODE_UDP 0 /**< UDP mode */ > #define APPL_MODE_PING 1 /**< ping mode */ > @@ -638,8 +639,9 @@ static int gen_recv_thread(void *arg) > int thr; > odp_pktio_t pktio; > thread_args_t *thr_args; > - odp_packet_t pkt; > - odp_event_t ev; > + odp_packet_t pkts[MAX_RX_BURST], pkt; > + odp_event_t events[MAX_RX_BURST]; > + int pkt_cnt, ev_cnt, i; > > thr = odp_thread_id(); > thr_args = arg; > @@ -662,18 +664,25 @@ static int gen_recv_thread(void *arg) > } > > /* Use schedule to get buf from any input queue */ > - ev = odp_schedule(NULL, ODP_SCHED_WAIT); > - > - pkt = odp_packet_from_event(ev); > - /* Drop packets with errors */ > - if (odp_unlikely(odp_packet_has_error(pkt))) { > - odp_packet_free(pkt); > + ev_cnt = odp_schedule_multi(NULL, ODP_SCHED_WAIT, > + events, MAX_RX_BURST); > + if (ev_cnt == 0) > continue; > + for (i = 0, pkt_cnt = 0; i < ev_cnt; i++) { > + pkt = odp_packet_from_event(events[i]); > + > + /* Drop packets with errors */ > + if (odp_unlikely(odp_packet_has_error(pkt))) { > + odp_packet_free(pkt); > + continue; > + } > + pkts[pkt_cnt++] = pkt; > } > > - print_pkts(thr, &pkt, 1); > + print_pkts(thr, pkts, pkt_cnt); > > - odp_packet_free(pkt); > + for (i = 0; i < pkt_cnt; i++) > + odp_packet_free(pkts[i]); void odp_packet_free_multi(const odp_packet_t pkt[], int num) > } > > return 0; >
diff --git a/example/generator/odp_generator.c b/example/generator/odp_generator.c index 2d95ba8..e14c62f 100644 --- a/example/generator/odp_generator.c +++ b/example/generator/odp_generator.c @@ -27,6 +27,7 @@ #define POOL_PKT_LEN 1856 /* Max packet length */ #define DEFAULT_PKT_INTERVAL 1000 /* Interval between each packet */ #define MAX_UDP_TX_BURST 32 +#define MAX_RX_BURST 32 #define APPL_MODE_UDP 0 /**< UDP mode */ #define APPL_MODE_PING 1 /**< ping mode */ @@ -638,8 +639,9 @@ static int gen_recv_thread(void *arg) int thr; odp_pktio_t pktio; thread_args_t *thr_args; - odp_packet_t pkt; - odp_event_t ev; + odp_packet_t pkts[MAX_RX_BURST], pkt; + odp_event_t events[MAX_RX_BURST]; + int pkt_cnt, ev_cnt, i; thr = odp_thread_id(); thr_args = arg; @@ -662,18 +664,25 @@ static int gen_recv_thread(void *arg) } /* Use schedule to get buf from any input queue */ - ev = odp_schedule(NULL, ODP_SCHED_WAIT); - - pkt = odp_packet_from_event(ev); - /* Drop packets with errors */ - if (odp_unlikely(odp_packet_has_error(pkt))) { - odp_packet_free(pkt); + ev_cnt = odp_schedule_multi(NULL, ODP_SCHED_WAIT, + events, MAX_RX_BURST); + if (ev_cnt == 0) continue; + for (i = 0, pkt_cnt = 0; i < ev_cnt; i++) { + pkt = odp_packet_from_event(events[i]); + + /* Drop packets with errors */ + if (odp_unlikely(odp_packet_has_error(pkt))) { + odp_packet_free(pkt); + continue; + } + pkts[pkt_cnt++] = pkt; } - print_pkts(thr, &pkt, 1); + print_pkts(thr, pkts, pkt_cnt); - odp_packet_free(pkt); + for (i = 0; i < pkt_cnt; i++) + odp_packet_free(pkts[i]); } return 0;
Signed-off-by: Bogdan Pricope <bogdan.pricope@linaro.org> --- example/generator/odp_generator.c | 29 +++++++++++++++++++---------- 1 file changed, 19 insertions(+), 10 deletions(-) -- 1.9.1