| /netbsd/external/bsd/unbound/dist/daemon/ |
| H A D | worker.c | 244 struct worker* worker = e->qstate->env->worker; in worker_handle_service_reply() local
352 struct worker* worker = (struct worker*)arg; in worker_handle_control_cmd() local
1248 struct worker* worker = (struct worker*)arg; in worker_handle_request() local
1792 struct worker* worker = (struct worker*)arg; in worker_sighandler() local
1838 struct worker* worker = (struct worker*)arg; in worker_stat_timer_cb() local
1855 struct worker* worker = (struct worker*)arg; in worker_probe_timer_cb() local
2029 worker->env.worker = worker; in worker_init()
2189 struct worker* worker = q->env->worker; in worker_send_query() local
2209 struct worker* worker = (struct worker*)arg; in worker_alloc_cleanup() local
2225 struct worker* worker = (struct worker*)arg; in worker_start_accept() local
[all …]
|
| H A D | stats.c | 101 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker) in server_stats_prefetch() argument
110 void server_stats_log(struct ub_server_stats* stats, struct worker* worker, in server_stats_log() argument
137 set_subnet_stats(struct worker* worker, struct ub_server_stats* svr, in set_subnet_stats() argument
162 set_neg_cache_stats(struct worker* worker, struct ub_server_stats* svr, in set_neg_cache_stats() argument
186 get_rrset_bogus(struct worker* worker, int reset) in get_rrset_bogus() argument
204 get_queries_ratelimit(struct worker* worker, int reset) in get_queries_ratelimit() argument
223 get_dnscrypt_cache_miss(struct worker* worker, int reset) in get_dnscrypt_cache_miss() argument
239 get_dnscrypt_replay(struct worker* worker, int reset) in get_dnscrypt_replay() argument
367 void server_stats_obtain(struct worker* worker, struct worker* who, in server_stats_obtain() argument
372 if(worker == who) { in server_stats_obtain()
[all …]
|
| H A D | remote.c | 428 rc->worker = worker; in daemon_remote_open_accept()
678 do_stop(RES* ssl, struct worker* worker) in do_stop() argument
687 do_reload(RES* ssl, struct worker* worker) in do_reload() argument
1631 struct worker* worker; member
1691 inf.worker = worker; in do_flush_infra()
1778 inf.worker = worker; in do_flush_zone()
1850 inf.worker = worker; in do_flush_bogus()
1925 inf.worker = worker; in do_flush_negative()
2315 do_status(RES* ssl, struct worker* worker) in do_status() argument
3025 struct worker* worker) in execute_cmd() argument
[all …]
|
| H A D | cachedump.c | 123 dump_rrset_cache(RES* ssl, struct worker* worker) in dump_rrset_cache() argument
279 dump_msg_cache(RES* ssl, struct worker* worker) in dump_msg_cache() argument
296 dump_cache(RES* ssl, struct worker* worker) in dump_cache() argument
382 struct packed_rrset_data* d, struct worker* worker) in move_into_cache() argument
434 &worker->alloc, *worker->env.now); in move_into_cache()
524 load_rrset_cache(RES* ssl, struct worker* worker) in load_rrset_cache() argument
580 load_ref(RES* ssl, sldns_buffer* buf, struct worker* worker, in load_ref() argument
625 load_msg(RES* ssl, sldns_buffer* buf, struct worker* worker) in load_msg() argument
692 load_msg_cache(RES* ssl, struct worker* worker) in load_msg_cache() argument
705 load_cache(RES* ssl, struct worker* worker) in load_cache() argument
[all …]
|
| H A D | stats.h | 46 struct worker;
64 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker);
67 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker);
70 void server_stats_log(struct ub_server_stats* stats, struct worker* worker,
80 void server_stats_obtain(struct worker* worker, struct worker* who,
91 void server_stats_compile(struct worker* worker, struct ub_stats_info* s,
100 void server_stats_reply(struct worker* worker, int reset);
|
| H A D | worker.h | 82 struct worker { struct
141 struct worker* worker_create(struct daemon* daemon, int id, int* ports, int n);
152 int worker_init(struct worker* worker, struct config_file *cfg,
158 void worker_work(struct worker* worker);
163 void worker_delete(struct worker* worker);
170 void worker_send_cmd(struct worker* worker, enum worker_commands cmd);
176 void worker_stats_clear(struct worker* worker);
|
| H A D | cachedump.h | 74 struct worker;
84 int dump_cache(RES* ssl, struct worker* worker);
93 int load_cache(RES* ssl, struct worker* worker);
105 int print_deleg_lookup(RES* ssl, struct worker* worker, uint8_t* nm,
|
| H A D | remote.h | 54 struct worker;
91 struct worker* worker; member
157 struct listen_port* ports, struct worker* worker);
175 void daemon_remote_exec(struct worker* worker);
|
| H A D | daemon.c | 396 daemon->env->worker = NULL; in daemon_setup_modules()
469 sizeof(struct worker*)); in daemon_create_workers()
522 struct worker* worker = (struct worker*)arg; in thread_start() local
524 log_thread_set(&worker->thread_num); in thread_start()
528 tube_close_write(worker->cmd); in thread_start()
529 close_other_pipes(worker->daemon, worker->thread_num); in thread_start()
532 if(worker->daemon->cfg->so_reuseport) in thread_start()
533 port_num = worker->thread_num % worker->daemon->num_ports; in thread_start()
537 if(!worker_init(worker, worker->daemon->cfg, in thread_start()
538 worker->daemon->ports[port_num], 0)) in thread_start()
[all …]
|
| /netbsd/external/bsd/unbound/dist/util/shm_side/ |
| H A D | shm_main.c | 224 void shm_main_run(struct worker *worker) in shm_main_run() argument
234 …worker->thread_num, worker->daemon, (unsigned)worker->env.now_tv->tv_sec, (unsigned)worker->daemon… in shm_main_run()
237 offset = worker->thread_num + 1; in shm_main_run()
238 stat_total = worker->daemon->shm_info->ptr_arr; in shm_main_run()
242 server_stats_compile(worker, stat_info, 0); in shm_main_run()
245 if (worker->thread_num == 0) { in shm_main_run()
252 shm_stat = worker->daemon->shm_info->ptr_ctl; in shm_main_run()
257 …eval_subtract(&shm_stat->time.up_sec, &shm_stat->time.up_usec, worker->env.now_tv, &worker->daemon… in shm_main_run()
264 if(worker->daemon->dnscenv) { in shm_main_run()
268 worker->daemon->dnscenv->nonces_cache); in shm_main_run()
[all …]
|
| H A D | shm_main.h | 45 struct worker;
66 void shm_main_run(struct worker *worker);
|
| /netbsd/external/mpl/bind/dist/lib/isc/netmgr/ |
| H A D | netmgr.c | 339 r = uv_async_init(&worker->loop, &worker->async, async_cb); in isc__netmgr_create()
446 worker->paused = true; in isc__nm_async_pause()
447 uv_stop(&worker->loop); in isc__nm_async_pause()
497 worker->paused = false; in isc__nm_async_resume()
726 if (worker->paused) { in nm_thread()
871 UNUSED(worker); in isc__nm_async_task()
2572 UNUSED(worker); in isc__nm_async_connectcb()
2614 UNUSED(worker); in isc__nm_async_readcb()
2657 UNUSED(worker); in isc__nm_async_sendcb()
2678 UNUSED(worker); in isc__nm_async_close()
[all …]
|
| H A D | netmgr-int.h | 1096 isc__nm_async_connectcb(isc__networker_t *worker, isc__netievent_t *ev0);
1105 isc__nm_async_readcb(isc__networker_t *worker, isc__netievent_t *ev0);
1117 isc__nm_async_sendcb(isc__networker_t *worker, isc__netievent_t *ev0);
1124 isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ev0);
1179 isc__nm_async_udpstop(isc__networker_t *worker, isc__netievent_t *ev0);
1181 isc__nm_async_udpsend(isc__networker_t *worker, isc__netievent_t *ev0);
1183 isc__nm_async_udpread(isc__networker_t *worker, isc__netievent_t *ev0);
1187 isc__nm_async_udpclose(isc__networker_t *worker, isc__netievent_t *ev0);
1261 isc__nm_async_tcpstop(isc__networker_t *worker, isc__netievent_t *ev0);
1263 isc__nm_async_tcpsend(isc__networker_t *worker, isc__netievent_t *ev0);
[all …]
|
| H A D | tcp.c | 120 isc__networker_t *worker = NULL; in tcp_connect_direct() local
130 worker = &sock->mgr->workers[sock->tid]; in tcp_connect_direct()
201 UNUSED(worker); in isc__nm_async_tcpconnect()
688 UNUSED(worker); in isc__nm_async_tcpstop()
778 UNUSED(worker); in isc__nm_async_tcpstartread()
828 UNUSED(worker); in isc__nm_async_tcppauseread()
955 UNUSED(worker); in isc__nm_async_tcpaccept()
967 isc__networker_t *worker = NULL; in accept_connection() local
1139 UNUSED(worker); in isc__nm_async_tcpsend()
1362 UNUSED(worker); in isc__nm_async_tcpclose()
[all …]
|
| H A D | tcpdns.c | 85 isc__networker_t *worker = NULL; in tcpdns_connect_direct() local
95 worker = &sock->mgr->workers[sock->tid]; in tcpdns_connect_direct()
172 UNUSED(worker); in isc__nm_async_tcpdnsconnect()
655 UNUSED(worker); in isc__nm_async_tcpdnsstop()
743 UNUSED(worker); in isc__nm_async_tcpdnsread()
935 UNUSED(worker); in isc__nm_async_tcpdnsaccept()
947 isc__networker_t *worker = NULL; in accept_connection() local
978 worker = &csock->mgr->workers[csock->tid]; in accept_connection()
1167 UNUSED(worker); in isc__nm_async_tcpdnssend()
1395 UNUSED(worker); in isc__nm_async_tcpdnsclose()
[all …]
|
| H A D | udp.c | 247 r = uv_timer_init(&worker->loop, &sock->read_timer); in isc__nm_async_udplisten()
358 UNUSED(worker); in isc__nm_async_udpstop()
587 UNUSED(worker); in isc__nm_async_udpsend()
664 isc__networker_t *worker = NULL; in udp_connect_direct() local
673 worker = &sock->mgr->workers[isc_nm_tid()]; in udp_connect_direct()
677 r = uv_udp_init(&worker->loop, &sock->uv_handle.udp); in udp_connect_direct()
681 r = uv_timer_init(&worker->loop, &sock->read_timer); in udp_connect_direct()
758 UNUSED(worker); in isc__nm_async_udpconnect()
938 UNUSED(worker); in isc__nm_async_udpread()
1113 UNUSED(worker); in isc__nm_async_udpclose()
[all …]
|
| /netbsd/external/apache2/llvm/dist/llvm/docs/ |
| H A D | HowToAddABuilder.rst | 9 buildbot-worker to private worker builder to LLVM Buildbot Infrastructure.
51 to authenticate your buildbot-worker.
53 #. Create a buildbot-worker in context of that buildbot-worker account. Point it
55 Creating a worker
61 $ buildbot-worker create-worker <buildbot-worker-root-directory> \
63 <buildbot-worker-access-name> \
64 <buildbot-worker-access-password>
70 example of the buildbot-worker description::
85 #. Send a patch which adds your build worker and your builder to
106 #. Check the status of your buildbot-worker on the `Waterfall Display
[all …]
|
| /netbsd/external/mit/libuv/dist/docs/code/multi-echo-server/ |
| H A D | main.c | 42 struct child_worker *worker = &workers[round_robin_counter]; in on_new_connection() local
75 struct child_worker *worker = &workers[cpu_count]; in setup_workers() local
76 uv_pipe_init(loop, &worker->pipe, 1); in setup_workers()
80 child_stdio[0].data.stream = (uv_stream_t*) &worker->pipe; in setup_workers()
85 worker->options.stdio = child_stdio; in setup_workers()
86 worker->options.stdio_count = 3; in setup_workers()
88 worker->options.exit_cb = close_process_handle; in setup_workers()
89 worker->options.file = args[0]; in setup_workers()
90 worker->options.args = args; in setup_workers()
92 uv_spawn(loop, &worker->req, &worker->options); in setup_workers()
[all …]
|
| /netbsd/external/bsd/unbound/dist/winrc/ |
| H A D | win_svc.c | 517 struct worker* worker = (struct worker*)arg; in worker_win_stop_cb() local
519 worker->need_to_exit = 1; in worker_win_stop_cb()
520 comm_base_exit(worker->base); in worker_win_stop_cb()
596 struct worker* worker = (struct worker*)arg; in wsvc_cron_cb() local
601 ub_thread_create(&cron_thread, win_do_cron, worker); in wsvc_cron_cb()
607 void wsvc_setup_worker(struct worker* worker) in wsvc_setup_worker() argument
613 comm_base_internal(worker->base), service_stop_event, in wsvc_setup_worker()
614 &worker_win_stop_cb, worker))) { in wsvc_setup_worker()
619 service_cron = comm_timer_create(worker->base, in wsvc_setup_worker()
620 wsvc_cron_cb, worker); in wsvc_setup_worker()
[all …]
|
| H A D | win_svc.h | 49 struct worker;
76 void wsvc_setup_worker(struct worker* worker);
82 void wsvc_desetup_worker(struct worker* worker);
|
| /netbsd/sys/net/npf/ |
| H A D | npf_worker.c | 53 lwp_t * worker[]; member
72 const size_t len = offsetof(npf_workerinfo_t, worker[nworkers]); in npf_worker_sysinit()
91 NULL, npf_worker, winfo, &winfo->worker[i], "npfgc%u", i)) { in npf_worker_sysinit()
118 lwp_t *worker; in npf_worker_sysfini() local
120 if ((worker = winfo->worker[i]) != NULL) { in npf_worker_sysfini()
121 kthread_join(worker); in npf_worker_sysfini()
127 kmem_free(winfo, offsetof(npf_workerinfo_t, worker[nworkers])); in npf_worker_sysfini()
|
| /netbsd/external/mit/libuv/dist/docs/code/ |
| H A D | Makefile | 49 all: $(examples) plugin/plugin proc-streams/test cgi/tick multi-echo-server/worker uvwget/uvwget
66 multi-echo-server/worker: multi-echo-server/worker.c
67 gcc $(CFLAGS) -o multi-echo-server/worker multi-echo-server/worker.c $(UV_LIB) $(LIBS)
79 rm -rf multi-echo-server/worker multi-echo-server/worker.dSYM
|
| /netbsd/tests/rump/rumpkern/h_client/ |
| H A D | h_reconcli.c | 52 worker(void *arg) in worker() function
106 pthread_create(&w1, NULL, worker, NULL); in main()
107 pthread_create(&w2, NULL, worker, NULL); in main()
108 pthread_create(&w3, NULL, worker, NULL); in main()
109 pthread_create(&w4, NULL, worker, NULL); in main()
|
| /netbsd/external/bsd/unbound/dist/contrib/ |
| H A D | drop-tld.diff | 1 diff --git a/daemon/worker.c b/daemon/worker.c
3 --- a/daemon/worker.c
4 +++ b/daemon/worker.c
10 + if(worker->env.cfg->drop_tld) {
20 verbose(VERB_ALGO, "worker request: refused zone transfer.");
|
| /netbsd/external/bsd/unbound/dist/services/ |
| H A D | authzone.h | 58 struct worker;
296 struct worker* worker; member
322 struct worker* worker; member
370 struct worker* worker; member
|