diff options
Diffstat (limited to 'example/timer/odp_timer_test.c')
| -rw-r--r-- | example/timer/odp_timer_test.c | 23 |
1 files changed, 14 insertions, 9 deletions
diff --git a/example/timer/odp_timer_test.c b/example/timer/odp_timer_test.c index 8bfb99d8f..b10559e6e 100644 --- a/example/timer/odp_timer_test.c +++ b/example/timer/odp_timer_test.c @@ -332,7 +332,9 @@ static int parse_args(int argc, char *argv[], test_args_t *args) int main(int argc, char *argv[]) { odph_helper_options_t helper_options; - odph_odpthread_t thread_tbl[MAX_WORKERS]; + odph_thread_t thread_tbl[MAX_WORKERS]; + odph_thread_common_param_t thr_common; + odph_thread_param_t thr_param; int num_workers; odp_queue_t queue; uint64_t tick, ns; @@ -344,7 +346,6 @@ int main(int argc, char *argv[]) char cpumaskstr[ODP_CPUMASK_STR_SIZE]; odp_instance_t instance; odp_init_t init_param; - odph_odpthread_params_t thr_params; odp_shm_t shm = ODP_SHM_INVALID; test_globals_t *gbls = NULL; int err = 0; @@ -509,16 +510,20 @@ int main(int argc, char *argv[]) odp_barrier_init(&gbls->test_barrier, num_workers); /* Create and launch worker threads */ - memset(&thr_params, 0, sizeof(thr_params)); - thr_params.start = run_thread; - thr_params.arg = gbls; - thr_params.thr_type = ODP_THREAD_WORKER; - thr_params.instance = instance; + odph_thread_common_param_init(&thr_common); + thr_common.instance = instance; + thr_common.cpumask = &cpumask; + thr_common.share_param = 1; - odph_odpthreads_create(thread_tbl, &cpumask, &thr_params); + odph_thread_param_init(&thr_param); + thr_param.start = run_thread; + thr_param.arg = gbls; + thr_param.thr_type = ODP_THREAD_WORKER; + + odph_thread_create(thread_tbl, &thr_common, &thr_param, num_workers); /* Wait for worker threads to exit */ - odph_odpthreads_join(thread_tbl); + odph_thread_join(thread_tbl, num_workers); /* free resources */ if (odp_queue_destroy(queue)) |