Home
last modified time | relevance | path

Searched refs:worker (Results 1 – 25 of 95) sorted by relevance

1234

/freebsd-14.2/contrib/unbound/daemon/
H A Dworker.c248 struct worker* worker = e->qstate->env->worker; in worker_handle_service_reply() local
378 struct worker* worker = (struct worker*)arg; in worker_handle_control_cmd() local
1362 struct worker* worker = (struct worker*)arg; in worker_handle_request() local
1991 struct worker* worker = (struct worker*)arg; in worker_sighandler() local
2037 struct worker* worker = (struct worker*)arg; in worker_stat_timer_cb() local
2054 struct worker* worker = (struct worker*)arg; in worker_probe_timer_cb() local
2232 worker->env.worker = worker; in worker_init()
2379 struct worker* worker = q->env->worker; in worker_send_query() local
2399 struct worker* worker = (struct worker*)arg; in worker_alloc_cleanup() local
2415 struct worker* worker = (struct worker*)arg; in worker_start_accept() local
[all …]
H A Dstats.c104 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker) in server_stats_prefetch() argument
113 void server_stats_log(struct ub_server_stats* stats, struct worker* worker, in server_stats_log() argument
140 set_subnet_stats(struct worker* worker, struct ub_server_stats* svr, in set_subnet_stats() argument
165 set_neg_cache_stats(struct worker* worker, struct ub_server_stats* svr, in set_neg_cache_stats() argument
189 get_rrset_bogus(struct worker* worker, int reset) in get_rrset_bogus() argument
207 get_queries_ratelimit(struct worker* worker, int reset) in get_queries_ratelimit() argument
226 get_dnscrypt_cache_miss(struct worker* worker, int reset) in get_dnscrypt_cache_miss() argument
242 get_dnscrypt_replay(struct worker* worker, int reset) in get_dnscrypt_replay() argument
383 void server_stats_obtain(struct worker* worker, struct worker* who, in server_stats_obtain() argument
388 if(worker == who) { in server_stats_obtain()
[all …]
H A Dremote.c391 struct listen_port* ports, struct worker* worker) in daemon_remote_open_accept() argument
394 rc->worker = worker; in daemon_remote_open_accept()
665 do_stop(RES* ssl, struct worker* worker) in do_stop() argument
1757 struct worker* worker; member
1819 inf.worker = worker; in do_flush_infra()
1914 inf.worker = worker; in do_flush_zone()
1997 inf.worker = worker; in do_flush_bogus()
2083 inf.worker = worker; in do_flush_negative()
2522 do_status(RES* ssl, struct worker* worker) in do_status() argument
3425 struct worker* worker) in execute_cmd() argument
[all …]
H A Dstats.h46 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 Dcachedump.c123 dump_rrset_cache(RES* ssl, struct worker* worker) in dump_rrset_cache() argument
280 dump_msg_cache(RES* ssl, struct worker* worker) in dump_msg_cache() argument
297 dump_cache(RES* ssl, struct worker* worker) in dump_cache() argument
383 struct packed_rrset_data* d, struct worker* worker) in move_into_cache() argument
435 worker->alloc, *worker->env.now); in move_into_cache()
526 load_rrset_cache(RES* ssl, struct worker* worker) in load_rrset_cache() argument
627 load_msg(RES* ssl, sldns_buffer* buf, struct worker* worker) in load_msg() argument
704 load_msg_cache(RES* ssl, struct worker* worker) in load_msg_cache() argument
717 load_cache(RES* ssl, struct worker* worker) in load_cache() argument
877 (worker->env.cfg->do_ip4 && worker->back->num_ip4 != 0), in print_deleg_lookup()
[all …]
H A Dworker.h82 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 Dcachedump.h74 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 Dremote.h54 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 Ddaemon.c452 daemon->env->worker = NULL; in daemon_privileged()
468 daemon->env->worker = NULL; in daemon_setup_modules()
575 sizeof(struct worker*)); in daemon_create_workers()
643 struct worker* worker = (struct worker*)arg; in thread_start() local
645 log_thread_set(&worker->thread_num); in thread_start()
649 tube_close_write(worker->cmd); in thread_start()
650 close_other_pipes(worker->daemon, worker->thread_num); in thread_start()
653 if(worker->daemon->cfg->so_reuseport) in thread_start()
654 port_num = worker->thread_num % worker->daemon->num_ports; in thread_start()
658 if(!worker_init(worker, worker->daemon->cfg, in thread_start()
[all …]
/freebsd-14.2/contrib/unbound/util/shm_side/
H A Dshm_main.c224 void shm_main_run(struct worker *worker) in shm_main_run() argument
234worker->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 Dshm_main.h45 struct worker;
66 void shm_main_run(struct worker *worker);
/freebsd-14.2/contrib/lib9p/
H A Dthreadpool.c48 tp = worker->ltw_tp; in l9p_responder()
54 if (worker->ltw_exiting) { in l9p_responder()
85 tp = worker->ltw_tp; 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
185 worker->ltw_tp = tp; in l9p_threadpool_init()
189 (void *)worker); in l9p_threadpool_init()
191 free(worker); in l9p_threadpool_init()
194 if (worker->ltw_responder) in l9p_threadpool_init()
[all …]
/freebsd-14.2/sys/compat/linuxkpi/common/include/linux/
H A Dkthread.h93 #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-14.2/contrib/netbsd-tests/rump/rumpkern/h_client/
H A Dh_reconcli.c52 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-14.2/contrib/libxo/tests/core/saved/
H A Dtest_11.H.out1 {{<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 Dtest_11.HP.out1 {{<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 Dtest_11.HIPx.out1 {{<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 Dtest_11.X.out1 {{<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 Dtest_11.J.out1 {{<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 Dtest_11.XP.out1 {{<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 Dtest_11.JP.out1 {{<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 Dtest_11.JPu.out1 {{<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 Dtest_11.T.out1 {{<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 Dtest_11.E.out4 {{<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-14.2/contrib/unbound/contrib/
H A Ddrop-tld.diff1 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.");

1234