Home
last modified time | relevance | path

Searched refs:workers (Results 1 – 25 of 33) sorted by relevance

12

/freebsd/sbin/dump/
H A Dtape.c103 } workers[WORKERS+1]; variable
144 workers[i].tblock = (char (*)[TP_BSIZE]) in alloctape()
146 workers[i].req = (struct req *)workers[i].tblock - ntrec - 1; in alloctape()
148 wp = &workers[0]; in alloctape()
238 if (++wp >= &workers[WORKERS]) in flushtape()
239 wp = &workers[0]; in flushtape()
259 if (workers[i].sent) { in flushtape()
260 if (atomic_read(workers[i].fd, in flushtape()
266 workers[i].sent = 0; in flushtape()
317 if (workers[f].sent) { in trewind()
[all …]
/freebsd/tools/regression/gaithrstress/
H A Dgaithrstress.c187 struct worker *workers; in main() local
232 workers = calloc(nworkers, sizeof(*workers)); in main()
233 if (workers == NULL) in main()
241 if (pthread_create(&workers[i].w_thread, NULL, work, in main()
242 &workers[i]) != 0) in main()
255 pthread_join(workers[i].w_thread, NULL); in main()
266 workers[i].w_lookup_success, workers[i].w_lookup_failure, in main()
267 workers[i].w_max_lookup_time.tv_sec / 60, in main()
268 workers[i].w_max_lookup_time.tv_sec % 60 < 10 ? "0" : "", in main()
269 (double)(workers[i].w_max_lookup_time.tv_sec % 60) + in main()
[all …]
/freebsd/contrib/unbound/daemon/
H A Ddaemon.c849 daemon->workers = (struct worker**)calloc((size_t)daemon->num, in daemon_create_workers()
851 if(!daemon->workers) in daemon_create_workers()
863 if(!(daemon->workers[i] = worker_create(daemon, i))) in daemon_create_workers()
897 tube_close_read(daemon->workers[i]->cmd); in close_other_pipes()
900 tube_delete(daemon->workers[i]->cmd); in close_other_pipes()
901 daemon->workers[i]->cmd = NULL; in close_other_pipes()
978 ub_thread_create(&daemon->workers[i]->thr_id, in daemon_start_others()
979 thread_start, daemon->workers[i]); in daemon_start_others()
982 tube_close_read(daemon->workers[i]->cmd); in daemon_start_others()
1000 worker_send_cmd(daemon->workers[i], worker_cmd_quit); in daemon_stop_others()
[all …]
H A Ddaemon.h130 struct worker** workers; member
H A Dstats.c456 if(!tube_write_msg(worker->daemon->workers[0]->cmd, in server_stats_reply()
H A Dremote.c706 worker_send_cmd(rc->worker->daemon->workers[i], in distribute_cmd()
708 if(!tube_write_msg(rc->worker->daemon->workers[i]->cmd, in distribute_cmd()
1253 server_stats_obtain(worker, daemon->workers[i], &s, reset); in do_stats()
8213 worker_send_cmd(daemon->workers[i], worker_cmd_reload_stop); in fr_main_perform_reload_stop()
8229 worker_send_cmd(daemon->workers[i], worker_cmd_reload_start); in fr_main_perform_reload_stop()
8263 worker_send_cmd(daemon->workers[i], worker_cmd_reload_poll); in fr_main_perform_reload_nopause_poll()
/freebsd/crypto/openssl/test/
H A Dlhash_test.c499 static thread_t *workers; variable
522 free(workers); in setup_num_workers()
524 workers = calloc(num_workers, sizeof(*workers)); in setup_num_workers()
525 return worker_exits != NULL && workers != NULL; in setup_num_workers()
705 if (!run_thread(&workers[i], do_mt_hash_work)) in test_hashtable_multithread()
711 wait_for_thread(workers[i]); in test_hashtable_multithread()
741 free(workers); in test_hashtable_multithread()
742 workers = NULL; in test_hashtable_multithread()
/freebsd/sys/contrib/zstd/programs/
H A Dzstdcli_trace.c83 int workers = 0; in TRACE_log() local
88 ZSTD_CCtxParams_getParameter(trace->params, ZSTD_c_nbWorkers, &workers); in TRACE_log()
113 workers, in TRACE_log()
/freebsd/contrib/ntp/libntp/lib/isc/include/isc/
H A Dtask.h657 unsigned int workers, unsigned int default_quantum,
660 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers,
773 (*isc_taskmgrcreatefunc_t)(isc_mem_t *mctx, unsigned int workers,
/freebsd/contrib/ntp/libntp/lib/isc/
H A Dtask.c141 unsigned int workers; member
224 isc__taskmgr_create(isc_mem_t *mctx, unsigned int workers,
1321 isc__taskmgr_create(isc_mem_t *mctx, unsigned int workers, in isc__taskmgr_create() argument
1332 REQUIRE(workers > 0); in isc__taskmgr_create()
1364 manager->workers = 0; in isc__taskmgr_create()
1366 workers * sizeof(isc_thread_t)); in isc__taskmgr_create()
1413 for (i = 0; i < workers; i++) { in isc__taskmgr_create()
1415 &manager->threads[manager->workers]) == in isc__taskmgr_create()
1417 manager->workers++; in isc__taskmgr_create()
1427 isc_thread_setconcurrency(workers); in isc__taskmgr_create()
[all …]
/freebsd/tools/tools/netrate/tcpp/
H A DREADME25 -p <numprocs> Number of workers, should be >= client -p arg
35 This selects server mode, four workers, and at most 1 million TCP connections
48 -p <numprocs> Number of workers, should be <= server -p
57 This creates four workers, each of which will (over its lifetime) set up and
/freebsd/sys/dev/mlx5/mlx5_en/
H A Dmlx5_en_rl.c613 ix = (rlw - priv->rl.workers) % in mlx5e_rl_worker()
908 rl->workers = malloc(sizeof(rl->workers[0]) * in mlx5e_rl_init()
941 struct mlx5e_rl_worker *rlw = rl->workers + j; in mlx5e_rl_init()
997 struct mlx5e_rl_worker *rlw = rl->workers + j; in mlx5e_rl_open_workers()
1025 struct mlx5e_rl_worker *rlw = rl->workers + y; in mlx5e_rl_close_workers()
1041 struct mlx5e_rl_worker *rlw = rl->workers + y; in mlx5e_rl_close_workers()
1088 struct mlx5e_rl_worker *rlw = rl->workers + y; in mlx5e_rl_cleanup()
1095 free(rl->workers, M_MLX5EN); in mlx5e_rl_cleanup()
1221 rlw = priv->rl.workers + ((params->rate_limit.hdr.flowid % 128) % in mlx5e_rl_snd_tag_alloc()
1322 struct mlx5e_rl_worker *rlw = rl->workers + y; in mlx5e_rl_refresh_channel_params()
[all …]
H A Den_rl.h158 struct mlx5e_rl_worker *workers; member
/freebsd/crypto/krb5/src/kdc/
H A Dmain.c61 static int workers = 0; variable
752 workers = atoi(optarg); in initialize_realms()
753 if (workers <= 0) in initialize_realms()
976 if (workers == 0) { in main()
1008 if (workers > 0) { in main()
1009 retval = create_workers(ctx, workers); in main()
/freebsd/usr.sbin/bhyve/
H A Dpci_virtio_scsi.c960 struct pci_vtscsi_worker *workers; in pci_vtscsi_init_queue() local
985 workers = calloc(sc->vss_thr_per_q, sizeof(struct pci_vtscsi_worker)); in pci_vtscsi_init_queue()
986 if (workers == NULL) in pci_vtscsi_init_queue()
990 workers[i].vsw_queue = queue; in pci_vtscsi_init_queue()
992 pthread_create(&workers[i].vsw_thread, NULL, &pci_vtscsi_proc, in pci_vtscsi_init_queue()
993 (void *)&workers[i]); in pci_vtscsi_init_queue()
996 pthread_set_name_np(workers[i].vsw_thread, tname); in pci_vtscsi_init_queue()
997 LIST_INSERT_HEAD(&queue->vsq_workers, &workers[i], vsw_link); in pci_vtscsi_init_queue()
/freebsd/contrib/llvm-project/compiler-rt/lib/fuzzer/
H A DFuzzerDriver.cpp673 if (Flags.jobs > 0 && Flags.workers == 0) { in FuzzerDriver()
674 Flags.workers = std::min(NumberOfCpuCores() / 2, Flags.jobs); in FuzzerDriver()
675 if (Flags.workers > 1) in FuzzerDriver()
676 Printf("Running %u workers\n", Flags.workers); in FuzzerDriver()
679 if (Flags.workers > 0 && Flags.jobs > 0) in FuzzerDriver()
680 return RunInMultipleProcesses(Args, Flags.workers, Flags.jobs); in FuzzerDriver()
H A DFuzzerFlags.def118 FUZZER_FLAG_UNSIGNED(workers, 0,
/freebsd/contrib/libpcap/doc/
H A DREADME.hpux100 And another message to tcpdump-workers@tcpdump.org, from Rick Jones:
104 To: tcpdump-workers@tcpdump.org
105 Subject: Re: [tcpdump-workers] I Can't Capture the Outbound Traffic
H A DREADME.aix43 should send to tcpdump-workers@lists.tcpdump.org a detailed bug
/freebsd/contrib/libpcap/
H A DCONTRIBUTING.md29 to the mailing list tcpdump-workers@lists.tcpdump.org and ask!
H A DCREDITS175 Mark Pizzolato <List-tcpdump-workers at subscriptions dot pizzolato dot net>
/freebsd/contrib/llvm-project/libc/src/__support/GPU/
H A Dallocator.cpp136 uint32_t workers = cpp::popcount(uniform); in uniform_memset() local
137 for (uint32_t i = impl::lane_count(mask & uniform); i < n; i += workers) in uniform_memset()
/freebsd/usr.bin/m4/TEST/
H A Dtest.m4171 wizards do not wan the workers or travelers to learn their incantations
/freebsd/contrib/tcpdump/
H A DCREDITS134 Hank Leininger <tcpdump-workers at progressive-comp dot com>
/freebsd/contrib/tzdata/
H A Dafrica211 # hot in Egypt), and the idea is to make fasting easier for workers by

12