Home
last modified time | relevance | path

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

1234

/freebsd-13.1/contrib/unbound/daemon/
H A Dworker.c244 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
1064 struct worker* worker = (struct worker*)arg; in worker_handle_request() local
1588 struct worker* worker = (struct worker*)arg; in worker_sighandler() local
1631 struct worker* worker = (struct worker*)arg; in worker_stat_timer_cb() local
1648 struct worker* worker = (struct worker*)arg; in worker_probe_timer_cb() local
1816 worker->env.worker = worker; in worker_init()
1976 struct worker* worker = q->env->worker; in worker_send_query() local
1996 struct worker* worker = (struct worker*)arg; in worker_alloc_cleanup() local
2011 struct worker* worker = (struct worker*)arg; in worker_start_accept() local
[all …]
H A Dstats.c101 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
366 void server_stats_obtain(struct worker* worker, struct worker* who, in server_stats_obtain() argument
371 if(worker == who) { in server_stats_obtain()
[all …]
H A Dremote.c428 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
1629 struct worker* worker; member
1689 inf.worker = worker; in do_flush_infra()
1776 inf.worker = worker; in do_flush_zone()
1848 inf.worker = worker; in do_flush_bogus()
1923 inf.worker = worker; in do_flush_negative()
2313 do_status(RES* ssl, struct worker* worker) in do_status() argument
3023 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.c121 dump_rrset_cache(RES* ssl, struct worker* worker) in dump_rrset_cache() argument
277 dump_msg_cache(RES* ssl, struct worker* worker) in dump_msg_cache() argument
294 dump_cache(RES* ssl, struct worker* worker) in dump_cache() argument
380 struct packed_rrset_data* d, struct worker* worker) in move_into_cache() argument
432 &worker->alloc, *worker->env.now); in move_into_cache()
438 load_rrset(RES* ssl, sldns_buffer* buf, struct worker* worker) in load_rrset() argument
522 load_rrset_cache(RES* ssl, struct worker* worker) in load_rrset_cache() argument
578 load_ref(RES* ssl, sldns_buffer* buf, struct worker* worker, in load_ref() argument
623 load_msg(RES* ssl, sldns_buffer* buf, struct worker* worker) in load_msg() argument
689 load_msg_cache(RES* ssl, struct worker* worker) in load_msg_cache() argument
[all …]
H A Dworker.h82 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 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.c396 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 …]
/freebsd-13.1/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-13.1/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-13.1/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-13.1/contrib/libxo/tests/core/saved/
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.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.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.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.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.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.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-13.1/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.");
H A Dredirect-bogus.patch1 Index: daemon/worker.c
3 --- daemon/worker.c (revision 4191)
4 +++ daemon/worker.c (working copy)
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,
27 worker->scratchpad, rep->ref, rep->rrset_count);
[all …]
/freebsd-13.1/contrib/unbound/services/
H A Dauthzone.h58 struct worker;
296 struct worker* worker; member
322 struct worker* worker; member
370 struct worker* worker; member

1234