| /freebsd-13-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-13-stable/sbin/dump/ |
| H A D | tape.c | 89 * sends writeheader()'s and lists of daddr's to the workers via pipes.
90 * The following structure defines the instruction packets sent to workers.
110 } workers[WORKERS+1]; variable in typeref:struct:worker
151 workers[i].tblock = (char (*)[TP_BSIZE])
153 workers[i].req = (struct req *)workers[i].tblock - ntrec - 1;
155 wp = &workers[0];
245 if (++wp >= &workers[WORKERS])
246 wp = &workers[0];
266 if (workers[
[all...] |
| /freebsd-13-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-13-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-13-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-13-stable/sys/dev/mlx5/mlx5_en/ |
| H A D | mlx5_en_rl.c | 494 ix = (rlw - priv->rl.workers) %
649 /* ratelimit workers */
788 /* allocate workers array */
789 rl->workers = malloc(sizeof(rl->workers[0]) *
822 struct mlx5e_rl_worker *rlw = rl->workers + j;
879 struct mlx5e_rl_worker *rlw = rl->workers + j;
907 struct mlx5e_rl_worker *rlw = rl->workers + y;
923 struct mlx5e_rl_worker *rlw = rl->workers + y;
970 struct mlx5e_rl_worker *rlw = rl->workers
[all...] |
| H A D | en_rl.h | 159 struct mlx5e_rl_worker *workers; member in struct:mlx5e_rl_priv_data
|
| H A D | mlx5_en_main.c | 917 struct mlx5e_rl_worker *rlw = priv->rl.workers + j;
|
| /freebsd-13-stable/contrib/llvm-project/compiler-rt/lib/fuzzer/ |
| H A D | FuzzerDriver.cpp | 266 Cmd.removeFlag("workers");
635 if (Flags.jobs > 0 && Flags.workers == 0) {
636 Flags.workers = std::min(NumberOfCpuCores() / 2, Flags.jobs);
637 if (Flags.workers > 1)
638 Printf("Running %u workers\n", Flags.workers);
641 if (Flags.workers > 0 && Flags.jobs > 0)
642 return RunInMultipleProcesses(Args, Flags.workers, Flags.jobs);
|