Home
last modified time | relevance | path

Searched defs:worker (Results 1 – 25 of 54) sorted by relevance

123

/netbsd-src/external/bsd/unbound/dist/daemon/
H A Dworker.h82 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 Dstats.c96 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker) in server_stats_querymiss()
104 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker) in server_stats_prefetch()
113 void server_stats_log(struct ub_server_stats* stats, struct worker* worker, in server_stats_log()
140 set_subnet_stats(struct worker* worker, struct ub_server_stats* svr, in set_subnet_stats()
165 set_neg_cache_stats(struct worker* worker, struct ub_server_stats* svr, in set_neg_cache_stats()
189 get_rrset_bogus(struct worker* worker, int reset) in get_rrset_bogus()
207 get_queries_ratelimit(struct worker* worker, int reset) in get_queries_ratelimit()
226 get_dnscrypt_cache_miss(struct worker* worker, int reset) in get_dnscrypt_cache_miss()
242 get_dnscrypt_replay(struct worker* worker, int reset) in get_dnscrypt_replay()
257 server_stats_compile(struct worker* worker, struct ub_stats_info* s, int reset) in server_stats_compile()
[all …]
H A Dworker.c117 worker_mem_report(struct worker* ATTR_UNUSED(worker), in worker_mem_report()
233 worker_send_cmd(struct worker* worker, enum worker_commands cmd) in worker_send_cmd()
246 struct worker* worker = e->qstate->env->worker; in worker_handle_service_reply() local
279 worker_err_ratelimit(struct worker* worker, int err) in worker_err_ratelimit()
308 worker_check_request(sldns_buffer* pkt, struct worker* worker, in worker_check_request()
376 struct worker* worker = (struct worker*)arg; in worker_handle_control_cmd() local
463 answer_norec_from_cache(struct worker* worker, struct query_info* qinfo, in answer_norec_from_cache()
586 apply_respip_action(struct worker* worker, const struct query_info* qinfo, in apply_respip_action()
642 answer_from_cache(struct worker* worker, struct query_info* qinfo, in answer_from_cache()
826 reply_and_prefetch(struct worker* worker, struct query_info* qinfo, in reply_and_prefetch()
[all …]
H A Dremote.c383 struct listen_port* ports, struct worker* worker) in daemon_remote_open_accept()
638 do_stop(RES* ssl, struct worker* worker) in do_stop()
647 do_reload(RES* ssl, struct worker* worker, int reuse_cache) in do_reload()
764 print_mem(RES* ssl, struct worker* worker, struct daemon* daemon, in print_mem()
847 print_uptime(RES* ssl, struct worker* worker, int reset) in print_uptime()
1084 do_stats(RES* ssl, struct worker* worker, int reset) in do_stats()
1395 do_view_zone_add(RES* ssl, struct worker* worker, char* arg) in do_view_zone_add()
1428 do_view_zone_remove(RES* ssl, struct worker* worker, char* arg) in do_view_zone_remove()
1451 do_view_data_add(RES* ssl, struct worker* worker, char* arg) in do_view_data_add()
1476 do_view_datas_add(RES* ssl, struct worker* worker, char* arg) in do_view_datas_add()
[all …]
H A Dcachedump.c123 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 …]
/netbsd-src/sbin/dump/
H A Dtape.c96 struct worker { struct
102 int fd; /* FD for this worker */ argument
103 int pid; /* PID for this worker */ argument
104 int sent; /* 1 == we've sent this worker requests */ argument
108 struct worker *wp; argument
/netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/netmgr/
H A Dnetmgr.c330 isc__networker_t *worker = &mgr->workers[i]; in isc__netmgr_create() local
387 isc__networker_t *worker = &mgr->workers[i]; in nm_destroy() local
399 isc__networker_t *worker = &mgr->workers[i]; in nm_destroy() local
439 enqueue_pause(isc__networker_t *worker) { in enqueue_pause()
446 isc__nm_async_pause(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_pause()
466 isc__networker_t *worker = &mgr->workers[i]; in isc_nm_pause() local
490 enqueue_resume(isc__networker_t *worker) { in enqueue_resume()
497 isc__nm_async_resume(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_resume()
515 isc__networker_t *worker = &mgr->workers[i]; in isc_nm_resume() local
715 isc__networker_t *worker = (isc__networker_t *)worker0; in nm_thread() local
[all …]
H A Dtcp.c120 isc__networker_t *worker = NULL; in tcp_connect_direct() local
194 isc__nm_async_tcpconnect(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpconnect()
515 isc__nm_async_tcplisten(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcplisten()
684 isc__nm_async_tcpstop(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpstop()
770 isc__nm_async_tcpstartread(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpstartread()
821 isc__nm_async_tcppauseread(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcppauseread()
950 isc__nm_async_tcpaccept(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpaccept()
967 isc__networker_t *worker = NULL; in accept_connection() local
1131 isc__nm_async_tcpsend(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpsend()
1355 isc__nm_async_tcpclose(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpclose()
[all …]
H A Dtcpdns.c85 isc__networker_t *worker = NULL; in tcpdns_connect_direct() local
165 isc__nm_async_tcpdnsconnect(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpdnsconnect()
481 isc__nm_async_tcpdnslisten(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpdnslisten()
650 isc__nm_async_tcpdnsstop(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpdnsstop()
737 isc__nm_async_tcpdnsread(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpdnsread()
930 isc__nm_async_tcpdnsaccept(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpdnsaccept()
947 isc__networker_t *worker = NULL; in accept_connection() local
1141 isc__nm_async_tcpdnssend(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpdnssend()
1390 isc__nm_async_tcpdnsclose(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpdnsclose()
1472 isc__nm_async_tcpdnscancel(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_tcpdnscancel()
H A Dudp.c217 isc__nm_async_udplisten(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_udplisten()
354 isc__nm_async_udpstop(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_udpstop()
579 isc__nm_async_udpsend(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_udpsend()
664 isc__networker_t *worker = NULL; in udp_connect_direct() local
751 isc__nm_async_udpconnect(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_udpconnect()
933 isc__nm_async_udpread(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_udpread()
1107 isc__nm_async_udpclose(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_udpclose()
1199 isc__nm_async_udpcancel(isc__networker_t *worker, isc__netievent_t *ev0) { in isc__nm_async_udpcancel()
/netbsd-src/external/mpl/bind/dist/lib/isc/netmgr/
H A Dnetmgr.c286 isc__networker_t *worker = &mgr->workers[i]; isc__netmgr_create() local
343 isc__networker_t *worker = &mgr->workers[i]; nm_destroy() local
355 isc__networker_t *worker = &mgr->workers[i]; nm_destroy() local
391 enqueue_pause(isc__networker_t * worker) enqueue_pause() argument
398 isc__nm_async_pause(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_pause() argument
418 isc__networker_t *worker = &mgr->workers[i]; isc_nm_pause() local
441 enqueue_resume(isc__networker_t * worker) enqueue_resume() argument
448 isc__nm_async_resume(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_resume() argument
466 isc__networker_t *worker = &mgr->workers[i]; isc_nm_resume() local
692 isc__networker_t *worker = (isc__networker_t *)worker0; nm_thread() local
764 process_all_queues(isc__networker_t * worker) process_all_queues() argument
800 isc__networker_t *worker = (isc__networker_t *)handle->loop->data; async_cb() local
812 isc__nm_async_stop(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_stop() argument
823 isc__networker_t *worker = NULL; isc_nm_task_enqueue() local
850 isc__nm_async_privilegedtask(worker,ev0) global() argument
854 isc__nm_async_task(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_task() argument
884 wait_for_priority_queue(isc__networker_t * worker) wait_for_priority_queue() argument
900 drain_queue(isc__networker_t * worker,netievent_type_t type) drain_queue() argument
934 process_netievent(isc__networker_t * worker,isc__netievent_t * ievent) process_netievent() argument
1015 process_queue(isc__networker_t * worker,netievent_type_t type) process_queue() argument
1142 isc__nm_maybe_enqueue_ievent(isc__networker_t * worker,isc__netievent_t * event) isc__nm_maybe_enqueue_ievent() argument
1157 isc__nm_enqueue_ievent(isc__networker_t * worker,isc__netievent_t * event) isc__nm_enqueue_ievent() argument
1641 isc__networker_t *worker = NULL; isc__nm_free_uvbuf() local
2224 isc__networker_t *worker = NULL; isc__nm_alloc_cb() local
2776 isc__networker_t *worker = &listener->mgr->workers[i]; isc__nmsocket_stop() local
2801 isc__nm_async_sockstop(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_sockstop() argument
2856 isc__nm_async_connectcb(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_connectcb() argument
2897 isc__nm_async_readcb(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_readcb() argument
2941 isc__nm_async_sendcb(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_sendcb() argument
2960 isc__nm_async_close(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_close() argument
2974 isc__nm_async_detach(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_detach() argument
3091 isc__nm_async_shutdown(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_shutdown() argument
3587 isc__networker_t *worker = NULL; isc_nm_work_offload() local
3774 isc__nm_async_settlsctx(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_settlsctx() argument
[all...]
H A Dtcp.c120 isc__networker_t *worker = NULL; tcp_connect_direct() local
193 isc__nm_async_tcpconnect(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpconnect() argument
522 isc__nm_async_tcplisten(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcplisten() argument
683 isc__nm_async_tcpstop(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpstop() argument
767 isc__nm_async_tcpstartread(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpstartread() argument
818 isc__nm_async_tcppauseread(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcppauseread() argument
946 isc__nm_async_tcpaccept(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpaccept() argument
963 isc__networker_t *worker = NULL; accept_connection() local
1127 isc__nm_async_tcpsend(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpsend() argument
1351 isc__nm_async_tcpclose(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpclose() argument
1436 isc__nm_async_tcpcancel(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tcpcancel() argument
[all...]
H A Dtcpdns.c
H A Dtlsdns.c
H A Dudp.c257 isc__networker_t *worker = NULL; route_connect_direct() local
312 isc__nm_async_routeconnect(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_routeconnect() argument
420 isc__nm_async_udplisten(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udplisten() argument
543 isc__nm_async_udpstop(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpstop() argument
770 isc__nm_async_udpsend(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpsend() argument
855 isc__networker_t *worker = NULL; udp_connect_direct() local
939 isc__nm_async_udpconnect(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpconnect() argument
1124 isc__nm_async_udpread(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpread() argument
1299 isc__nm_async_udpclose(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpclose() argument
1395 isc__nm_async_udpcancel(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_udpcancel() argument
[all...]
H A Dtlsstream.c810 isc__nm_async_tlssend(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tlssend() argument
863 isc__nm_async_tlsstartread(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tlsstartread() argument
975 isc__nm_async_tlsclose(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tlsclose() argument
1127 isc__nm_async_tlscancel(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tlscancel() argument
1140 isc__nm_async_tlsdobio(isc__networker_t * worker,isc__netievent_t * ev0) isc__nm_async_tlsdobio() argument
[all...]
/netbsd-src/external/bsd/unbound/dist/winrc/
H A Dwin_svc.c517 struct worker* worker = (struct worker*)arg; in worker_win_stop_cb() local
596 struct worker* worker = (struct worker*)arg; in wsvc_cron_cb() local
607 void wsvc_setup_worker(struct worker* worker) in wsvc_setup_worker()
627 void wsvc_desetup_worker(struct worker* ATTR_UNUSED(worker)) in wsvc_desetup_worker()
/netbsd-src/external/mit/libuv/dist/docs/code/multi-echo-server/
H A Dmain.c42 struct child_worker *worker = &workers[round_robin_counter]; in on_new_connection() local
75 struct child_worker *worker = &workers[cpu_count]; in setup_workers() local
/netbsd-src/crypto/external/bsd/openssl/dist/crypto/bn/
H A Dbn_sparc.c50 bn_mul_mont_f worker = funcs[num / 16 - 1]; in bn_mul_mont() local
/netbsd-src/sys/net/npf/
H A Dnpf_worker.c53 lwp_t * worker[]; member
118 lwp_t *worker; in npf_worker_sysfini() local
/netbsd-src/external/bsd/unbound/dist/util/shm_side/
H A Dshm_main.c224 void shm_main_run(struct worker *worker) in shm_main_run()
/netbsd-src/sys/external/bsd/drm2/dist/include/drm/
H A Ddrm_flip_work.h80 struct work_struct worker; member
/netbsd-src/usr.sbin/npf/npftest/libnpftest/
H A Dnpf_perf_test.c28 worker(void *arg) in worker() function
/netbsd-src/external/bsd/unbound/dist/testcode/
H A Dtestbound.c536 struct worker* ATTR_UNUSED(worker)) in daemon_remote_open_accept()
572 void wsvc_setup_worker(struct worker* ATTR_UNUSED(worker)) in wsvc_setup_worker()
579 void wsvc_desetup_worker(struct worker* ATTR_UNUSED(worker)) in wsvc_desetup_worker()
/netbsd-src/tests/rump/rumpkern/h_client/
H A Dh_reconcli.c52 worker(void *arg) in worker() function

123