Lines Matching refs:worker
27 struct worker { struct
35 static struct worker *worker; argument
84 struct worker *w = (struct worker *) arg; in workerfn()
121 static void create_threads(struct worker *w, pthread_attr_t thread_attr, in create_threads()
136 worker[i].tid = i; in create_threads()
139 worker[i].futex = calloc(1, sizeof(u_int32_t)); in create_threads()
140 if (!worker[i].futex) in create_threads()
143 worker[i].futex = &global_futex; in create_threads()
153 if (pthread_create(&w[i].thread, &thread_attr, workerfn, &worker[i])) { in create_threads()
190 worker = calloc(params.nthreads, sizeof(*worker)); in bench_futex_lock_pi()
191 if (!worker) in bench_futex_lock_pi()
209 create_threads(worker, thread_attr, cpu); in bench_futex_lock_pi()
222 ret = pthread_join(worker[i].thread, NULL); in bench_futex_lock_pi()
234 worker[i].ops / bench__runtime.tv_sec : 0; in bench_futex_lock_pi()
239 worker[i].tid, worker[i].futex, t); in bench_futex_lock_pi()
242 zfree(&worker[i].futex); in bench_futex_lock_pi()
247 free(worker); in bench_futex_lock_pi()