| /freebsd-src/contrib/unbound/daemon/ |
| H A D | worker.h | 82 struct worker { struct
93 /** pipe, for commands for this worker */ argument
95 /** the event base this worker works with */ argument
101 /** ports to be used by this worker. */ argument
103 /** number of ports for this worker */ argument
116 /** random() table for this worker. */ argument
139 * Create the worker structure. Bare bones version, zeroed struct, argument
|
| H A D | stats.c | 96 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker) in server_stats_querymiss() argument
104 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker) in server_stats_prefetch() argument
113 server_stats_log(struct ub_server_stats * stats,struct worker * worker,int threadnum) server_stats_log() argument
140 set_subnet_stats(struct worker * worker,struct ub_server_stats * svr,int reset) set_subnet_stats() argument
165 set_neg_cache_stats(struct worker * worker,struct ub_server_stats * svr,int reset) set_neg_cache_stats() argument
189 get_rrset_bogus(struct worker * worker,int reset) get_rrset_bogus() argument
207 get_queries_ratelimit(struct worker * worker,int reset) get_queries_ratelimit() argument
226 get_dnscrypt_cache_miss(struct worker * worker,int reset) get_dnscrypt_cache_miss() argument
242 get_dnscrypt_replay(struct worker * worker,int reset) get_dnscrypt_replay() argument
257 server_stats_compile(struct worker * worker,struct ub_stats_info * s,int reset) server_stats_compile() argument
377 server_stats_obtain(struct worker * worker,struct worker * who,struct ub_stats_info * s,int reset) server_stats_obtain() argument
424 server_stats_reply(struct worker * worker,int reset) server_stats_reply() argument
[all...] |
| H A D | worker.c | 117 worker_mem_report(struct worker* ATTR_UNUSED(worker), in worker_mem_report() argument
233 worker_send_cmd(struct worker * worker,enum worker_commands cmd) worker_send_cmd() argument
246 struct worker* worker = e->qstate->env->worker; worker_handle_service_reply() local
279 worker_err_ratelimit(struct worker * worker,int err) worker_err_ratelimit() argument
308 worker_check_request(sldns_buffer * pkt,struct worker * worker,struct check_request_result * out) worker_check_request() argument
376 struct worker* worker = (struct worker*)arg; worker_handle_control_cmd() local
463 answer_norec_from_cache(struct worker * worker,struct query_info * qinfo,uint16_t id,uint16_t flags,struct comm_reply * repinfo,struct edns_data * edns) answer_norec_from_cache() argument
586 apply_respip_action(struct worker * worker,const struct query_info * qinfo,struct respip_client_info * cinfo,struct reply_info * rep,struct sockaddr_storage * addr,socklen_t addrlen,struct ub_packed_rrset_key ** alias_rrset,struct reply_info ** encode_repp,struct auth_zones * az) apply_respip_action() argument
642 answer_from_cache(struct worker * worker,struct query_info * qinfo,struct respip_client_info * cinfo,int * need_drop,int * is_expired_answer,int * is_secure_answer,struct ub_packed_rrset_key ** alias_rrset,struct reply_info ** partial_repp,struct reply_info * rep,uint16_t id,uint16_t flags,struct comm_reply * repinfo,struct edns_data * edns) answer_from_cache() argument
831 reply_and_prefetch(struct worker * worker,struct query_info * qinfo,uint16_t flags,struct comm_reply * repinfo,time_t leeway,int noreply,int rpz_passthru,struct edns_option * opt_list) reply_and_prefetch() argument
879 chaos_replystr(sldns_buffer * pkt,char ** str,int num,struct edns_data * edns,struct worker * worker,struct comm_reply * repinfo) chaos_replystr() argument
930 chaos_replyonestr(sldns_buffer * pkt,const char * str,struct edns_data * edns,struct worker * worker,struct comm_reply * repinfo) chaos_replyonestr() argument
1117 deny_refuse(struct comm_point * c,enum acl_access acl,enum acl_access deny,enum acl_access refuse,struct worker * worker,struct comm_reply * repinfo,struct acl_addr * acladdr,int ede,struct check_request_result * check_result) deny_refuse() argument
1305 deny_refuse_all(struct comm_point * c,enum acl_access * acl,struct worker * worker,struct comm_reply * repinfo,struct acl_addr ** acladdr,int ede,int check_proxy,struct check_request_result * check_result) deny_refuse_all() argument
1327 deny_refuse_non_local(struct comm_point * c,enum acl_access acl,struct worker * worker,struct comm_reply * repinfo,struct acl_addr * acladdr,int ede,struct check_request_result * check_result) deny_refuse_non_local() argument
1338 check_ip_ratelimit(struct worker * worker,struct sockaddr_storage * addr,socklen_t addrlen,int has_cookie,sldns_buffer * pkt) check_ip_ratelimit() argument
1364 struct worker* worker = (struct worker*)arg; worker_handle_request() local
1992 struct worker* worker = (struct worker*)arg; worker_sighandler() local
2024 worker_restart_timer(struct worker * worker) worker_restart_timer() argument
2038 struct worker* worker = (struct worker*)arg; worker_stat_timer_cb() local
2055 struct worker* worker = (struct worker*)arg; worker_probe_timer_cb() local
2069 struct worker* worker = (struct worker*)calloc(1, worker_create() local
2099 worker_init(struct worker * worker,struct config_file * cfg,struct listen_port * ports,int do_sigs) worker_init() argument
2323 worker_work(struct worker * worker) worker_work() argument
2329 worker_delete(struct worker * worker) worker_delete() argument
2378 struct worker* worker = q->env->worker; worker_send_query() local
2398 struct worker* worker = (struct worker*)arg; worker_alloc_cleanup() local
2403 worker_stats_clear(struct worker * worker) worker_stats_clear() argument
2414 struct worker* worker = (struct worker*)arg; worker_start_accept() local
2422 struct worker* worker = (struct worker*)arg; worker_stop_accept() local
[all...] |
| H A D | remote.c | 383 daemon_remote_open_accept(struct daemon_remote * rc,struct listen_port * ports,struct worker * worker) daemon_remote_open_accept() argument
638 do_stop(RES * ssl,struct worker * worker) do_stop() argument
647 do_reload(RES * ssl,struct worker * worker,int reuse_cache) do_reload() argument
764 print_mem(RES * ssl,struct worker * worker,struct daemon * daemon,struct ub_stats_info * s) print_mem() argument
847 print_uptime(RES * ssl,struct worker * worker,int reset) print_uptime() argument
1084 do_stats(RES * ssl,struct worker * worker,int reset) do_stats() argument
1395 do_view_zone_add(RES * ssl,struct worker * worker,char * arg) do_view_zone_add() argument
1428 do_view_zone_remove(RES * ssl,struct worker * worker,char * arg) do_view_zone_remove() argument
1451 do_view_data_add(RES * ssl,struct worker * worker,char * arg) do_view_data_add() argument
1476 do_view_datas_add(RES * ssl,struct worker * worker,char * arg) do_view_datas_add() argument
1498 do_view_data_remove(RES * ssl,struct worker * worker,char * arg) do_view_data_remove() argument
1521 do_view_datas_remove(RES * ssl,struct worker * worker,char * arg) do_view_datas_remove() argument
1542 do_lookup(RES * ssl,struct worker * worker,char * arg) do_lookup() argument
1555 do_cache_remove(struct worker * worker,uint8_t * nm,size_t nmlen,uint16_t t,uint16_t c) do_cache_remove() argument
1580 do_flush_type(RES * ssl,struct worker * worker,char * arg) do_flush_type() argument
1603 do_flush_stats(RES * ssl,struct worker * worker) do_flush_stats() argument
1614 struct worker* worker; global() member
1658 do_flush_infra(RES * ssl,struct worker * worker,char * arg) do_flush_infra() argument
1692 do_flush_requestlist(RES * ssl,struct worker * worker) do_flush_requestlist() argument
1751 do_flush_zone(RES * ssl,struct worker * worker,char * arg) do_flush_zone() argument
1829 do_flush_bogus(RES * ssl,struct worker * worker) do_flush_bogus() argument
1904 do_flush_negative(RES * ssl,struct worker * worker) do_flush_negative() argument
2075 do_forward(RES * ssl,struct worker * worker,char * args) do_forward() argument
2154 do_forward_add(RES * ssl,struct worker * worker,char * args) do_forward_add() argument
2190 do_forward_remove(RES * ssl,struct worker * worker,char * args) do_forward_remove() argument
2211 do_stub_add(RES * ssl,struct worker * worker,char * args) do_stub_add() argument
2267 do_stub_remove(RES * ssl,struct worker * worker,char * args) do_stub_remove() argument
2291 do_insecure_add(RES * ssl,struct worker * worker,char * arg) do_insecure_add() argument
2312 do_insecure_remove(RES * ssl,struct worker * worker,char * arg) do_insecure_remove() argument
2327 do_insecure_list(RES * ssl,struct worker * worker) do_insecure_list() argument
2343 do_status(RES * ssl,struct worker * worker) do_status() argument
2451 do_dump_requestlist(RES * ssl,struct worker * worker) do_dump_requestlist() argument
2545 do_dump_infra(RES * ssl,struct worker * worker) do_dump_infra() argument
2557 do_log_reopen(RES * ssl,struct worker * worker) do_log_reopen() argument
2566 do_auth_zone_reload(RES * ssl,struct worker * worker,char * arg) do_auth_zone_reload() argument
2645 do_auth_zone_transfer(RES * ssl,struct worker * worker,char * arg) do_auth_zone_transfer() argument
2665 do_set_option(RES * ssl,struct worker * worker,char * arg) do_set_option() argument
2694 do_get_option(RES * ssl,struct worker * worker,char * arg) do_get_option() argument
2706 do_list_forwards(RES * ssl,struct worker * worker) do_list_forwards() argument
2738 do_list_stubs(RES * ssl,struct worker * worker) do_list_stubs() argument
2822 do_list_local_data(RES * ssl,struct worker * worker,struct local_zones * zones) do_list_local_data() argument
2861 do_view_list_local_zones(RES * ssl,struct worker * worker,char * arg) do_view_list_local_zones() argument
2877 do_view_list_local_data(RES * ssl,struct worker * worker,char * arg) do_view_list_local_data() argument
2945 do_ratelimit_list(RES * ssl,struct worker * worker,char * arg) do_ratelimit_list() argument
2964 do_ip_ratelimit_list(RES * ssl,struct worker * worker,char * arg) do_ip_ratelimit_list() argument
2983 do_rpz_enable_disable(RES * ssl,struct worker * worker,char * arg,int enable) do_rpz_enable_disable() argument
3020 do_rpz_enable(RES * ssl,struct worker * worker,char * arg) do_rpz_enable() argument
3027 do_rpz_disable(RES * ssl,struct worker * worker,char * arg) do_rpz_disable() argument
3061 execute_cmd(struct daemon_remote * rc,RES * ssl,char * cmd,struct worker * worker) execute_cmd() argument
3230 daemon_remote_exec(struct worker * worker) daemon_remote_exec() argument
[all...] |
| H A D | cachedump.c | 123 dump_rrset_cache(RES* ssl, struct worker* worker) in dump_rrset_cache()
252 dump_msg_lruhash(RES* ssl, struct worker* worker, struct lruhash* h) in dump_msg_lruhash()
280 dump_msg_cache(RES* ssl, struct worker* worker) in dump_msg_cache()
297 dump_cache(RES* ssl, struct worker* worker) in dump_cache()
383 struct packed_rrset_data* d, struct worker* worker) in move_into_cache()
442 load_rrset(RES* ssl, sldns_buffer* buf, struct worker* worker) in load_rrset()
526 load_rrset_cache(RES* ssl, struct worker* worker) in load_rrset_cache()
582 load_ref(RES* ssl, sldns_buffer* buf, struct worker* worker, in load_ref()
627 load_msg(RES* ssl, sldns_buffer* buf, struct worker* worker) in load_msg()
704 load_msg_cache(RES* ssl, struct worker* worker) in load_msg_cache()
[all …]
|
| H A D | remote.h | 91 struct worker* worker; member
|
| H A D | daemon.c | 617 struct worker* worker = (struct worker*)arg; thread_start() local
[all...] |
| /freebsd-src/sbin/dump/ |
| H A D | tape.c | 92 static struct worker { struct
98 int fd; /* FD for this worker */ argument
99 int pid; /* PID for this worker */ argument
100 int sent; /* 1 == we've sent this worker requests */ argument
104 static struct worker *wp; argument
757 worker(int cmd, int worker_number) in worker() function
|
| /freebsd-src/tools/regression/gaithrstress/ |
| H A D | gaithrstress.c | 44 struct worker { struct
50 static volatile int workers_stop = 0; argument
|
| /freebsd-src/contrib/lib9p/ |
| H A D | threadpool.c | 45 struct l9p_worker *worker = arg; in l9p_responder() local
82 struct l9p_worker *worker = arg; in l9p_worker() local
158 struct l9p_worker *worker; in l9p_threadpool_init() local
403 struct l9p_worker *worker, *tmp; in l9p_threadpool_shutdown() local
|
| /freebsd-src/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()
130 kthread_queue_work(struct kthread_worker *worker, struct kthread_work *work) in kthread_queue_work()
161 kthread_flush_worker(struct kthread_worker *worker) in kthread_flush_worker()
|
| /freebsd-src/crypto/openssl/crypto/bn/ |
| H A D | bn_sparc.c | 50 bn_mul_mont_f worker = funcs[num / 16 - 1]; in bn_mul_mont() local
|
| /freebsd-src/contrib/xz/src/liblzma/common/ |
| H A D | outqueue.c | 182 lzma_outq_get_buf(lzma_outq *outq, void *worker) in lzma_outq_get_buf()
275 void (*enable_partial_output)(void *worker)) in lzma_outq_enable_partial_output()
|
| H A D | outqueue.h | 28 void *worker; member
|
| /freebsd-src/contrib/unbound/util/shm_side/ |
| H A D | shm_main.c | 224 void shm_main_run(struct worker *worker) in shm_main_run()
|
| /freebsd-src/contrib/netbsd-tests/rump/rumpkern/h_client/ |
| H A D | h_reconcli.c | 52 worker(void *arg) in worker() function
|
| /freebsd-src/sys/contrib/zstd/lib/common/ |
| H A D | threading.c | 38 static unsigned __stdcall worker(void *arg) in worker() function
|
| /freebsd-src/sys/compat/linuxkpi/common/src/ |
| H A D | linux_kthread.c | 178 struct kthread_worker *worker = context; in lkpi_kthread_worker_init_fn() local
|
| /freebsd-src/contrib/unbound/services/ |
| H A D | authzone.h | 296 struct worker* worker; member
322 struct worker* worker; member
370 struct worker* worker; member
|
| /freebsd-src/contrib/processor-trace/libipt/test/src/ |
| H A D | ptunit-block_cache.c | 254 static int worker(void *arg) in worker() function
|
| /freebsd-src/sys/dev/mlx5/mlx5_en/ |
| H A D | en_rl.h | 133 struct mlx5e_rl_worker *worker; member
|
| /freebsd-src/tests/sys/cddl/zfs/tests/txg_integrity/ |
| H A D | fsync_integrity.c | 378 worker(void* args) in worker() function
|
| /freebsd-src/usr.sbin/bhyve/ |
| H A D | pci_virtio_scsi.c | 261 struct pci_vtscsi_worker *worker = (struct pci_vtscsi_worker *)arg; in pci_vtscsi_proc() local
650 struct pci_vtscsi_worker *worker; in pci_vtscsi_init_queue() local
|
| /freebsd-src/sys/dev/hptrr/ |
| H A D | os_bsd.h | 179 struct task worker; member
|
| /freebsd-src/sys/dev/hpt27xx/ |
| H A D | os_bsd.h | 176 struct task worker; member
|