Searched refs:worker (Results 1 - 25 of 52) sorted by relevance

123

/freebsd-13-stable/contrib/unbound/daemon/
H A Dcachedump.h74 struct worker;
80 * @param worker: worker that is available (buffers, etc) and has
84 int dump_cache(RES* ssl, struct worker* worker);
89 * @param worker: worker that is available (buffers, etc) and has
93 int load_cache(RES* ssl, struct worker* worker);
98 * @param worker
[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,
75 * @param worker: the worker that is executing (the first worker)
[all...]
H A Dworker.c2 * daemon/worker.c - worker that handles a pending list of requests.
39 * This file implements the worker that handles callbacks on events, for
46 #include "daemon/worker.h"
114 worker_mem_report(struct worker* ATTR_UNUSED(worker),
129 front = listen_get_mem(worker->front);
130 back = outnet_get_mem(worker->back);
131 msg = slabhash_get_mem(worker->env.msg_cache);
132 rrset = slabhash_get_mem(&worker
230 worker_send_cmd(struct worker* worker, enum worker_commands cmd) argument
243 struct worker* worker = q->env->worker; local
275 struct worker* worker = e->qstate->env->worker; local
308 worker_err_ratelimit(struct worker* worker, int err) argument
328 worker_check_request(sldns_buffer* pkt, struct worker* worker) argument
383 struct worker* worker = (struct worker*)arg; local
470 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) argument
577 apply_respip_action(struct worker* worker, const struct query_info* qinfo, struct respip_client_info* cinfo, struct reply_info* rep, struct comm_reply* repinfo, struct ub_packed_rrset_key** alias_rrset, struct reply_info** encode_repp, struct auth_zones* az) argument
631 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) argument
783 reply_and_prefetch(struct worker* worker, struct query_info* qinfo, uint16_t flags, struct comm_reply* repinfo, time_t leeway, int noreply) argument
817 chaos_replystr(sldns_buffer* pkt, char** str, int num, struct edns_data* edns, struct worker* worker, struct comm_reply* repinfo) argument
861 chaos_replyonestr(sldns_buffer* pkt, const char* str, struct edns_data* edns, struct worker* worker, struct comm_reply* repinfo) argument
1046 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) argument
1080 deny_refuse_all(struct comm_point* c, enum acl_access acl, struct worker* worker, struct comm_reply* repinfo) argument
1087 deny_refuse_non_local(struct comm_point* c, enum acl_access acl, struct worker* worker, struct comm_reply* repinfo) argument
1097 struct worker* worker = (struct worker*)arg; local
1628 struct worker* worker = (struct worker*)arg; local
1657 worker_restart_timer(struct worker* worker) argument
1671 struct worker* worker = (struct worker*)arg; local
1688 struct worker* worker = (struct worker*)arg; local
1702 struct worker* worker = (struct worker*)calloc(1, local
1732 worker_init(struct worker* worker, struct config_file *cfg, struct listen_port* ports, int do_sigs) argument
1947 worker_work(struct worker* worker) argument
1953 worker_delete(struct worker* worker) argument
2003 struct worker* worker = q->env->worker; local
2022 struct worker* worker = (struct worker*)arg; local
2027 worker_stats_clear(struct worker* worker) argument
2037 struct worker* worker = (struct worker*)arg; local
2045 struct worker* worker = (struct worker*)arg; local
[all...]
H A Dworker.h2 * daemon/worker.h - worker that handles a pending list of requests.
39 * This file describes the worker structure that holds a list of
46 #include "libunbound/worker.h"
66 /** worker commands */
68 /** make the worker quit */
82 struct worker { struct
89 /** pipe, for commands for this worker */
91 /** the event base this worker works with */
97 /** ports to be used by this worker
[all...]
H A Dstats.c49 #include "daemon/worker.h"
93 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker) argument
96 stats->sum_query_list_size += worker->env.mesh->all.count;
97 if((long long)worker->env.mesh->all.count > stats->max_query_list_size)
98 stats->max_query_list_size = (long long)worker->env.mesh->all.count;
101 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker) argument
105 stats->sum_query_list_size += worker->env.mesh->all.count;
106 if((long long)worker
110 server_stats_log(struct ub_server_stats* stats, struct worker* worker, int threadnum) argument
137 set_subnet_stats(struct worker* worker, struct ub_server_stats* svr, int reset) argument
162 set_neg_cache_stats(struct worker* worker, struct ub_server_stats* svr, int reset) argument
186 get_rrset_bogus(struct worker* worker, int reset) argument
204 get_queries_ratelimit(struct worker* worker, int reset) argument
223 get_dnscrypt_cache_miss(struct worker* worker, int reset) argument
239 get_dnscrypt_replay(struct worker* worker, int reset) argument
254 server_stats_compile(struct worker* worker, struct ub_stats_info* s, int reset) argument
366 server_stats_obtain(struct worker* worker, struct worker* who, struct ub_stats_info* s, int reset) argument
391 server_stats_reply(struct worker* worker, int reset) argument
[all...]
H A Dremote.h54 struct worker;
90 /** the worker for this remote control */
91 struct worker* worker; member in struct:daemon_remote
153 * @param worker: worker with communication base. and links to command channels.
157 struct listen_port* ports, struct worker* worker);
173 * @param worker: this worker (th
[all...]
H A Dremote.c58 #include "daemon/worker.h"
250 rc->worker = NULL;
402 n->com = comm_point_create_raw(rc->worker->base, fd, 0,
412 struct listen_port* ports, struct worker* worker)
415 rc->worker = worker;
473 n->c = comm_point_create_raw(rc->worker->base, newfd, 0,
665 do_stop(RES* ssl, struct worker* worker) argument
411 daemon_remote_open_accept(struct daemon_remote* rc, struct listen_port* ports, struct worker* worker) argument
674 do_reload(RES* ssl, struct worker* worker) argument
780 print_mem(RES* ssl, struct worker* worker, struct daemon* daemon, struct ub_stats_info* s) argument
863 print_uptime(RES* ssl, struct worker* worker, int reset) argument
1089 do_stats(RES* ssl, struct worker* worker, int reset) argument
1378 do_view_zone_add(RES* ssl, struct worker* worker, char* arg) argument
1411 do_view_zone_remove(RES* ssl, struct worker* worker, char* arg) argument
1434 do_view_data_add(RES* ssl, struct worker* worker, char* arg) argument
1459 do_view_datas_add(RES* ssl, struct worker* worker, char* arg) argument
1481 do_view_data_remove(RES* ssl, struct worker* worker, char* arg) argument
1504 do_view_datas_remove(RES* ssl, struct worker* worker, char* arg) argument
1525 do_lookup(RES* ssl, struct worker* worker, char* arg) argument
1538 do_cache_remove(struct worker* worker, uint8_t* nm, size_t nmlen, uint16_t t, uint16_t c) argument
1563 do_flush_type(RES* ssl, struct worker* worker, char* arg) argument
1583 do_flush_stats(RES* ssl, struct worker* worker) argument
1594 struct worker* worker; member in struct:del_info
1638 do_flush_infra(RES* ssl, struct worker* worker, char* arg) argument
1672 do_flush_requestlist(RES* ssl, struct worker* worker) argument
1731 do_flush_zone(RES* ssl, struct worker* worker, char* arg) argument
1809 do_flush_bogus(RES* ssl, struct worker* worker) argument
1884 do_flush_negative(RES* ssl, struct worker* worker) argument
2051 do_forward(RES* ssl, struct worker* worker, char* args) argument
2127 do_forward_add(RES* ssl, struct worker* worker, char* args) argument
2155 do_forward_remove(RES* ssl, struct worker* worker, char* args) argument
2172 do_stub_add(RES* ssl, struct worker* worker, char* args) argument
2213 do_stub_remove(RES* ssl, struct worker* worker, char* args) argument
2231 do_insecure_add(RES* ssl, struct worker* worker, char* arg) argument
2252 do_insecure_remove(RES* ssl, struct worker* worker, char* arg) argument
2267 do_insecure_list(RES* ssl, struct worker* worker) argument
2283 do_status(RES* ssl, struct worker* worker) argument
2391 do_dump_requestlist(RES* ssl, struct worker* worker) argument
2485 do_dump_infra(RES* ssl, struct worker* worker) argument
2497 do_log_reopen(RES* ssl, struct worker* worker) argument
2506 do_auth_zone_reload(RES* ssl, struct worker* worker, char* arg) argument
2539 do_auth_zone_transfer(RES* ssl, struct worker* worker, char* arg) argument
2559 do_set_option(RES* ssl, struct worker* worker, char* arg) argument
2588 do_get_option(RES* ssl, struct worker* worker, char* arg) argument
2600 do_list_forwards(RES* ssl, struct worker* worker) argument
2628 do_list_stubs(RES* ssl, struct worker* worker) argument
2708 do_list_local_data(RES* ssl, struct worker* worker, struct local_zones* zones) argument
2747 do_view_list_local_zones(RES* ssl, struct worker* worker, char* arg) argument
2763 do_view_list_local_data(RES* ssl, struct worker* worker, char* arg) argument
2829 do_ratelimit_list(RES* ssl, struct worker* worker, char* arg) argument
2847 do_ip_ratelimit_list(RES* ssl, struct worker* worker, char* arg) argument
2865 do_rpz_enable_disable(RES* ssl, struct worker* worker, char* arg, int enable) argument
2902 do_rpz_enable(RES* ssl, struct worker* worker, char* arg) argument
2909 do_rpz_disable(RES* ssl, struct worker* worker, char* arg) argument
2942 execute_cmd(struct daemon_remote* rc, RES* ssl, char* cmd, struct worker* worker) argument
3124 daemon_remote_exec(struct worker* worker) argument
[all...]
H A Dcachedump.c46 #include "daemon/worker.h"
121 dump_rrset_cache(RES* ssl, struct worker* worker) argument
123 struct rrset_cache* r = worker->env.rrset_cache;
129 *worker->env.now)) {
221 /** copy msg to worker pad */
249 dump_msg_lruhash(RES* ssl, struct worker* worker, struct lruhash* h) argument
258 regional_free_all(worker->scratchpad);
260 /* make copy of rrset in worker buffe
277 dump_msg_cache(RES* ssl, struct worker* worker) argument
294 dump_cache(RES* ssl, struct worker* worker) argument
379 move_into_cache(struct ub_packed_rrset_key* k, struct packed_rrset_data* d, struct worker* worker) argument
438 load_rrset(RES* ssl, sldns_buffer* buf, struct worker* worker) argument
522 load_rrset_cache(RES* ssl, struct worker* worker) argument
578 load_ref(RES* ssl, sldns_buffer* buf, struct worker* worker, struct regional *region, struct ub_packed_rrset_key** rrset, int* go_on) argument
623 load_msg(RES* ssl, sldns_buffer* buf, struct worker* worker) argument
689 load_msg_cache(RES* ssl, struct worker* worker) argument
702 load_cache(RES* ssl, struct worker* worker) argument
713 print_dp_details(RES* ssl, struct worker* worker, struct delegpt* dp) argument
817 print_deleg_lookup(RES* ssl, struct worker* worker, uint8_t* nm, size_t nmlen, int ATTR_UNUSED(nmlabs)) argument
[all...]
H A Ddaemon.h49 struct worker;
73 * Structure holding worker list.
85 /** array of listening ports, opened. Listening ports per worker,
86 * or just one element[0] shared by the worker threads. */
96 /** remote control connections management (for first worker) */
102 /** the worker entries */
103 struct worker** workers;
165 * Close off the worker thread information.
H A Ddaemon.c70 #include "daemon/worker.h"
179 * @param wrk: worker that handles signals.
182 signal_handling_playback(struct worker* wrk)
395 daemon->env->worker = NULL;
436 * Allocate empty worker structures. With backptr and thread-number,
467 daemon->workers = (struct worker**)calloc((size_t)daemon->num,
468 sizeof(struct worker*));
485 fatal_exit("could not create worker");
521 struct worker* worker local
[all...]
/freebsd-13-stable/contrib/unbound/util/shm_side/
H A Dshm_main.h45 struct worker;
66 void shm_main_run(struct worker *worker);
H A Dshm_main.c55 #include "daemon/worker.h"
218 void shm_main_run(struct worker *worker) argument
227 verbose(VERB_DETAIL, "SHM run - worker [%d] - daemon [%p] - timenow(%u) - timeboot(%u)",
228 worker->thread_num, worker->daemon, (unsigned)worker->env.now_tv->tv_sec, (unsigned)worker->daemon->time_boot.tv_sec);
231 offset = worker->thread_num + 1;
232 stat_total = worker
[all...]
/freebsd-13-stable/contrib/lib9p/
H A Dthreadpool.c45 struct l9p_worker *worker = arg; local
48 tp = worker->ltw_tp;
52 while (STAILQ_EMPTY(&tp->ltp_replyq) && !worker->ltw_exiting)
54 if (worker->ltw_exiting) {
82 struct l9p_worker *worker = arg; local
85 tp = worker->ltw_tp;
88 while (STAILQ_EMPTY(&tp->ltp_workq) && !worker->ltw_exiting)
90 if (worker->ltw_exiting)
97 req->lr_worker = worker;
158 struct l9p_worker *worker; local
403 struct l9p_worker *worker, *tmp; local
[all...]
/freebsd-13-stable/contrib/netbsd-tests/rump/rumpkern/h_client/
H A Dh_reconcli.c52 worker(void *arg) function
106 pthread_create(&w1, NULL, worker, NULL);
107 pthread_create(&w2, NULL, worker, NULL);
108 pthread_create(&w3, NULL, worker, NULL);
109 pthread_create(&w4, NULL, worker, NULL);
/freebsd-13-stable/sys/contrib/zstd/lib/common/
H A Dthreading.c38 static unsigned __stdcall worker(void *arg) function
51 thread->handle = (HANDLE) _beginthreadex(NULL, 0, worker, thread, 0, NULL);
/freebsd-13-stable/contrib/unbound/services/
H A Dauthzone.h58 struct worker;
124 /** the zone has expired (enabled by the xfer worker), fallback
184 * owner by a worker (worker-num). A worker can pick up a task and then do
185 * it. This means the events (timeouts, sockets) are for that worker.
188 * They don't have locks themselves, the worker (that owns it) uses it,
199 * lock this lock. Then a worker can reassign itself to fill up
201 * Once it has the task assigned to it, the worker can access the
278 * worker ca
285 struct worker* worker; member in struct:auth_nextprobe
311 struct worker* worker; member in struct:auth_probe
359 struct worker* worker; member in struct:auth_transfer
[all...]
/freebsd-13-stable/usr.sbin/unbound/daemon/
H A DMakefile11 ub_event.c unbound.c worker.c
/freebsd-13-stable/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/src/
H A DTestDrop.java127 Runnable worker = new Runnable() {
134 Thread t = new Thread(worker);
/freebsd-13-stable/usr.sbin/bhyve/
H A Dpci_virtio_scsi.c264 struct pci_vtscsi_worker *worker = (struct pci_vtscsi_worker *)arg; local
265 struct pci_vtscsi_queue *q = worker->vsw_queue;
273 && !worker->vsw_exiting)
276 if (worker->vsw_exiting)
639 struct pci_vtscsi_worker *worker; local
653 worker = calloc(1, sizeof(struct pci_vtscsi_worker));
654 worker->vsw_queue = queue;
656 pthread_create(&worker->vsw_thread, NULL, &pci_vtscsi_proc,
657 (void *)worker);
660 pthread_set_name_np(worker
[all...]
/freebsd-13-stable/lib/libmilter/
H A DMakefile28 signal.c sm_gethost.c errstring.c strl.c worker.c
/freebsd-13-stable/contrib/unbound/util/
H A Dmodule.c97 if(env->worker) {
132 if(env->worker) {
H A Dmodule.h168 struct worker;
468 /** internal data for daemon - worker thread. */
469 struct worker* worker; member in struct:module_env
470 /** the worker event base */
500 * iterator forwarder information. per-thread, created by worker */
503 * iterator forwarder information. per-thread, created by worker.
/freebsd-13-stable/crypto/openssl/crypto/
H A Dsparcv9cap.c61 bn_mul_mont_f worker = funcs[num / 16 - 1]; local
63 if ((*worker) (rp, ap, bp, np, n0))
66 if ((*worker) (rp, ap, bp, np, n0))
/freebsd-13-stable/tools/regression/gaithrstress/
H A Dgaithrstress.c46 struct worker { struct
104 struct worker *w = arg;
189 struct worker *workers;
240 printf("Starting %lu worker%.*s: ", nworkers, nworkers > 1, "s");
245 err(1, "creating worker %zu", i);
254 printf("Stopping %lu worker%.*s: ", nworkers, nworkers > 1, "s");
/freebsd-13-stable/sbin/dump/
H A Dtape.c78 static void worker(int, int);
86 * are exported to several worker processes. While one worker writes the
98 #define WORKERS 3 /* 1 worker writing, 1 reading, 1 for slack */
99 static struct worker { struct
105 int fd; /* FD for this worker */
106 int pid; /* PID for this worker */
107 int sent; /* 1 == we've sent this worker requests */
111 static struct worker *wp;
119 /* received the SIGUSR2 signal from the prev worker
765 worker(int cmd, int worker_number) function
[all...]

Completed in 295 milliseconds

123