| /netbsd-src/external/bsd/unbound/dist/daemon/ |
| H A D | worker.c | 117 worker_mem_report(struct worker* ATTR_UNUSED(worker), in worker_mem_report() argument
132 front = listen_get_mem(worker->front); in worker_mem_report()
133 back = outnet_get_mem(worker->back); in worker_mem_report()
134 msg = slabhash_get_mem(worker->env.msg_cache); in worker_mem_report()
135 rrset = slabhash_get_mem(&worker->env.rrset_cache->table); in worker_mem_report()
136 infra = infra_get_mem(worker->env.infra_cache); in worker_mem_report()
137 mesh = mesh_get_mem(worker->env.mesh); in worker_mem_report()
138 ac = alloc_get_mem(worker->alloc); in worker_mem_report()
139 superac = alloc_get_mem(&worker->daemon->superalloc); in worker_mem_report()
140 anch = anchors_get_mem(worker->env.anchors); in worker_mem_report()
[all …]
|
| H A D | stats.c | 96 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker) in server_stats_querymiss() argument
99 stats->sum_query_list_size += worker->env.mesh->all.count; in server_stats_querymiss()
100 if((long long)worker->env.mesh->all.count > stats->max_query_list_size) in server_stats_querymiss()
101 stats->max_query_list_size = (long long)worker->env.mesh->all.count; in server_stats_querymiss()
104 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker) in server_stats_prefetch() argument
108 stats->sum_query_list_size += worker->env.mesh->all.count; in server_stats_prefetch()
109 if((long long)worker->env.mesh->all.count > stats->max_query_list_size) in server_stats_prefetch()
110 stats->max_query_list_size = (long long)worker->env.mesh->all.count; in server_stats_prefetch()
113 void server_stats_log(struct ub_server_stats* stats, struct worker* worker, in server_stats_log() argument
132 (unsigned)worker->env.mesh->stats_dropped, in server_stats_log()
[all …]
|
| H A D | remote.c | 214 rc->worker = NULL; in daemon_remote_clear()
373 n->com = comm_point_create_raw(rc->worker->base, fd, 0, in accept_open()
383 struct listen_port* ports, struct worker* worker) in daemon_remote_open_accept() argument
386 rc->worker = worker; in daemon_remote_open_accept()
444 n->c = comm_point_create_raw(rc->worker->base, newfd, 0, in remote_accept_callback()
638 do_stop(RES* ssl, struct worker* worker) in do_stop() argument
640 worker->need_to_exit = 1; in do_stop()
641 comm_base_exit(worker->base); in do_stop()
647 do_reload(RES* ssl, struct worker* worker, int reuse_cache) in do_reload() argument
649 worker->reuse_cache = reuse_cache; in do_reload()
[all …]
|
| H A D | cachedump.c | 123 dump_rrset_cache(RES* ssl, struct worker* worker) in dump_rrset_cache() argument
125 struct rrset_cache* r = worker->env.rrset_cache; in dump_rrset_cache()
131 *worker->env.now)) { in dump_rrset_cache()
252 dump_msg_lruhash(RES* ssl, struct worker* worker, struct lruhash* h) in dump_msg_lruhash() argument
261 regional_free_all(worker->scratchpad); in dump_msg_lruhash()
264 if(!copy_msg(worker->scratchpad, e, &k, &d)) { in dump_msg_lruhash()
271 if(!dump_msg(ssl, k, d, *worker->env.now)) { in dump_msg_lruhash()
280 dump_msg_cache(RES* ssl, struct worker* worker) in dump_msg_cache() argument
282 struct slabhash* sh = worker->env.msg_cache; in dump_msg_cache()
287 if(!dump_msg_lruhash(ssl, worker, sh->array[slab])) { in dump_msg_cache()
[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
147 struct worker* worker_create(struct daemon* daemon, int id, int* ports, int n);
158 int worker_init(struct worker* worker, struct config_file *cfg,
164 void worker_work(struct worker* worker);
169 void worker_delete(struct worker* worker);
176 void worker_send_cmd(struct worker* worker, enum worker_commands cmd);
182 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 | 185 signal_handling_playback(struct worker* wrk) in signal_handling_playback()
451 daemon->env->worker = NULL; in daemon_setup_modules()
544 daemon->workers = (struct worker**)calloc((size_t)daemon->num, in daemon_create_workers()
545 sizeof(struct worker*)); in daemon_create_workers()
613 struct worker* worker = (struct worker*)arg; in thread_start() local
615 log_thread_set(&worker->thread_num); in thread_start()
619 tube_close_write(worker->cmd); in thread_start()
620 close_other_pipes(worker->daemon, worker->thread_num); in thread_start()
623 if(worker->daemon->cfg->so_reuseport) in thread_start()
624 port_num = worker->thread_num % worker->daemon->num_ports; in thread_start()
[all …]
|
| /netbsd-src/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()
239 stat_info = worker->daemon->shm_info->ptr_arr + offset; 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()
253 shm_stat->time.now_sec = (long long)worker->env.now_tv->tv_sec; in shm_main_run()
254 shm_stat->time.now_usec = (long long)worker->env.now_tv->tv_usec; in shm_main_run()
[all …]
|
| /netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/netmgr/ |
| H A D | netmgr.c | 154 process_netievent(isc__networker_t *worker, isc__netievent_t *ievent);
156 process_queue(isc__networker_t *worker, netievent_type_t type);
158 wait_for_priority_queue(isc__networker_t *worker);
160 drain_queue(isc__networker_t *worker, netievent_type_t type);
163 isc__nm_async_stop(isc__networker_t *worker, isc__netievent_t *ev0);
165 isc__nm_async_pause(isc__networker_t *worker, isc__netievent_t *ev0);
167 isc__nm_async_resume(isc__networker_t *worker, isc__netievent_t *ev0);
169 isc__nm_async_detach(isc__networker_t *worker, isc__netievent_t *ev0);
171 isc__nm_async_close(isc__networker_t *worker, isc__netievent_t *ev0);
330 isc__networker_t *worker = &mgr->workers[i]; in isc__netmgr_create() local
[all …]
|
| H A D | netmgr-int.h | 964 isc__nm_maybe_enqueue_ievent(isc__networker_t *worker, isc__netievent_t *event);
971 isc__nm_enqueue_ievent(isc__networker_t *worker, isc__netievent_t *event);
1097 isc__nm_async_connectcb(isc__networker_t *worker, isc__netievent_t *ev0);
1106 isc__nm_async_readcb(isc__networker_t *worker, isc__netievent_t *ev0);
1118 isc__nm_async_sendcb(isc__networker_t *worker, isc__netievent_t *ev0);
1125 isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ev0);
1176 isc__nm_async_udplisten(isc__networker_t *worker, isc__netievent_t *ev0);
1178 isc__nm_async_udpconnect(isc__networker_t *worker, isc__netievent_t *ev0);
1180 isc__nm_async_udpstop(isc__networker_t *worker, isc__netievent_t *ev0);
1182 isc__nm_async_udpsend(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()
138 r = uv_tcp_init(&worker->loop, &sock->uv_handle.tcp); in tcp_connect_direct()
142 r = uv_timer_init(&worker->loop, &sock->read_timer); in tcp_connect_direct()
194 isc__nm_async_tcpconnect(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpconnect() argument
201 UNUSED(worker); in isc__nm_async_tcpconnect()
515 isc__nm_async_tcplisten(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcplisten() argument
538 r = uv_tcp_init(&worker->loop, &sock->uv_handle.tcp); in isc__nm_async_tcplisten()
545 r = uv_timer_init(&worker->loop, &sock->read_timer); in isc__nm_async_tcplisten()
684 isc__nm_async_tcpstop(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpstop() argument
[all …]
|
| /netbsd-src/external/apache2/llvm/dist/llvm/docs/ |
| H A D | HowToAddABuilder.rst | 9 buildbot-worker to private worker builder to LLVM Buildbot Infrastructure.
41 #. Install buildbot-worker (currently we are using buildbot version 2.8.5).
42 Depending on the platform, buildbot-worker could be available to download and
46 #. Create a designated user account, your buildbot-worker will be running under,
49 #. Choose the buildbot-worker root directory (all builds will be placed under
50 it), buildbot-worker access name and password the build master will be using
51 to authenticate your buildbot-worker.
53 #. Create a buildbot-worker in context of that buildbot-worker account. Point it
55 Creating a worker
56 <http://docs.buildbot.net/current/tutorial/firstrun.html#creating-a-worker>`_
[all …]
|
| /netbsd-src/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
43 … uv_write2(write_req, (uv_stream_t*) &worker->pipe, &dummy_buf, 1, (uv_stream_t*) client, NULL); in on_new_connection()
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()
[all …]
|
| /netbsd-src/external/mpl/bind/dist/lib/isc/netmgr/ |
| H A D | netmgr.c | 119 isc__networker_t *worker = arg;
120 isc_loop_t *loop = worker->loop;
122 worker->shuttingdown = true;
124 isc__netmgr_log(worker->netmgr, ISC_LOG_DEBUG(1),
125 "Shutting down network manager worker on loop %p(%d)",
130 isc__networker_detach(&worker);
215 isc__networker_t *worker = &netmgr->workers[i];
217 *worker = (isc__networker_t){ in isc__netmgr_create()
223 isc_nm_attach(netmgr, &worker->netmgr); in isc__netmgr_create()
225 isc_mem_attach(loop->mctx, &worker in isc__netmgr_create()
286 isc__networker_t *worker = &mgr->workers[i]; isc__netmgr_create() local
343 isc__networker_t *worker = &mgr->workers[i]; nm_destroy() local
355 isc__networker_t *worker = &mgr->workers[i]; nm_destroy() local
391 enqueue_pause(isc__networker_t * worker) enqueue_pause() argument
398 isc__nm_async_pause(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_pause() argument
418 isc__networker_t *worker = &mgr->workers[i]; isc_nm_pause() local
441 enqueue_resume(isc__networker_t * worker) enqueue_resume() argument
448 isc__nm_async_resume(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_resume() argument
466 isc__networker_t *worker = &mgr->workers[i]; isc_nm_resume() local
692 isc__networker_t *worker = (isc__networker_t *)worker0; nm_thread() local
764 process_all_queues(isc__networker_t * worker) process_all_queues() argument
800 isc__networker_t *worker = (isc__networker_t *)handle->loop->data; async_cb() local
812 isc__nm_async_stop(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_stop() argument
823 isc__networker_t *worker = NULL; isc_nm_task_enqueue() local
850 isc__nm_async_privilegedtask(worker,ev0) global() argument
854 isc__nm_async_task(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_task() argument
884 wait_for_priority_queue(isc__networker_t * worker) wait_for_priority_queue() argument
900 drain_queue(isc__networker_t * worker,netievent_type_t type) drain_queue() argument
934 process_netievent(isc__networker_t * worker,isc__netievent_t * ievent) process_netievent() argument
1015 process_queue(isc__networker_t * worker,netievent_type_t type) process_queue() argument
1142 isc__nm_maybe_enqueue_ievent(isc__networker_t * worker,isc__netievent_t * event) isc__nm_maybe_enqueue_ievent() argument
1157 isc__nm_enqueue_ievent(isc__networker_t * worker,isc__netievent_t * event) isc__nm_enqueue_ievent() argument
1641 isc__networker_t *worker = NULL; isc__nm_free_uvbuf() local
2224 isc__networker_t *worker = NULL; isc__nm_alloc_cb() local
2776 isc__networker_t *worker = &listener->mgr->workers[i]; isc__nmsocket_stop() local
2801 isc__nm_async_sockstop(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_sockstop() argument
2856 isc__nm_async_connectcb(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_connectcb() argument
2897 isc__nm_async_readcb(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_readcb() argument
2941 isc__nm_async_sendcb(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_sendcb() argument
2960 isc__nm_async_close(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_close() argument
2974 isc__nm_async_detach(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_detach() argument
3091 isc__nm_async_shutdown(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_shutdown() argument
3587 isc__networker_t *worker = NULL; isc_nm_work_offload() local
3774 isc__nm_async_settlsctx(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_settlsctx() argument
[all...] |
| H A D | netmgr-int.h | 85 "UDP receive buffer size must be smaller or equal than worker "
89 "TCP receive buffer size must be smaller or equal than worker "
210 * Single network event loop worker.
232 isc__nm_dump_active(isc__networker_t *worker);
503 isc__networker_t *worker;
519 worker */
765 isc___nmsocket_init(isc_nmsocket_t *sock, isc__networker_t *worker,
1429 isc__nm_closing(isc__networker_t *worker);
|
| H A D | udp.c | 111 isc_nm_t *mgr = sock->worker->netmgr;
112 isc_loop_t *loop = sock->worker->loop;
188 isc__networker_t *worker = &mgr->workers[tid]; in isc_nm_listenudp()
191 isc__nmsocket_init(csock, worker, isc_nm_udpsocket, iface, sock); in isc_nm_listenudp()
207 isc_async_run(worker->loop, start_udp_child_job, csock); in isc_nm_listenudp()
217 isc__networker_t *worker = NULL; in isc_nm_listenudp()
222 worker = &mgr->workers[0]; in isc_nm_listenudp()
224 if (isc__nm_closing(worker)) {
233 sock = isc_mempool_get(worker->nmsocket_pool); in route_socket()
234 isc__nmsocket_init(sock, worker, isc_nm_udplistene in route_socket()
257 isc__networker_t *worker = NULL; route_connect_direct() local
312 isc__nm_async_routeconnect(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_routeconnect() argument
420 isc__nm_async_udplisten(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udplisten() argument
543 isc__nm_async_udpstop(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpstop() argument
770 isc__nm_async_udpsend(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpsend() argument
855 isc__networker_t *worker = NULL; udp_connect_direct() local
939 isc__nm_async_udpconnect(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpconnect() argument
1124 isc__nm_async_udpread(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpread() argument
1299 isc__nm_async_udpclose(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpclose() argument
1395 isc__nm_async_udpcancel(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpcancel() argument
[all...] |
| H A D | tcp.c | 81 isc__networker_t *worker = NULL;
90 worker = sock->worker; in failed_accept_cb()
98 r = uv_tcp_init(&worker->loop->loop, &sock->uv_handle.tcp); in failed_accept_cb()
102 r = uv_timer_init(&worker->loop->loop, &sock->read_timer); in failed_accept_cb()
122 isc__nm_set_network_buffers(sock->worker->netmgr, in tcp_connect_direct()
146 isc__networker_t *worker = NULL; in tcp_connect_direct()
152 worker = sock->worker; in tcp_connect_direct()
165 } else if (isc__nm_closing(worker)) { in tcp_connect_direct()
120 isc__networker_t *worker = NULL; tcp_connect_direct() local
193 isc__nm_async_tcpconnect(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpconnect() argument
522 isc__nm_async_tcplisten(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcplisten() argument
683 isc__nm_async_tcpstop(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpstop() argument
767 isc__nm_async_tcpstartread(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpstartread() argument
818 isc__nm_async_tcppauseread(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcppauseread() argument
946 isc__nm_async_tcpaccept(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpaccept() argument
963 isc__networker_t *worker = NULL; accept_connection() local
1127 isc__nm_async_tcpsend(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpsend() argument
1351 isc__nm_async_tcpclose(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpclose() argument
1436 isc__nm_async_tcpcancel(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpcancel() argument
[all...] |
| /netbsd-src/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-src/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-src/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-src/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-src/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.");
|