diff mbox

[v3,2/2] example: timer: use ability to indicate that event was lost

Message ID 1437744694-8615-3-git-send-email-ivan.khoronzhuk@linaro.org
State Accepted
Commit 3b09d8928f599c80cae0aa46be8db8ccaf5d800a
Headers show

Commit Message

Ivan Khoronzhuk July 24, 2015, 1:31 p.m. UTC 
In case if for some reason one of the TMOs was lost, the test will
be polling forever in order to take it and delete. It can be used to
indicate that event was lost. Just abort the test if it cannot receive
one of the "last" TMOs for some period.

Signed-off-by: Ivan Khoronzhuk <ivan.khoronzhuk@linaro.org>
---
 example/timer/odp_timer_test.c | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)
diff mbox

Patch

diff --git a/example/timer/odp_timer_test.c b/example/timer/odp_timer_test.c
index 29d32af..ecfc708 100644
--- a/example/timer/odp_timer_test.c
+++ b/example/timer/odp_timer_test.c
@@ -21,6 +21,7 @@ 
 
 #define MAX_WORKERS           32            /**< Max worker threads */
 #define NUM_TMOS              10000         /**< Number of timers */
+#define WAIT_NUM	      10    /**< Max tries to rx last tmo per worker */
 
 
 /** Test arguments */
@@ -112,6 +113,7 @@  static void test_abs_timeouts(int thr, test_globals_t *gbls)
 	uint64_t tick;
 	struct test_timer *ttp;
 	odp_timeout_t tmo;
+	uint32_t num_workers = gbls->num_workers;
 
 	EXAMPLE_DBG("  [%i] test_timeouts\n", thr);
 
@@ -141,6 +143,7 @@  static void test_abs_timeouts(int thr, test_globals_t *gbls)
 	tick = odp_timer_current_tick(gbls->tp);
 
 	while (1) {
+		int wait = 0;
 		odp_event_t ev;
 		odp_timer_set_t rc;
 
@@ -166,6 +169,9 @@  static void test_abs_timeouts(int thr, test_globals_t *gbls)
 			ev = odp_schedule(&queue, sched_tmo);
 			/* Check if odp_schedule() timed out, possibly there
 			 * are no remaining timeouts to receive */
+			if (++wait > WAIT_NUM &&
+			    odp_atomic_load_u32(&gbls->remain) < num_workers)
+				EXAMPLE_ABORT("At least one TMO was lost\n");
 		} while (ev == ODP_EVENT_INVALID &&
 			 (int)odp_atomic_load_u32(&gbls->remain) > 0);
 
@@ -193,7 +199,7 @@  static void test_abs_timeouts(int thr, test_globals_t *gbls)
 		if (!rx_num)
 			EXAMPLE_ABORT("Unexpected timeout received (timer %x, tick %"PRIu64")\n",
 				      ttp->tim, tick);
-		else if (rx_num > gbls->num_workers)
+		else if (rx_num > num_workers)
 			continue;
 
 		odp_timeout_free(odp_timeout_from_event(ttp->ev));