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)
304 printinfo("starting worker/consumer %sthreads%s\n",
311 struct worker *w = &worker[i];
356 (void *)(struct worker *) w);
369 struct worker *worker = p;
381 shuffle((void *)worker, nthreads, sizeof(*worker));
385 struct worker *w = &worker[i];
408 struct worker *w1 = (struct worker *) p1;
409 struct worker *w2 = (struct worker *) p2;
418 struct worker *worker = NULL;
458 worker = calloc(nthreads, sizeof(*worker));
459 if (!worker) {
484 do_threads(worker, cpu);
498 (void *)(struct worker *) worker);
519 qsort(worker, nthreads, sizeof(struct worker), cmpworker);
523 worker[i].ops / bench__runtime.tv_sec : 0;
529 worker[i].tid, &worker[i].fdmap[0], t);
532 worker[i].tid, &worker[i].fdmap[0],
533 &worker[i].fdmap[nfds-1], t);