Searched refs:workers (Results 1 - 25 of 57) sorted by relevance

123

/netbsd-current/external/mpl/bind/dist/lib/isc/
H A Dnetmgr_p.h22 isc__netmgr_create(isc_mem_t *mctx, uint32_t workers, isc_nm_t **netgmrp);
24 * Creates a new network manager with 'workers' worker threads,
H A Dmanagers.c24 isc_managers_create(isc_mem_t *mctx, size_t workers, size_t quantum, argument
33 isc__netmgr_create(mctx, workers, &netmgr);
/netbsd-current/external/mpl/dhcp/bind/dist/lib/isc/
H A Dnetmgr_p.h22 isc__netmgr_create(isc_mem_t *mctx, uint32_t workers, isc_nm_t **netgmrp);
24 * Creates a new network manager with 'workers' worker threads,
H A Dmanagers.c23 isc_managers_create(isc_mem_t *mctx, size_t workers, size_t quantum, argument
30 isc__netmgr_create(mctx, workers, &netmgr);
/netbsd-current/external/mpl/bind/dist/tests/libtest/
H A Disc.c44 unsigned int workers = 0; variable
55 if (workers == 0) {
58 workers = atoi(env_workers);
60 workers = isc_os_ncpus();
62 INSIST(workers > 0);
65 result = isc_managers_create(mctx, workers, 0, &netmgr, &taskmgr,
/netbsd-current/external/apache2/llvm/dist/llvm/utils/lit/lit/
H A Drun.py19 def __init__(self, tests, lit_config, workers, progress_callback,
23 self.workers = workers
27 assert workers > 0
69 pool = multiprocessing.Pool(self.workers, lit.worker.initialize,
114 desired_limit = self.workers * ncpus * 2 # the 2 is a safety factor
H A Ddisplay.py4 def create_display(opts, tests, total_tests, workers):
10 header = '-- Testing: %d%s tests, %d workers --' % (
11 num_tests, of_total, workers)
/netbsd-current/external/mpl/dhcp/bind/dist/lib/isc/include/isc/
H A Dmanagers.h27 isc_managers_create(isc_mem_t *mctx, size_t workers, size_t quantum,
/netbsd-current/external/mpl/bind/dist/lib/isc/include/isc/
H A Dmanagers.h26 isc_managers_create(isc_mem_t *mctx, size_t workers, size_t quantum,
/netbsd-current/sbin/dump/
H A Dtape.c86 * sends writeheader()'s and lists of daddr's to the workers via pipes.
87 * The following structure defines the instruction packets sent to workers.
107 } workers[WORKERS+1]; variable in typeref:struct:worker
144 workers[i].tblock = (char (*)[TP_BSIZE])
146 workers[i].req = (struct req *)workers[i].tblock - ntrec - 1;
148 wp = &workers[0];
292 if (++wp >= &workers[WORKERS])
293 wp = &workers[0];
313 if (workers[
[all...]
/netbsd-current/external/mit/libuv/dist/docs/code/multi-echo-server/
H A Dmain.c13 } *workers; variable in typeref:struct:child_worker
42 struct child_worker *worker = &workers[round_robin_counter];
65 // launch same number of workers as number of CPUs
73 workers = calloc(cpu_count, sizeof(struct child_worker));
75 struct child_worker *worker = &workers[cpu_count];
/netbsd-current/external/bsd/jemalloc/dist/msvc/test_threads/
H A Dtest_threads.cpp30 vector<thread> workers; local
40 workers.emplace_back([tid=i]() {
75 for (thread& t : workers) {
/netbsd-current/external/mpl/bind/dist/tests/isc/
H A Dnetmgr_test.c260 workers = atoi(env_workers);
262 workers = isc_os_ncpus();
264 INSIST(workers > 0);
265 nworkers = ISC_MAX(ISC_MIN(workers, 32), 1);
611 if (active > workers) {
613 * If we have more active connections than workers,
617 isc_test_nap(active - workers);
941 isc_thread_t threads[workers];
950 for (size_t i = 0; i < workers; i++) {
961 for (size_t i = 0; i < workers;
[all...]
/netbsd-current/external/bsd/unbound/dist/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.
544 daemon->workers = (struct worker**)calloc((size_t)daemon->num,
546 if(!daemon->workers)
558 if(!(daemon->workers[i] = worker_create(daemon, i,
595 tube_close_read(daemon->workers[i]->cmd);
598 tube_delete(daemon->workers[i]->cmd);
599 daemon->workers[i]->cmd = NULL;
648 ub_thread_create(&daemon->workers[i]->thr_id,
649 thread_start, daemon->workers[
[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.
105 struct worker** workers; member in struct:daemon
166 * Fork workers and start service.
180 * Delete workers, close listening ports.
/netbsd-current/external/mpl/bind/dist/bin/tests/
H A Dtest_server.c44 static int workers; variable
107 workers = val;
120 workers = isc_os_ncpus();
129 { "workers", required_argument, NULL, 'w' },
165 printf("Will listen at %s://%s, %d workers\n", protocols[protocol], buf,
166 workers);
194 isc_managers_create(mctx, workers, 0, &netmgr, NULL, NULL);
H A Dtest_client.c64 static int workers; variable
127 workers = val;
185 workers = isc_os_ncpus();
194 { "workers", required_argument, NULL, 'w' },
285 printf(" to %s, %d workers\n", buf, workers);
313 isc_managers_create(mctx, workers, 0, &netmgr, NULL, NULL);
/netbsd-current/sys/external/bsd/compiler_rt/dist/lib/asan/tests/
H A Dasan_mac_test.cc176 pthread_t workers[kNumWorkers], forker; local
178 PTHREAD_CREATE(&workers[i], 0, MallocIntrospectionLockWorker, 0);
182 PTHREAD_JOIN(workers[i], 0);
/netbsd-current/external/bsd/ntp/dist/lib/isc/include/isc/
H A Dtask.h659 unsigned int workers, unsigned int default_quantum,
662 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers,
670 *\li 'workers' in the number of worker threads to create. In general,
672 * The 'workers' value is advisory only. An attempt will be made to
673 * create 'workers' threads, but if at least one thread creation
684 *\li workers > 0
775 (*isc_taskmgrcreatefunc_t)(isc_mem_t *mctx, unsigned int workers,
/netbsd-current/external/bsd/ntp/dist/lib/isc/
H A Dtask_api.c59 unsigned int workers, unsigned int default_quantum,
67 result = (*taskmgr_createfunc)(mctx, workers, default_quantum,
79 isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers, argument
87 result = (*taskmgr_createfunc)(mctx, workers, default_quantum,
58 isc_taskmgr_createinctx(isc_mem_t *mctx, isc_appctx_t *actx, unsigned int workers, unsigned int default_quantum, isc_taskmgr_t **managerp) argument
/netbsd-current/external/gpl3/gdb.old/dist/gdb/testsuite/gdb.python/
H A Dpy-xmethods.py60 # 2. Matcher returning a list of workers.
102 workers = []
104 workers.append(E_method_int_worker())
106 workers.append(E_method_char_worker())
107 return workers
111 # xmethod matchers and workers for template classes and template
/netbsd-current/external/gpl3/gdb/dist/gdb/testsuite/gdb.python/
H A Dpy-xmethods.py62 # 2. Matcher returning a list of workers.
105 workers = []
107 workers.append(E_method_int_worker())
109 workers.append(E_method_char_worker())
110 return workers
114 # xmethod matchers and workers for template classes and template
/netbsd-current/external/gpl3/gdb.old/dist/gdb/testsuite/
H A DMakefile.in306 workers/%.worker:
312 # gen-workers, build-pieces, final.
325 rm -rf gdb.perf/workers
326 mkdir -p gdb.perf/workers
328 $(DO_RUNTEST) --directory=gdb.perf --outdir gdb.perf/workers GDB_PARALLEL=gdb.perf $(RUNTESTFLAGS) GDB_PERFTEST_MODE=compile GDB_PERFTEST_SUBMODE=gen-workers $(TIMESTAMP)
330 $(MAKE) $$(cd gdb.perf && echo workers/*/*.worker)
348 -rm -rf gdb.perf/workers gdb.perf/outputs gdb.perf/temp gdb.perf/cache
/netbsd-current/external/gpl3/gdb/dist/gdb/testsuite/
H A DMakefile.in336 workers/%.worker:
342 # gen-workers, build-pieces, final.
355 rm -rf gdb.perf/workers
356 mkdir -p gdb.perf/workers
358 $(DO_RUNTEST) --directory=gdb.perf --outdir gdb.perf/workers GDB_PARALLEL=gdb.perf $(RUNTESTFLAGS) GDB_PERFTEST_MODE=compile GDB_PERFTEST_SUBMODE=gen-workers $(TIMESTAMP)
360 $(MAKE) $$(cd gdb.perf && echo workers/*/*.worker)
378 -rm -rf gdb.perf/workers gdb.perf/outputs gdb.perf/temp gdb.perf/cache
/netbsd-current/usr.sbin/nfsd/
H A Dnfsd.c428 pthread_t *workers; local
521 workers = calloc(nfsdcnt, sizeof(*workers));
522 if (workers == NULL) {
530 error = pthread_create(&workers[i], NULL, worker, NULL);
564 pthread_join(workers[i], NULL);

Completed in 220 milliseconds

123