diff options
| author | Bogdan Pricope <bogdan.pricope@linaro.org> | 2018-01-16 16:13:11 +0200 |
|---|---|---|
| committer | Maxim Uvarov <maxim.uvarov@linaro.org> | 2018-02-16 22:55:42 +0300 |
| commit | 9ee8609b86639606217d2f78c52f28e3fe08c782 (patch) | |
| tree | e7701db87271de4672e6112dc02252331c34a24f /example | |
| parent | 569810c52a72c83aced5c5b8adf3eec40f371d90 (diff) | |
example: generator: remove busy wait for direct mode receive
Add timeout to avoid unnecessary loops on low traffic.
Signed-off-by: Bogdan Pricope <bogdan.pricope@linaro.org>
Reviewed-by: Bill Fischofer <bill.fischofer@linaro.org>
Signed-off-by: Maxim Uvarov <maxim.uvarov@linaro.org>
Diffstat (limited to 'example')
| -rw-r--r-- | example/generator/odp_generator.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/example/generator/odp_generator.c b/example/generator/odp_generator.c index f8c787e44..440b6b287 100644 --- a/example/generator/odp_generator.c +++ b/example/generator/odp_generator.c @@ -939,6 +939,7 @@ static int gen_recv_direct_thread(void *arg) odp_packet_t pkts[MAX_RX_BURST]; int pkt_cnt, burst_size; odp_pktin_queue_t pktin; + uint64_t wait = odp_pktin_wait_time(ODP_TIME_SEC_IN_NS); thr = odp_thread_id(); thr_args = (thread_args_t *)arg; @@ -952,8 +953,7 @@ static int gen_recv_direct_thread(void *arg) if (thr_args->stop) break; - pkt_cnt = odp_pktin_recv_tmo(pktin, pkts, burst_size, - ODP_PKTIN_NO_WAIT); + pkt_cnt = odp_pktin_recv_tmo(pktin, pkts, burst_size, wait); if (pkt_cnt > 0) { process_pkts(thr, thr_args, pkts, pkt_cnt); |