Searched refs:workers (Results 1 - 9 of 9) sorted by relevance
| /freebsd-11-stable/tools/regression/gaithrstress/ |
| H A D | gaithrstress.c | 189 struct worker *workers; local
234 workers = calloc(nworkers, sizeof(*workers));
235 if (workers == NULL)
236 err(1, "allocating workers");
243 if (pthread_create(&workers[i].w_thread, NULL, work,
244 &workers[i]) != 0)
257 pthread_join(workers[i].w_thread, NULL);
268 workers[i].w_lookup_success, workers[
[all...] |
| /freebsd-11-stable/contrib/unbound/daemon/ |
| H A D | daemon.c | 2 * daemon/daemon.c - collection of workers that handles requests.
39 * The daemon consists of global settings and a number of workers.
467 daemon->workers = (struct worker**)calloc((size_t)daemon->num,
469 if(!daemon->workers)
481 if(!(daemon->workers[i] = worker_create(daemon, i,
503 tube_close_read(daemon->workers[i]->cmd);
506 tube_delete(daemon->workers[i]->cmd);
507 daemon->workers[i]->cmd = NULL;
556 ub_thread_create(&daemon->workers[i]->thr_id,
557 thread_start, daemon->workers[
[all...] |
| H A D | daemon.h | 2 * daemon/daemon.h - collection of workers that handles requests.
39 * The daemon consists of global settings and a number of workers.
103 struct worker** workers; member in struct:daemon
158 * Fork workers and start service.
172 * Delete workers, close listening ports.
|
| H A D | stats.c | 396 if(!tube_write_msg(worker->daemon->workers[0]->cmd,
|
| H A D | remote.c | 1099 server_stats_obtain(worker, daemon->workers[i], &s, reset);
2923 worker_send_cmd(rc->worker->daemon->workers[i],
2925 if(!tube_write_msg(rc->worker->daemon->workers[i]->cmd,
|
| /freebsd-11-stable/contrib/ntp/lib/isc/include/isc/ |
| H A D | task.h | 657 unsigned int workers, unsigned int default_quantum,
660 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers,
668 *\li 'workers' in the number of worker threads to create. In general,
670 * The 'workers' value is advisory only. An attempt will be made to
671 * create 'workers' threads, but if at least one thread creation
682 *\li workers > 0
773 (*isc_taskmgrcreatefunc_t)(isc_mem_t *mctx, unsigned int workers,
|
| /freebsd-11-stable/contrib/ntp/lib/isc/ |
| H A D | task_api.c | 57 unsigned int workers, unsigned int default_quantum,
65 result = (*taskmgr_createfunc)(mctx, workers, default_quantum,
77 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers, argument
85 result = (*taskmgr_createfunc)(mctx, workers, default_quantum,
56 isc_taskmgr_createinctx(isc_mem_t *mctx, isc_appctx_t *actx, unsigned int workers, unsigned int default_quantum, isc_taskmgr_t **managerp) argument
|
| H A D | task.c | 141 unsigned int workers; member in struct:isc__taskmgr
224 isc__taskmgr_create(isc_mem_t *mctx, unsigned int workers,
1321 isc__taskmgr_create(isc_mem_t *mctx, unsigned int workers, argument
1332 REQUIRE(workers > 0);
1364 manager->workers = 0;
1366 workers * sizeof(isc_thread_t));
1411 * Start workers.
1413 for (i = 0; i < workers; i++) {
1415 &manager->threads[manager->workers]) ==
1417 manager->workers
[all...] |
| /freebsd-11-stable/contrib/llvm-project/compiler-rt/lib/fuzzer/ |
| H A D | FuzzerDriver.cpp | 262 Cmd.removeFlag("workers");
637 if (Flags.jobs > 0 && Flags.workers == 0) {
638 Flags.workers = std::min(NumberOfCpuCores() / 2, Flags.jobs);
639 if (Flags.workers > 1)
640 Printf("Running %u workers\n", Flags.workers);
643 if (Flags.workers > 0 && Flags.jobs > 0)
644 return RunInMultipleProcesses(Args, Flags.workers, Flags.jobs);
|
Completed in 93 milliseconds