Home
last modified time | relevance | path

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

1234

/freebsd-12.1/contrib/unbound/daemon/
H A Dworker.c242 struct worker* worker = q->env->worker; in worker_handle_reply() local
274 struct worker* worker = e->qstate->env->worker; in worker_handle_service_reply() local
382 struct worker* worker = (struct worker*)arg; in worker_handle_control_cmd() local
1089 struct worker* worker = (struct worker*)arg; in worker_handle_request() local
1628 struct worker* worker = (struct worker*)arg; in worker_sighandler() local
1671 struct worker* worker = (struct worker*)arg; in worker_stat_timer_cb() local
1688 struct worker* worker = (struct worker*)arg; in worker_probe_timer_cb() local
1851 worker->env.worker = worker; in worker_init()
1978 struct worker* worker = q->env->worker; in worker_send_query() local
1997 struct worker* worker = (struct worker*)arg; in worker_alloc_cleanup() 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
361 void server_stats_obtain(struct worker* worker, struct worker* who, in server_stats_obtain() argument
366 if(worker == who) { in server_stats_obtain()
[all …]
H A Dremote.c418 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
1585 struct worker* worker; member
1645 inf.worker = worker; in do_flush_infra()
1732 inf.worker = worker; in do_flush_zone()
1804 inf.worker = worker; in do_flush_bogus()
1879 inf.worker = worker; in do_flush_negative()
2274 do_status(RES* ssl, struct worker* worker) in do_status() argument
2883 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.c376 daemon->env->worker = NULL; in daemon_setup_modules()
449 sizeof(struct worker*)); in daemon_create_workers()
504 struct worker* worker = (struct worker*)arg; in thread_start() local
506 log_thread_set(&worker->thread_num); in thread_start()
510 tube_close_write(worker->cmd); in thread_start()
511 close_other_pipes(worker->daemon, worker->thread_num); in thread_start()
514 if(worker->daemon->cfg->so_reuseport) in thread_start()
515 port_num = worker->thread_num % worker->daemon->num_ports; in thread_start()
519 if(!worker_init(worker, worker->daemon->cfg, in thread_start()
520 worker->daemon->ports[port_num], 0)) in thread_start()
[all …]
/freebsd-12.1/contrib/unbound/util/shm_side/
H A Dshm_main.c218 void shm_main_run(struct worker *worker) in shm_main_run() argument
228worker->thread_num, worker->daemon, (unsigned)worker->env.now_tv->tv_sec, (unsigned)worker->daemon… in shm_main_run()
231 offset = worker->thread_num + 1; in shm_main_run()
232 stat_total = worker->daemon->shm_info->ptr_arr; in shm_main_run()
236 server_stats_compile(worker, stat_info, 0); in shm_main_run()
239 if (worker->thread_num == 0) { in shm_main_run()
246 shm_stat = worker->daemon->shm_info->ptr_ctl; in shm_main_run()
251 …eval_subtract(&shm_stat->time.up_sec, &shm_stat->time.up_usec, worker->env.now_tv, &worker->daemon… in shm_main_run()
258 if(worker->daemon->dnscenv) { in shm_main_run()
262 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-12.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-12.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-12.1/contrib/libxo/tests/core/saved/
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.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.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.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.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.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-12.1/contrib/unbound/services/
H A Dauthzone.h58 struct worker;
280 struct worker* worker; member
306 struct worker* worker; member
354 struct worker* worker; member
/freebsd-12.1/usr.sbin/bhyve/
H A Dpci_virtio_scsi.c263 struct pci_vtscsi_worker *worker = (struct pci_vtscsi_worker *)arg; in pci_vtscsi_proc() local
264 struct pci_vtscsi_queue *q = worker->vsw_queue; in pci_vtscsi_proc()
272 && !worker->vsw_exiting) in pci_vtscsi_proc()
275 if (worker->vsw_exiting) in pci_vtscsi_proc()
637 struct pci_vtscsi_worker *worker; in pci_vtscsi_init_queue() local
651 worker = calloc(1, sizeof(struct pci_vtscsi_worker)); in pci_vtscsi_init_queue()
652 worker->vsw_queue = queue; in pci_vtscsi_init_queue()
654 pthread_create(&worker->vsw_thread, NULL, &pci_vtscsi_proc, in pci_vtscsi_init_queue()
655 (void *)worker); in pci_vtscsi_init_queue()
658 pthread_set_name_np(worker->vsw_thread, tname); in pci_vtscsi_init_queue()
[all …]

1234