| /freebsd/contrib/unbound/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 | cachedump.c | 255 struct worker* worker; member
269 *dump_info->worker->env.now); in dump_rrset_entry()
275 dump_rrset_cache(RES* ssl, struct worker* worker) in dump_rrset_cache() argument
277 struct rrset_cache* r = worker->env.rrset_cache; in dump_rrset_cache()
279 dump_info.worker = worker; in dump_rrset_cache()
391 regional_free_all(dump_info->worker->scratchpad); in dump_msg_entry()
394 if(!copy_msg(dump_info->worker->scratchpad, e, &k, &d)) { in dump_msg_entry()
402 dump_msg(txt, k, d, *dump_info->worker->env.now); in dump_msg_entry()
407 dump_msg_cache(RES* ssl, struct worker* worker) in dump_msg_cache() argument
410 dump_info.worker = worker; 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 | remote.c | 250 rc->worker = NULL; in daemon_remote_clear()
429 n->com = comm_point_create_raw(rc->worker->base, fd, 0, in accept_open()
439 struct listen_port* ports, struct worker* worker) in daemon_remote_open_accept() argument
442 rc->worker = worker; in daemon_remote_open_accept()
500 n->c = comm_point_create_raw(rc->worker->base, newfd, 0, in remote_accept_callback()
705 for(i=1; i<rc->worker->daemon->num; i++) { in distribute_cmd()
706 worker_send_cmd(rc->worker->daemon->workers[i], in distribute_cmd()
708 if(!tube_write_msg(rc->worker->daemon->workers[i]->cmd, in distribute_cmd()
718 do_stop(RES* ssl, struct worker* worker) in do_stop() argument
720 worker->need_to_exit = 1; in do_stop()
[all …]
|
| H A D | remote.h | 56 struct worker;
94 struct worker* worker; member
176 struct worker* worker; member
239 struct worker* worker; member
299 struct listen_port* ports, struct worker* worker);
317 void daemon_remote_exec(struct worker* worker);
360 void fast_reload_thread_start(RES* ssl, struct worker* worker,
373 void fast_reload_worker_pickup_changes(struct worker* worker);
|
| H A D | worker.h | 88 struct worker { struct
147 struct worker* worker_create(struct daemon* daemon, int id);
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 | daemon.c | 191 signal_handling_playback(struct worker* wrk) in signal_handling_playback()
721 daemon->env->worker = NULL; in daemon_privileged()
737 daemon->env->worker = NULL; in daemon_setup_modules()
849 daemon->workers = (struct worker**)calloc((size_t)daemon->num, in daemon_create_workers()
850 sizeof(struct worker*)); in daemon_create_workers()
913 set_log_thread_id(struct worker* worker, struct config_file* cfg) in set_log_thread_id() argument
916 log_assert(worker); in set_log_thread_id()
918 worker->thread_tid = gettid(); in set_log_thread_id()
920 log_thread_set(&worker->thread_tid); in set_log_thread_id()
923 log_thread_set(&worker->thread_num); in set_log_thread_id()
[all …]
|
| /freebsd/contrib/unbound/util/shm_side/ |
| H A D | shm_main.c | 240 shm_general_info(struct worker* worker) in shm_general_info() argument
245 shm_stat = worker->daemon->shm_info->ptr_ctl; in shm_general_info()
246 shm_stat->time.now_sec = (long long)worker->env.now_tv->tv_sec; in shm_general_info()
247 shm_stat->time.now_usec = (long long)worker->env.now_tv->tv_usec; in shm_general_info()
250 …stat_timeval_subtract(&shm_stat->time.up_sec, &shm_stat->time.up_usec, worker->env.now_tv, &worker… in shm_general_info()
251 …act(&shm_stat->time.elapsed_sec, &shm_stat->time.elapsed_usec, worker->env.now_tv, &worker->daemon… in shm_general_info()
253 shm_stat->mem.msg = (long long)slabhash_get_mem(worker->env.msg_cache); in shm_general_info()
254 shm_stat->mem.rrset = (long long)slabhash_get_mem(&worker->env.rrset_cache->table); in shm_general_info()
257 if(worker->daemon->dnscenv) { in shm_general_info()
259 worker->daemon->dnscenv->shared_secrets_cache); in shm_general_info()
[all …]
|
| /freebsd/contrib/lib9p/ |
| H A D | threadpool.c | 45 struct l9p_worker *worker = arg; in l9p_responder() local
48 tp = worker->ltw_tp; in l9p_responder()
52 while (STAILQ_EMPTY(&tp->ltp_replyq) && !worker->ltw_exiting) in l9p_responder()
54 if (worker->ltw_exiting) { in l9p_responder()
82 struct l9p_worker *worker = arg; in l9p_worker() local
85 tp = worker->ltw_tp; in l9p_worker()
88 while (STAILQ_EMPTY(&tp->ltp_workq) && !worker->ltw_exiting) in l9p_worker()
90 if (worker->ltw_exiting) in l9p_worker()
97 req->lr_worker = worker; in l9p_worker()
158 struct l9p_worker *worker; in l9p_threadpool_init() local
[all …]
|
| /freebsd/sys/compat/linuxkpi/common/include/linux/ |
| H A D | kthread.h | 93 #define kthread_init_worker(worker) \ argument
114 kthread_destroy_worker(struct kthread_worker *worker) in kthread_destroy_worker() argument
116 taskqueue_drain_all(worker->tq); in kthread_destroy_worker()
117 taskqueue_free(worker->tq); in kthread_destroy_worker()
118 free(worker, M_KMALLOC); in kthread_destroy_worker()
130 kthread_queue_work(struct kthread_worker *worker, struct kthread_work *work) in kthread_queue_work() argument
134 error = taskqueue_enqueue_flags(worker->tq, &work->task, in kthread_queue_work()
137 work->tq = worker->tq; in kthread_queue_work()
161 kthread_flush_worker(struct kthread_worker *worker) in kthread_flush_worker() argument
163 taskqueue_drain_all(worker->tq); in kthread_flush_worker()
|
| /freebsd/contrib/unbound/winrc/ |
| H A D | win_svc.c | 547 struct worker* worker = (struct worker*)arg; in worker_win_stop_cb() local
549 worker->need_to_exit = 1; in worker_win_stop_cb()
550 comm_base_exit(worker->base); in worker_win_stop_cb()
626 struct worker* worker = (struct worker*)arg; in wsvc_cron_cb() local
631 ub_thread_create(&cron_thread, win_do_cron, worker); in wsvc_cron_cb()
637 void wsvc_setup_worker(struct worker* worker) in wsvc_setup_worker() argument
643 comm_base_internal(worker->base), service_stop_event, in wsvc_setup_worker()
644 &worker_win_stop_cb, worker))) { in wsvc_setup_worker()
649 service_cron = comm_timer_create(worker->base, in wsvc_setup_worker()
650 wsvc_cron_cb, worker); in wsvc_setup_worker()
[all …]
|
| /freebsd/contrib/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()
|
| /freebsd/contrib/unbound/services/ |
| H A D | authzone.h | 58 struct worker;
314 struct worker* worker; member
340 struct worker* worker; member
390 struct worker* worker; member
852 void xfr_disown_tasks(struct auth_xfer* xfr, struct worker* worker);
|
| /freebsd/contrib/libxo/tests/core/saved/ |
| H A 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…
|
| H A 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…
|
| H A 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…
|
| H A 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…
|
| H A 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…
|
| H A D | test_11.JPu.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…
|
| H A 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…
|
| H A 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…
|
| H A 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…
|
| /freebsd/contrib/unbound/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.");
|