| /netbsd-src/sbin/dump/ |
| H A D | tape.c | 107 } 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()
292 if (++wp >= &workers[WORKERS]) in flushtape()
293 wp = &workers[0]; in flushtape()
313 if (workers[i].sent) { in flushtape()
314 if (atomic_read(workers[i].fd, in flushtape()
320 workers[i].sent = 0; in flushtape()
369 if (workers[f].sent) { in trewind()
[all …]
|
| /netbsd-src/external/mpl/bind/dist/tests/libtest/ |
| H A D | isc.c | 42 unsigned int workers = 0;
61 workers = atoi(env_workers); in setup_managers()
63 workers = isc_os_ncpus(); in setup_managers()
66 if (workers < 2) { in setup_managers()
67 workers = 2; in setup_managers()
70 INSIST(workers != 0); in setup_managers()
96 isc_loopmgr_create(mctx, workers, &loopmgr);
44 unsigned int workers = 0; global() variable
|
| /netbsd-src/external/bsd/unbound/dist/daemon/ |
| H A D | daemon.c | 544 daemon->workers = (struct worker**)calloc((size_t)daemon->num, in daemon_create_workers()
546 if(!daemon->workers) in daemon_create_workers()
558 if(!(daemon->workers[i] = worker_create(daemon, i, in daemon_create_workers()
595 tube_close_read(daemon->workers[i]->cmd); in close_other_pipes()
598 tube_delete(daemon->workers[i]->cmd); in close_other_pipes()
599 daemon->workers[i]->cmd = NULL; in close_other_pipes()
648 ub_thread_create(&daemon->workers[i]->thr_id, in daemon_start_others()
649 thread_start, daemon->workers[i]); in daemon_start_others()
652 tube_close_read(daemon->workers[i]->cmd); in daemon_start_others()
670 worker_send_cmd(daemon->workers[i], worker_cmd_quit); in daemon_stop_others()
[all …]
|
| /netbsd-src/external/mpl/bind/dist/tests/isc/ |
| H A D | netmgr_test.c | |
| H A D | doh_test.c | 313 workers = atoi(env_workers); in setup_test()
315 workers = isc_os_ncpus(); in setup_test()
317 INSIST(workers > 0); in setup_test()
777 if (active > workers) { in doh_recv_one()
799 isc_quota_t *quotap = init_listener_quota(workers); in doh_recv_one()
926 isc_quota_t *quotap = init_listener_quota(workers); in doh_recv_two()
1029 isc_quota_t *quotap = init_listener_quota(workers); in ISC_RUN_TEST_IMPL()
1142 isc_quota_t *quotap = init_listener_quota(workers); in ISC_RUN_TEST_IMPL()
|
| /netbsd-src/external/apache2/llvm/dist/llvm/utils/lit/lit/ |
| H A D | run.py | 19 def __init__(self, tests, lit_config, workers, progress_callback, argument
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 D | main.py | 207 workers = min(len(tests), opts.workers)
208 display = lit.display.create_display(opts, tests, discovered_tests, workers)
210 run = lit.run.Run(tests, lit_config, workers, display.update,
|
| /netbsd-src/external/mit/libuv/dist/docs/code/multi-echo-server/ |
| H A D | main.c | 13 } *workers; variable
42 struct child_worker *worker = &workers[round_robin_counter]; in on_new_connection()
73 workers = calloc(cpu_count, sizeof(struct child_worker)); in setup_workers()
75 struct child_worker *worker = &workers[cpu_count]; in setup_workers()
|
| /netbsd-src/external/mpl/bind/dist/bin/tests/ |
| H A D | test_server.c | 45 static int workers;
108 workers = val; in parse_workers()
121 workers = isc_os_ncpus(); in parse_options()
130 { "workers", required_argument, NULL, 'w' }, in parse_options()
166 printf("Will listen at %s://%s, %d workers\n", protocols[protocol], buf, in parse_options()
167 workers); in parse_options()
172 isc_managers_create(&mctx, workers, &loopmgr, &netmgr); in _signal()
44 static int workers; global() variable
|
| H A D | test_client.c | 65 static int workers;
128 workers = val; in parse_workers()
186 workers = isc_os_ncpus(); in parse_options()
195 { "workers", required_argument, NULL, 'w' }, in parse_options()
286 printf(" to %s, %d workers\n", buf, workers); in parse_options()
291 isc_managers_create(&mctx, workers, &loopmgr, &netmgr); in _signal()
64 static int workers; global() variable
|
| /netbsd-src/usr.sbin/nfsd/ |
| H A D | nfsd.c | 428 pthread_t *workers; in main() local
521 workers = calloc(nfsdcnt, sizeof(*workers)); in main()
522 if (workers == NULL) { in main()
530 error = pthread_create(&workers[i], NULL, worker, NULL); in main()
564 pthread_join(workers[i], NULL); in main()
|
| /netbsd-src/sys/external/bsd/compiler_rt/dist/lib/asan/tests/ |
| H A D | asan_mac_test.cc | 176 pthread_t workers[kNumWorkers], forker; in TEST() local
178 PTHREAD_CREATE(&workers[i], 0, MallocIntrospectionLockWorker, 0); in TEST()
182 PTHREAD_JOIN(workers[i], 0); in TEST()
|
| /netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/ |
| H A D | managers.c | 23 isc_managers_create(isc_mem_t *mctx, size_t workers, size_t quantum, in isc_managers_create() argument
30 isc__netmgr_create(mctx, workers, &netmgr); in isc_managers_create()
|
| /netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/netmgr/ |
| H A D | netmgr.c | 174 isc__nm_threadpool_initialize(uint32_t workers);
327 mgr->workers = isc_mem_get(mctx, in isc__netmgr_create()
330 isc__networker_t *worker = &mgr->workers[i]; in isc__netmgr_create()
341 worker->loop.data = &mgr->workers[i]; in isc__netmgr_create()
361 isc_thread_create(nm_thread, &mgr->workers[i], &worker->thread); in isc__netmgr_create()
387 isc__networker_t *worker = &mgr->workers[i]; in nm_destroy()
399 isc__networker_t *worker = &mgr->workers[i]; in nm_destroy()
429 isc_mem_put(mgr->mctx, mgr->workers, in nm_destroy()
466 isc__networker_t *worker = &mgr->workers[i]; in isc_nm_pause()
511 drain_queue(&mgr->workers[isc_nm_tid()], NETIEVENT_PRIORITY); in isc_nm_resume()
[all …]
|
| H A D | tcp.c | 130 worker = &sock->mgr->workers[sock->tid]; in tcp_connect_direct()
341 isc__nm_async_tcpconnect(&mgr->workers[sock->tid], in isc_nm_tcpconnect()
347 isc__nm_enqueue_ievent(&mgr->workers[sock->tid], in isc_nm_tcpconnect()
419 isc__nm_maybe_enqueue_ievent(&mgr->workers[tid], in start_tcp_child()
427 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in enqueue_stoplistening()
763 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_tcp_read()
814 isc__nm_maybe_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_tcp_pauseread()
863 isc__nm_maybe_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_tcp_resumeread()
942 isc__nm_maybe_enqueue_ievent(&sock->mgr->workers[sock->tid], in quota_accept_cb()
994 worker = &csock->mgr->workers[isc_nm_tid()]; in accept_connection()
[all …]
|
| H A D | udp.c | 119 isc__nm_maybe_enqueue_ievent(&mgr->workers[tid], in start_udp_child()
127 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in enqueue_stoplistening()
570 isc__nm_enqueue_ievent(&sock->mgr->workers[rsock->tid], in isc__nm_udp_send()
673 worker = &sock->mgr->workers[isc_nm_tid()]; in udp_connect_direct()
847 isc__nm_async_udpconnect(&mgr->workers[sock->tid], in isc_nm_udpconnect()
853 isc__nm_enqueue_ievent(&mgr->workers[sock->tid], in isc_nm_udpconnect()
980 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_udp_read()
1135 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_udp_close()
1194 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_udp_cancelread()
|
| H A D | tcpdns.c | 95 worker = &sock->mgr->workers[sock->tid]; in tcpdns_connect_direct()
303 isc__nm_async_tcpdnsconnect(&mgr->workers[sock->tid], in isc_nm_tcpdnsconnect()
309 isc__nm_enqueue_ievent(&mgr->workers[sock->tid], in isc_nm_tcpdnsconnect()
351 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in enqueue_stoplistening()
392 isc__nm_maybe_enqueue_ievent(&mgr->workers[tid], in start_tcpdns_child()
730 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_tcpdns_read()
922 isc__nm_maybe_enqueue_ievent(&sock->mgr->workers[sock->tid], in quota_accept_cb()
978 worker = &csock->mgr->workers[csock->tid]; in accept_connection()
1108 isc__nm_maybe_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_tcpdns_send()
1384 isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid], in isc__nm_tcpdns_close()
[all …]
|
| /netbsd-src/external/mpl/bind/dist/lib/isc/netmgr/ |
| H A D | udp.c | 188 isc__networker_t *worker = &mgr->workers[tid]; in isc_nm_listenudp()
212 isc_nm_listenudp(isc_nm_t *mgr, uint32_t workers, isc_sockaddr_t *iface, in isc_nm_listenudp()
222 worker = &mgr->workers[0]; in isc_nm_listenudp()
228 if (workers == 0) { in route_socket()
229 workers = mgr->nloops; in route_socket()
231 REQUIRE(workers <= mgr->nloops); in route_socket()
236 sock->nchildren = (workers == ISC_NM_LISTEN_ALL) ? (uint32_t)mgr->nloops in route_socket()
237 : workers; in route_socket()
371 worker = &mgr->workers[isc_tid()]; in isc_nm_routeconnect()
833 worker = &mgr->workers[isc_ti in udp_send_direct()
[all...] |
| H A D | tcp.c | 235 worker = &mgr->workers[isc_tid()]; in tcp_connect_cb()
417 isc__networker_t *worker = &mgr->workers[tid]; in start_tcp_child()
446 isc_nm_listentcp(isc_nm_t *mgr, uint32_t workers, isc_sockaddr_t *iface,
457 if (workers == 0) { in isc_nm_listentcp()
458 workers = mgr->nloops; in isc_nm_listentcp()
460 REQUIRE(workers <= mgr->nloops); in isc_nm_listentcp()
462 worker = &mgr->workers[0]; in isc_nm_listentcp()
466 sock->nchildren = (workers == ISC_NM_LISTEN_ALL) ? (uint32_t)mgr->nloops in isc_nm_listentcp()
467 : workers; in isc_nm_listentcp()
|
| H A D | netmgr.c | 206 netmgr->workers = isc_mem_cget(mctx, netmgr->nloops,
207 sizeof(netmgr->workers[0]));
215 isc__networker_t *worker = &netmgr->workers[i];
262 isc_mem_cput(mgr->mctx, mgr->workers, mgr->nloops, in isc__netmgr_create()
263 sizeof(mgr->workers[0])); in isc__netmgr_create()
2476 isc__networker_t *worker = &listener->worker->netmgr->workers[tid]; in isc_nmhandle_keepalive()
2495 &listener->worker->netmgr->workers[i]; in isc_nmhandle_keepalive()
2960 isc__networker_t *worker = &netmgr->workers[i]; in isc__nm_async_close()
|
| H A D | tcpdns.c | |
| H A D | tlsdns.c | |
| /netbsd-src/external/mpl/bind/dist/lib/isc/ |
| H A D | managers.c | 22 isc_managers_create(isc_mem_t **mctxp, uint32_t workers,
29 isc_loopmgr_create(*mctxp, workers, loopmgrp); in isc_managers_create()
36 isc_rwlock_setworkers(workers); in isc_managers_create()
24 isc_managers_create(isc_mem_t * mctx,size_t workers,size_t quantum,isc_nm_t ** netmgrp,isc_taskmgr_t ** taskmgrp,isc_timermgr_t ** timermgrp) isc_managers_create() argument
|
| /netbsd-src/external/apache2/llvm/dist/llvm/docs/ |
| H A D | HowToAddABuilder.rst | 25 Volunteers can provide their build machines to work as build workers to
89 * workers are added to ``buildbot/osuosl/master/config/workers.py``
108 ``http://lab.llvm.org:8011/#/workers`` to see if administrator contact and
|
| /netbsd-src/sys/external/bsd/compiler_rt/dist/lib/fuzzer/ |
| H A D | FuzzerDriver.cpp | 560 if (Flags.jobs > 0 && Flags.workers == 0) { in FuzzerDriver()
561 Flags.workers = std::min(NumberOfCpuCores() / 2, Flags.jobs); in FuzzerDriver()
562 if (Flags.workers > 1) in FuzzerDriver()
563 Printf("Running %u workers\n", Flags.workers); in FuzzerDriver()
566 if (Flags.workers > 0 && Flags.jobs > 0) in FuzzerDriver()
567 return RunInMultipleProcesses(Args, Flags.workers, Flags.jobs); in FuzzerDriver()
|