Lines Matching refs:worker
9 * epoll instance for N worker threads):
11 * |---> [worker A]
12 * |---> [worker B]
13 * [combined queue] .---> [worker C]
14 * |---> [worker D]
15 * |---> [worker E]
18 * queueing (which refers to one epoll instance per worker). For example,
21 * worker does a limited amount of processing.
23 * [queue A] ---> [worker]
24 * [queue B] ---> [worker]
25 * [queue C] ---> [worker]
26 * [queue D] ---> [worker]
27 * [queue E] ---> [worker]
118 struct worker {
186 struct worker *w = (struct worker *) arg;
240 static void nest_epollfd(struct worker *w)
292 static int do_threads(struct worker *worker, struct perf_cpu_map *cpu)
306 printinfo("starting worker/consumer %sthreads%s\n",
318 struct worker *w = &worker[i];
366 (void *)(struct worker *) w);
382 struct worker *worker = p;
394 shuffle((void *)worker, nthreads, sizeof(*worker));
398 struct worker *w = &worker[i];
421 struct worker *w1 = (struct worker *) p1;
422 struct worker *w2 = (struct worker *) p2;
431 struct worker *worker = NULL;
471 worker = calloc(nthreads, sizeof(*worker));
472 if (!worker) {
497 do_threads(worker, cpu);
511 (void *)(struct worker *) worker);
532 qsort(worker, nthreads, sizeof(struct worker), cmpworker);
536 worker[i].ops / bench__runtime.tv_sec : 0;
542 worker[i].tid, &worker[i].fdmap[0], t);
545 worker[i].tid, &worker[i].fdmap[0],
546 &worker[i].fdmap[nfds-1], t);
554 free(worker[i].fdmap);
556 free(worker);