Home
last modified time | relevance | path

Searched full:workers (Results 1 – 25 of 96) sorted by relevance

1234

/freebsd/sbin/dump/
H A Dtape.c82 * sends writeheader()'s and lists of daddr's to the workers via pipes.
83 * The following structure defines the instruction packets sent to workers.
91 #define WORKERS 3 /* 1 worker writing, 1 reading, 1 for slack */ macro
103 } workers[WORKERS+1]; variable
139 for (i = 0; i <= WORKERS; i++) { in alloctape()
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()
[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()
234 err(1, "allocating workers"); 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()
[all …]
/freebsd/sys/contrib/zstd/programs/
H A Dzstdcli_trace.c48 * workers in TRACE_enable()
56 …fprintf(g_traceFile, "Algorithm, Version, Method, Mode, Level, Workers, Dictionary Size, Uncompres… in TRACE_enable()
83 int workers = 0; in TRACE_log() local
88 ZSTD_CCtxParams_getParameter(trace->params, ZSTD_c_nbWorkers, &workers); in TRACE_log()
99 * workers in TRACE_log()
113 workers, in TRACE_log()
/freebsd/contrib/unbound/daemon/
H A Ddaemon.c2 * daemon/daemon.c - collection of workers that handles requests.
39 * The daemon consists of global settings and a number of workers.
573 daemon->workers = (struct worker**)calloc((size_t)daemon->num, in daemon_create_workers()
575 if(!daemon->workers) in daemon_create_workers()
587 if(!(daemon->workers[i] = worker_create(daemon, i, in daemon_create_workers()
624 tube_close_read(daemon->workers[i]->cmd); in close_other_pipes()
627 tube_delete(daemon->workers[i]->cmd); in close_other_pipes()
628 daemon->workers[i]->cmd = NULL; in close_other_pipes()
677 ub_thread_create(&daemon->workers[i]->thr_id, in daemon_start_others()
678 thread_start, daemon->workers[ in daemon_start_others()
[all...]
H A Ddaemon.h2 * daemon/daemon.h - collection of workers that handles requests.
39 * The daemon consists of global settings and a number of workers.
115 struct worker** workers;
168 * changes for workers */
198 * Fork workers and start service.
212 * Delete workers, close listening ports.
107 struct worker** workers; global() member
/freebsd/contrib/lib9p/
H A Dthreadpool.h39 * Most of the workers in the threadpool run requests.
51 pthread_cond_t ltp_work_cv; /* to signal regular workers */
53 LIST_HEAD(, l9p_worker) ltp_workers; /* list of all workers */
57 * All workers, including the responder, use this as their
72 * in terms of workers working on it. That is, this tells us
/freebsd/sys/contrib/openzfs/lib/libtpool/
H A Dthread_pool_impl.h69 pthread_cond_t tp_workcv; /* synchronization with workers */
74 pthread_attr_t tp_attr; /* attributes of the workers */
76 uint_t tp_linger; /* seconds before idle workers exit */
81 int tp_idle; /* number of idle workers */
H A Dthread_pool.c216 * and the number of workers exceeds the minimum. in tpool_worker()
407 * If there are idle workers, awaken one.
408 * Else, if the maximum number of workers has
482 /* mark the pool as being destroyed; wakeup idle workers */ in tpool_destroy()
487 /* cancel all active workers */ in tpool_destroy()
491 /* wait for all active workers to finish */ in tpool_destroy()
506 * Like tpool_destroy(), but don't cancel workers or wait for them to finish.
516 /* no workers, just delete the pool */ in tpool_abandon()
520 /* wake up all workers, last one will delete the pool */ in tpool_abandon()
/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
H A Dtcpp_client.c91 * attempt to localize IPs to particular workers. in tcpp_client_newconn()
285 * Start workers. in tcpp_client()
311 * GC workers. in tcpp_client()
H A Dtcpp_server.c291 * Start workers. in tcpp_server()
340 * GC workers. in tcpp_server()
/freebsd/contrib/sendmail/libmilter/
H A Dworker.c30 int tm_nb_workers; /* number of workers in the pool */
31 int tm_nb_idle; /* number of workers waiting */
88 /* session states - with respect to the pool of workers */
154 ** MI_START_SESSION -- Start a session in the pool of workers
307 /* Create the pool of workers */ in mi_pool_controller_init()
312 smi_log(SMI_LOG_ERR, "can't create workers crew: %s", in mi_pool_controller_init()
322 ** MI_POOL_CONTROLLER -- manage the pool of workers
567 ** Not the pipe for workers waking us,
754 ** if not, let's check if there is enough idle 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()
1411 * Start workers. 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()
[all …]
/freebsd/sys/dev/mlx5/mlx5_en/
H A Dmlx5_en_rl.c613 ix = (rlw - priv->rl.workers) % in mlx5e_rl_worker()
768 /* ratelimit workers */ in mlx5e_rl_set_default_params()
907 /* allocate workers array */ in mlx5e_rl_init()
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()
[all …]
/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,
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/contrib/llvm-project/compiler-rt/lib/fuzzer/
H A DFuzzerDriver.cpp293 Cmd.removeFlag("workers"); in RunInMultipleProcesses()
672 if (Flags.jobs > 0 && Flags.workers == 0) { in FuzzerDriver()
673 Flags.workers = std::min(NumberOfCpuCores() / 2, Flags.jobs); in FuzzerDriver()
674 if (Flags.workers > 1) in FuzzerDriver()
675 Printf("Running %u workers\n", Flags.workers); in FuzzerDriver()
678 if (Flags.workers > 0 && Flags.jobs > 0) in FuzzerDriver()
679 return RunInMultipleProcesses(Args, Flags.workers, Flags.jobs); in FuzzerDriver()
/freebsd/crypto/openssl/test/
H A Dlhash_test.c655 thread_t workers[NUM_WORKERS]; in test_hashtable_multithread() local
663 memset(workers, 0, sizeof(thread_t) * NUM_WORKERS); in test_hashtable_multithread()
679 if (!run_thread(&workers[i], do_mt_hash_work)) in test_hashtable_multithread()
685 wait_for_thread(workers[i]); in test_hashtable_multithread()
690 * Now that the workers are done, check for any error in test_hashtable_multithread()
/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/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/contrib/libpcap/
H A DCONTRIBUTING.md29 to the mailing list tcpdump-workers@lists.tcpdump.org and ask!
/freebsd/usr.bin/mkuzip/
H A Dmkuz_conveyor.h35 * Work items are places in here, and picked up by workers in a FIFO
/freebsd/sys/contrib/device-tree/Bindings/media/
H A Dmediatek,vcodec-subdev-decoder.yaml46 Its workers take input bitstream and LAT buffer, enable the hardware for
50 Its workers take LAT buffer and output buffer, enable the hardware for
/freebsd/cddl/lib/libtpool/tests/
H A Dlibtpool_test.c16 /* Block this task until all thread pool workers have been created. */ in tp_delay()
/freebsd/contrib/llvm-project/clang/include/clang/Tooling/DependencyScanning/
H A DDependencyScanningService.h73 /// is used by the individual dependency scanning workers.

1234