| /freebsd-12-stable/contrib/unbound/daemon/ |
| 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 …]
|
| 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 …]
|
| 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 …]
|
| 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 …]
|
| 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);
|
| 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);
|
| 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,
|
| 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);
|
| 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 …]
|
| /freebsd-12-stable/contrib/unbound/util/shm_side/ |
| 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 …]
|
| D | shm_main.h | 45 struct worker;
66 void shm_main_run(struct worker *worker);
|
| /freebsd-12-stable/contrib/netbsd-tests/rump/rumpkern/h_client/ |
| 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()
|
| /freebsd-12-stable/contrib/unbound/contrib/ |
| 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.");
|
| D | redirect-bogus.patch | 1 Index: daemon/worker.c
3 --- daemon/worker.c (revision 4191)
4 +++ daemon/worker.c (working copy)
6 if(!inplace_cb_reply_servfail_call(&worker->env, qinfo, NULL, rep,
7 LDNS_RCODE_SERVFAIL, edns, worker->scratchpad))
12 + worker->env.cfg->redirect_bogus_ipv4) {
16 + worker->env.cfg->redirect_bogus_ipv4);
18 + worker->env.cfg->redirect_bogus_ipv6) {
21 + worker->env.cfg->redirect_bogus_ipv6);
26 rrset_array_unlock_touch(worker->env.rrset_cache,
[all …]
|
| /freebsd-12-stable/contrib/libxo/tests/core/saved/ |
| D | test_11.JP.out | 1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| D | test_11.HP.out | 1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| D | test_11.XP.out | 1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| D | test_11.J.out | 1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| D | test_11.H.out | 1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| D | test_11.T.out | 1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| D | test_11.HIPx.out | 1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| D | test_11.X.out | 1 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
5 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
9 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
13 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| D | test_11.E.out | 4 {{<14>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-status [animal-status@42 a…
8 {{<22>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-consumed [animal-consumed@…
12 {{<29>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 animal-talk [animal-talk@42 count…
16 {{<165>1 2015-06-23T13:47:09.123-0500 worker-host test-program 222 ID47 [ID47@32473 iut="3" event-s…
|
| /freebsd-12-stable/contrib/unbound/services/ |
| D | authzone.h | 58 struct worker;
296 struct worker* worker; member
322 struct worker* worker; member
370 struct worker* worker; member
|
| /freebsd-12-stable/usr.sbin/bhyve/ |
| D | pci_virtio_scsi.c | 264 struct pci_vtscsi_worker *worker = (struct pci_vtscsi_worker *)arg; in pci_vtscsi_proc() local
265 struct pci_vtscsi_queue *q = worker->vsw_queue; in pci_vtscsi_proc()
273 && !worker->vsw_exiting) in pci_vtscsi_proc()
276 if (worker->vsw_exiting) in pci_vtscsi_proc()
661 struct pci_vtscsi_worker *worker; in pci_vtscsi_init_queue() local
675 worker = calloc(1, sizeof(struct pci_vtscsi_worker)); in pci_vtscsi_init_queue()
676 worker->vsw_queue = queue; in pci_vtscsi_init_queue()
678 pthread_create(&worker->vsw_thread, NULL, &pci_vtscsi_proc, in pci_vtscsi_init_queue()
679 (void *)worker); in pci_vtscsi_init_queue()
682 pthread_set_name_np(worker->vsw_thread, tname); in pci_vtscsi_init_queue()
[all …]
|