Symbol: worker
regress/sys/kern/noexec/noexec.c
351
if ((error = pthread_create(&th, NULL, worker, (void *)&ctx)))
sbin/unwind/libunbound/daemon/remote.h
175
struct worker* worker;
sbin/unwind/libunbound/daemon/remote.h
232
struct worker* worker;
sbin/unwind/libunbound/daemon/remote.h
290
struct listen_port* ports, struct worker* worker);
sbin/unwind/libunbound/daemon/remote.h
308
void daemon_remote_exec(struct worker* worker);
sbin/unwind/libunbound/daemon/remote.h
351
void fast_reload_thread_start(RES* ssl, struct worker* worker,
sbin/unwind/libunbound/daemon/remote.h
371
void fast_reload_worker_pickup_changes(struct worker* worker);
sbin/unwind/libunbound/daemon/remote.h
55
struct worker;
sbin/unwind/libunbound/daemon/remote.h
93
struct worker* worker;
sbin/unwind/libunbound/daemon/stats.h
100
void server_stats_reply(struct worker* worker, int reset);
sbin/unwind/libunbound/daemon/stats.h
46
struct worker;
sbin/unwind/libunbound/daemon/stats.h
64
void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker);
sbin/unwind/libunbound/daemon/stats.h
67
void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker);
sbin/unwind/libunbound/daemon/stats.h
70
void server_stats_log(struct ub_server_stats* stats, struct worker* worker,
sbin/unwind/libunbound/daemon/stats.h
80
void server_stats_obtain(struct worker* worker, struct worker* who,
sbin/unwind/libunbound/daemon/stats.h
91
void server_stats_compile(struct worker* worker, struct ub_stats_info* s,
sbin/unwind/libunbound/daemon/worker.h
153
struct worker* worker_create(struct daemon* daemon, int id, int* ports, int n);
sbin/unwind/libunbound/daemon/worker.h
164
int worker_init(struct worker* worker, struct config_file *cfg,
sbin/unwind/libunbound/daemon/worker.h
170
void worker_work(struct worker* worker);
sbin/unwind/libunbound/daemon/worker.h
175
void worker_delete(struct worker* worker);
sbin/unwind/libunbound/daemon/worker.h
182
void worker_send_cmd(struct worker* worker, enum worker_commands cmd);
sbin/unwind/libunbound/daemon/worker.h
188
void worker_stats_clear(struct worker* worker);
sbin/unwind/libunbound/libunbound/libunbound.c
173
ctx->env->worker = NULL;
sbin/unwind/libunbound/libunbound/libworker.c
174
w->env->worker = (struct worker*)w;
sbin/unwind/libunbound/libunbound/libworker.c
884
struct libworker* w = (struct libworker*)q->env->worker;
sbin/unwind/libunbound/libunbound/libworker.c
906
struct libworker* lw = (struct libworker*)e->qstate->env->worker;
sbin/unwind/libunbound/services/authzone.c
5402
xfr->task_transfer->worker = NULL;
sbin/unwind/libunbound/services/authzone.c
5592
log_assert(xfr->task_transfer->worker == env->worker);
sbin/unwind/libunbound/services/authzone.c
5636
if(xfr->task_nextprobe->worker == NULL)
sbin/unwind/libunbound/services/authzone.c
6117
if(xfr->task_nextprobe->worker == NULL)
sbin/unwind/libunbound/services/authzone.c
6330
log_assert(xfr->task_transfer->worker == NULL);
sbin/unwind/libunbound/services/authzone.c
6333
xfr->task_transfer->worker = env->worker;
sbin/unwind/libunbound/services/authzone.c
6357
xfr->task_probe->worker = NULL;
sbin/unwind/libunbound/services/authzone.c
6545
if(xfr->task_transfer->worker == NULL) {
sbin/unwind/libunbound/services/authzone.c
6710
if(xfr->task_nextprobe->worker == NULL)
sbin/unwind/libunbound/services/authzone.c
6738
if(xfr->task_nextprobe->worker == NULL)
sbin/unwind/libunbound/services/authzone.c
6750
if(xfr->task_nextprobe->worker == NULL)
sbin/unwind/libunbound/services/authzone.c
6832
xfr->task_nextprobe->worker = NULL;
sbin/unwind/libunbound/services/authzone.c
6887
if(xfr->task_probe->worker == NULL) {
sbin/unwind/libunbound/services/authzone.c
6893
if(xfr->task_transfer->worker == NULL) {
sbin/unwind/libunbound/services/authzone.c
6902
xfr->task_probe->worker = env->worker;
sbin/unwind/libunbound/services/authzone.c
6935
log_assert(xfr->task_nextprobe->worker == NULL ||
sbin/unwind/libunbound/services/authzone.c
6936
xfr->task_nextprobe->worker == env->worker);
sbin/unwind/libunbound/services/authzone.c
6988
xfr->task_nextprobe->worker = env->worker;
sbin/unwind/libunbound/services/authzone.c
6998
if(xfr->task_probe->worker == NULL)
sbin/unwind/libunbound/services/authzone.c
7028
if(x->task_nextprobe && x->task_nextprobe->worker == NULL) {
sbin/unwind/libunbound/services/authzone.c
7059
if(x->task_nextprobe && x->task_nextprobe->worker != NULL) {
sbin/unwind/libunbound/services/authzone.c
7062
if(x->task_probe && x->task_probe->worker != NULL) {
sbin/unwind/libunbound/services/authzone.c
7065
if(x->task_transfer && x->task_transfer->worker != NULL) {
sbin/unwind/libunbound/services/authzone.c
7135
lock_protect(&xfr->lock, &xfr->task_nextprobe->worker,
sbin/unwind/libunbound/services/authzone.c
7136
sizeof(xfr->task_nextprobe->worker));
sbin/unwind/libunbound/services/authzone.c
7137
lock_protect(&xfr->lock, &xfr->task_probe->worker,
sbin/unwind/libunbound/services/authzone.c
7138
sizeof(xfr->task_probe->worker));
sbin/unwind/libunbound/services/authzone.c
7139
lock_protect(&xfr->lock, &xfr->task_transfer->worker,
sbin/unwind/libunbound/services/authzone.c
7140
sizeof(xfr->task_transfer->worker));
sbin/unwind/libunbound/services/authzone.c
8753
void xfr_disown_tasks(struct auth_xfer* xfr, struct worker* worker)
sbin/unwind/libunbound/services/authzone.c
8755
if(xfr->task_nextprobe->worker == worker) {
sbin/unwind/libunbound/services/authzone.c
8758
if(xfr->task_probe->worker == worker) {
sbin/unwind/libunbound/services/authzone.c
8761
if(xfr->task_transfer->worker == worker) {
sbin/unwind/libunbound/services/authzone.h
299
struct worker* worker;
sbin/unwind/libunbound/services/authzone.h
325
struct worker* worker;
sbin/unwind/libunbound/services/authzone.h
373
struct worker* worker;
sbin/unwind/libunbound/services/authzone.h
58
struct worker;
sbin/unwind/libunbound/services/authzone.h
829
void xfr_disown_tasks(struct auth_xfer* xfr, struct worker* worker);
sbin/unwind/libunbound/services/rpz.c
2360
if(ms->env->worker)
sbin/unwind/libunbound/services/rpz.c
2361
ms->env->worker->stats.rpz_action[action]++;
sbin/unwind/libunbound/services/rpz.c
2422
if(ms->env->worker)
sbin/unwind/libunbound/services/rpz.c
2423
ms->env->worker->stats.rpz_action[action]++;
sbin/unwind/libunbound/services/rpz.c
2581
if(ms->env->worker)
sbin/unwind/libunbound/services/rpz.c
2582
ms->env->worker->stats.rpz_action[r->action_override]++;
sbin/unwind/libunbound/util/module.c
266
if(env->worker) {
sbin/unwind/libunbound/util/module.c
301
if(env->worker) {
sbin/unwind/libunbound/util/module.h
168
struct worker;
sbin/unwind/libunbound/util/module.h
487
struct worker* worker;
sbin/unwind/libunbound/validator/autotrust.c
1215
env->worker?*(int*)env->worker:0, llvalue);
sys/dev/pci/drm/amd/amdkfd/kfd_process.c
2266
struct send_exception_work_handler_workarea worker;
sys/dev/pci/drm/amd/amdkfd/kfd_process.c
2268
INIT_WORK_ONSTACK(&worker.work, send_exception_work_handler);
sys/dev/pci/drm/amd/amdkfd/kfd_process.c
2270
worker.p = p;
sys/dev/pci/drm/amd/amdkfd/kfd_process.c
2271
worker.queue_id = queue_id;
sys/dev/pci/drm/amd/amdkfd/kfd_process.c
2272
worker.error_reason = error_reason;
sys/dev/pci/drm/amd/amdkfd/kfd_process.c
2274
schedule_work(&worker.work);
sys/dev/pci/drm/amd/amdkfd/kfd_process.c
2275
flush_work(&worker.work);
sys/dev/pci/drm/amd/amdkfd/kfd_process.c
2276
destroy_work_on_stack(&worker.work);
sys/dev/pci/drm/drm_flip_work.c
104
struct drm_flip_work *work = container_of(w, struct drm_flip_work, worker);
sys/dev/pci/drm/drm_flip_work.c
144
INIT_WORK(&work->worker, flip_worker);
sys/dev/pci/drm/drm_flip_work.c
98
queue_work(wq, &work->worker);
sys/dev/pci/drm/drm_internal.h
111
kthread_flush_worker(vblank->worker);
sys/dev/pci/drm/drm_internal.h
116
if (vblank->worker)
sys/dev/pci/drm/drm_internal.h
117
kthread_destroy_worker(vblank->worker);
sys/dev/pci/drm/drm_linux.c
318
kthread_destroy_worker(struct kthread_worker *worker)
sys/dev/pci/drm/drm_linux.c
320
taskq_destroy(worker->tq);
sys/dev/pci/drm/drm_linux.c
321
free(worker, M_DRM, sizeof(*worker));
sys/dev/pci/drm/drm_linux.c
333
kthread_queue_work(struct kthread_worker *worker, struct kthread_work *work)
sys/dev/pci/drm/drm_linux.c
335
work->tq = worker->tq;
sys/dev/pci/drm/drm_linux.c
356
kthread_flush_worker(struct kthread_worker *worker)
sys/dev/pci/drm/drm_linux.c
361
if (worker->tq)
sys/dev/pci/drm/drm_linux.c
362
taskq_barrier(worker->tq);
sys/dev/pci/drm/drm_vblank_work.c
154
ret = kthread_queue_work(vblank->worker, &work->base);
sys/dev/pci/drm/drm_vblank_work.c
257
kthread_flush_worker(vblank->worker);
sys/dev/pci/drm/drm_vblank_work.c
280
struct kthread_worker *worker;
sys/dev/pci/drm/drm_vblank_work.c
284
worker = kthread_run_worker(0, "card%d-crtc%d",
sys/dev/pci/drm/drm_vblank_work.c
287
if (IS_ERR(worker))
sys/dev/pci/drm/drm_vblank_work.c
288
return PTR_ERR(worker);
sys/dev/pci/drm/drm_vblank_work.c
290
vblank->worker = worker;
sys/dev/pci/drm/drm_vblank_work.c
293
sched_set_fifo(worker->task);
sys/dev/pci/drm/drm_vblank_work.c
64
kthread_queue_work(vblank->worker, &work->base);
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
184
struct kthread_worker *worker;
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
367
struct kthread_worker *worker;
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
372
worker = kthread_run_worker(0, "igt/parallel:%s",
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
374
if (IS_ERR(worker)) {
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
375
err = PTR_ERR(worker);
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
379
data[n].worker = worker;
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
395
kthread_queue_work(data[n].worker, &data[n].work);
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
422
if (data[n].worker)
sys/dev/pci/drm/i915/gem/selftests/i915_gem_context.c
423
kthread_destroy_worker(data[n].worker);
sys/dev/pci/drm/i915/gt/selftest_execlists.c
3557
struct kthread_worker *worker[I915_NUM_ENGINES] = {};
sys/dev/pci/drm/i915/gt/selftest_execlists.c
3577
worker[id] = kthread_run_worker(0, "igt/smoke:%d", id);
sys/dev/pci/drm/i915/gt/selftest_execlists.c
3578
if (IS_ERR(worker[id])) {
sys/dev/pci/drm/i915/gt/selftest_execlists.c
3579
err = PTR_ERR(worker[id]);
sys/dev/pci/drm/i915/gt/selftest_execlists.c
3584
kthread_queue_work(worker[id], &arg[id].work);
sys/dev/pci/drm/i915/gt/selftest_execlists.c
3589
if (IS_ERR_OR_NULL(worker[id]))
sys/dev/pci/drm/i915/gt/selftest_execlists.c
3598
kthread_destroy_worker(worker[id]);
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
1014
struct kthread_worker *worker;
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
1028
worker = kthread_run_worker(0, "igt/%s",
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
1030
if (IS_ERR(worker)) {
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
1031
err = PTR_ERR(worker);
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
1037
threads[tmp].worker = worker;
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
1040
kthread_queue_work(threads[tmp].worker,
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
1191
if (!threads[tmp].worker)
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
1204
kthread_destroy_worker(threads[tmp].worker);
sys/dev/pci/drm/i915/gt/selftest_hangcheck.c
854
struct kthread_worker *worker;
sys/dev/pci/drm/i915/gt/selftest_slpc.c
20
struct kthread_worker *worker;
sys/dev/pci/drm/i915/gt/selftest_slpc.c
507
threads[i].worker = kthread_run_worker(0, "igt/slpc_parallel:%d", gt->info.id);
sys/dev/pci/drm/i915/gt/selftest_slpc.c
509
if (IS_ERR(threads[i].worker)) {
sys/dev/pci/drm/i915/gt/selftest_slpc.c
510
ret = PTR_ERR(threads[i].worker);
sys/dev/pci/drm/i915/gt/selftest_slpc.c
516
kthread_queue_work(threads[i].worker, &threads[i].work);
sys/dev/pci/drm/i915/gt/selftest_slpc.c
522
if (IS_ERR_OR_NULL(threads[i].worker))
sys/dev/pci/drm/i915/gt/selftest_slpc.c
531
kthread_destroy_worker(threads[i].worker);
sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.c
1205
container_of(w, struct intel_guc_ct, requests.worker);
sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.c
1244
queue_work(system_unbound_wq, &ct->requests.worker);
sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.c
151
INIT_WORK(&ct->requests.worker, ct_incoming_request_worker_func);
sys/dev/pci/drm/i915/gt/uc/intel_guc_ct.h
84
struct work_struct worker; /* handler for incoming requests */
sys/dev/pci/drm/i915/gt/uc/intel_guc_submission.c
1747
flush_work(&guc->ct.requests.worker);
sys/dev/pci/drm/i915/selftests/i915_request.c
1457
struct kthread_worker *worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
1645
struct kthread_worker *worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
1647
worker = kthread_run_worker(0, "igt/parallel:%s",
sys/dev/pci/drm/i915/selftests/i915_request.c
1649
if (IS_ERR(worker)) {
sys/dev/pci/drm/i915/selftests/i915_request.c
1650
err = PTR_ERR(worker);
sys/dev/pci/drm/i915/selftests/i915_request.c
1654
threads[idx].worker = worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
1659
kthread_queue_work(worker, &threads[idx].work);
sys/dev/pci/drm/i915/selftests/i915_request.c
1667
if (!threads[idx].worker)
sys/dev/pci/drm/i915/selftests/i915_request.c
1675
kthread_destroy_worker(threads[idx++].worker);
sys/dev/pci/drm/i915/selftests/i915_request.c
1806
struct kthread_worker *worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
1808
worker = kthread_run_worker(0, "igt/%d.%d", idx, n);
sys/dev/pci/drm/i915/selftests/i915_request.c
1809
if (IS_ERR(worker)) {
sys/dev/pci/drm/i915/selftests/i915_request.c
1810
ret = PTR_ERR(worker);
sys/dev/pci/drm/i915/selftests/i915_request.c
1814
threads[i].worker = worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
1819
kthread_queue_work(worker, &threads[i].work);
sys/dev/pci/drm/i915/selftests/i915_request.c
1836
if (!threads[i].worker)
sys/dev/pci/drm/i915/selftests/i915_request.c
1845
kthread_destroy_worker(threads[i].worker);
sys/dev/pci/drm/i915/selftests/i915_request.c
2957
struct kthread_worker *worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
302
struct kthread_worker *worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
3215
struct kthread_worker *worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
3221
worker = kthread_run_worker(0, "igt:%s",
sys/dev/pci/drm/i915/selftests/i915_request.c
3223
if (IS_ERR(worker)) {
sys/dev/pci/drm/i915/selftests/i915_request.c
3224
err = PTR_ERR(worker);
sys/dev/pci/drm/i915/selftests/i915_request.c
3228
engines[idx].worker = worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
3234
kthread_queue_work(worker, &engines[idx].work);
sys/dev/pci/drm/i915/selftests/i915_request.c
3242
if (!engines[idx].worker)
sys/dev/pci/drm/i915/selftests/i915_request.c
3252
kthread_destroy_worker(engines[idx].worker);
sys/dev/pci/drm/i915/selftests/i915_request.c
492
struct kthread_worker *worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
494
worker = kthread_run_worker(0, "igt/%d", n);
sys/dev/pci/drm/i915/selftests/i915_request.c
495
if (IS_ERR(worker)) {
sys/dev/pci/drm/i915/selftests/i915_request.c
496
ret = PTR_ERR(worker);
sys/dev/pci/drm/i915/selftests/i915_request.c
501
threads[n].worker = worker;
sys/dev/pci/drm/i915/selftests/i915_request.c
508
kthread_queue_work(worker, &threads[n].work);
sys/dev/pci/drm/i915/selftests/i915_request.c
522
kthread_destroy_worker(threads[n].worker);
sys/dev/pci/drm/include/drm/drm_flip_work.h
65
struct work_struct worker;
sys/dev/pci/drm/include/drm/drm_vblank.h
243
struct kthread_worker *worker;
usr.sbin/unbound/daemon/cachedump.c
1006
(worker->env.cfg->do_ip4 && worker->back->num_ip4 != 0),
usr.sbin/unbound/daemon/cachedump.c
1007
(worker->env.cfg->do_ip6 && worker->back->num_ip6 != 0),
usr.sbin/unbound/daemon/cachedump.c
1008
worker->env.cfg->do_nat64)) {
usr.sbin/unbound/daemon/cachedump.c
1010
print_dp_details(ssl, worker, dp);
usr.sbin/unbound/daemon/cachedump.c
1029
stub = hints_lookup_stub(worker->env.hints, nm, qinfo.qclass,
usr.sbin/unbound/daemon/cachedump.c
1035
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/cachedump.c
1041
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/cachedump.c
1046
print_dp_details(ssl, worker, stub->dp);
usr.sbin/unbound/daemon/cachedump.c
1047
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/cachedump.c
1050
print_dp_details(ssl, worker, dp);
usr.sbin/unbound/daemon/cachedump.c
255
struct worker* worker;
usr.sbin/unbound/daemon/cachedump.c
269
*dump_info->worker->env.now);
usr.sbin/unbound/daemon/cachedump.c
275
dump_rrset_cache(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
277
struct rrset_cache* r = worker->env.rrset_cache;
usr.sbin/unbound/daemon/cachedump.c
279
dump_info.worker = worker;
usr.sbin/unbound/daemon/cachedump.c
391
regional_free_all(dump_info->worker->scratchpad);
usr.sbin/unbound/daemon/cachedump.c
394
if(!copy_msg(dump_info->worker->scratchpad, e, &k, &d)) {
usr.sbin/unbound/daemon/cachedump.c
402
dump_msg(txt, k, d, *dump_info->worker->env.now);
usr.sbin/unbound/daemon/cachedump.c
407
dump_msg_cache(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
410
dump_info.worker = worker;
usr.sbin/unbound/daemon/cachedump.c
413
if(!dump_slabhash(worker->env.msg_cache, &dump_msg_entry, ssl,
usr.sbin/unbound/daemon/cachedump.c
420
dump_cache(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
422
if(!dump_rrset_cache(ssl, worker))
usr.sbin/unbound/daemon/cachedump.c
424
if(!dump_msg_cache(ssl, worker))
usr.sbin/unbound/daemon/cachedump.c
506
struct packed_rrset_data* d, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
514
ak = alloc_special_obtain(worker->alloc);
usr.sbin/unbound/daemon/cachedump.c
525
ub_packed_rrset_parsedelete(ak, worker->alloc);
usr.sbin/unbound/daemon/cachedump.c
535
ub_packed_rrset_parsedelete(ak, worker->alloc);
usr.sbin/unbound/daemon/cachedump.c
557
(void)rrset_cache_update(worker->env.rrset_cache, &ref,
usr.sbin/unbound/daemon/cachedump.c
558
worker->alloc, *worker->env.now);
usr.sbin/unbound/daemon/cachedump.c
565
load_rrset(RES* ssl, sldns_buffer* buf, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
568
struct regional* region = worker->scratchpad;
usr.sbin/unbound/daemon/cachedump.c
611
d->ttl = (time_t)ttl + *worker->env.now;
usr.sbin/unbound/daemon/cachedump.c
627
&go_on, *worker->env.now)) {
usr.sbin/unbound/daemon/cachedump.c
634
&go_on, *worker->env.now)) {
usr.sbin/unbound/daemon/cachedump.c
644
return move_into_cache(rk, d, worker);
usr.sbin/unbound/daemon/cachedump.c
649
load_rrset_cache(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
651
sldns_buffer* buf = worker->env.scratch_buffer;
usr.sbin/unbound/daemon/cachedump.c
655
if(!load_rrset(ssl, buf, worker))
usr.sbin/unbound/daemon/cachedump.c
705
load_ref(RES* ssl, sldns_buffer* buf, struct worker* worker,
usr.sbin/unbound/daemon/cachedump.c
732
k = rrset_cache_lookup(worker->env.rrset_cache, qinfo.qname,
usr.sbin/unbound/daemon/cachedump.c
734
(uint32_t)flags, *worker->env.now, 0);
usr.sbin/unbound/daemon/cachedump.c
742
*rrset = packed_rrset_copy_region(k, region, *worker->env.now);
usr.sbin/unbound/daemon/cachedump.c
750
load_msg(RES* ssl, sldns_buffer* buf, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
752
struct regional* region = worker->scratchpad;
usr.sbin/unbound/daemon/cachedump.c
808
if(!load_ref(ssl, buf, worker, region, &rep.rrsets[i],
usr.sbin/unbound/daemon/cachedump.c
817
if(!dns_cache_store(&worker->env, &qinf, &rep, 0, 0, 0, NULL, flags,
usr.sbin/unbound/daemon/cachedump.c
818
*worker->env.now, 1)) {
usr.sbin/unbound/daemon/cachedump.c
827
load_msg_cache(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
829
sldns_buffer* buf = worker->env.scratch_buffer;
usr.sbin/unbound/daemon/cachedump.c
833
if(!load_msg(ssl, buf, worker))
usr.sbin/unbound/daemon/cachedump.c
840
load_cache(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/cachedump.c
842
if(!load_rrset_cache(ssl, worker))
usr.sbin/unbound/daemon/cachedump.c
844
if(!load_msg_cache(ssl, worker))
usr.sbin/unbound/daemon/cachedump.c
846
return read_fixed(ssl, worker->env.scratch_buffer, "EOF");
usr.sbin/unbound/daemon/cachedump.c
851
print_dp_details(RES* ssl, struct worker* worker, struct delegpt* dp)
usr.sbin/unbound/daemon/cachedump.c
870
entry_ttl = infra_get_host_rto(worker->env.infra_cache,
usr.sbin/unbound/daemon/cachedump.c
872
&ri, &delay, *worker->env.now, &tA, &tAAAA, &tother);
usr.sbin/unbound/daemon/cachedump.c
888
if(!infra_get_lame_rtt(worker->env.infra_cache,
usr.sbin/unbound/daemon/cachedump.c
891
*worker->env.now)) {
usr.sbin/unbound/daemon/cachedump.c
907
if(infra_host(worker->env.infra_cache, &a->addr, a->addrlen,
usr.sbin/unbound/daemon/cachedump.c
908
dp->name, dp->namelen, *worker->env.now, &edns_vs,
usr.sbin/unbound/daemon/cachedump.c
961
int print_deleg_lookup(RES* ssl, struct worker* worker, uint8_t* nm,
usr.sbin/unbound/daemon/cachedump.c
967
struct regional* region = worker->scratchpad;
usr.sbin/unbound/daemon/cachedump.c
984
dp = forwards_lookup(worker->env.fwds, nm, qinfo.qclass, nolock);
usr.sbin/unbound/daemon/cachedump.c
987
lock_rw_unlock(&worker->env.fwds->lock);
usr.sbin/unbound/daemon/cachedump.c
991
print_dp_details(ssl, worker, dp);
usr.sbin/unbound/daemon/cachedump.c
992
lock_rw_unlock(&worker->env.fwds->lock);
usr.sbin/unbound/daemon/cachedump.c
997
dp = dns_cache_find_delegation(&worker->env, nm, nmlen,
usr.sbin/unbound/daemon/cachedump.c
999
*worker->env.now, 0, NULL, 0);
usr.sbin/unbound/daemon/cachedump.h
105
int print_deleg_lookup(RES* ssl, struct worker* worker, uint8_t* nm,
usr.sbin/unbound/daemon/cachedump.h
74
struct worker;
usr.sbin/unbound/daemon/cachedump.h
84
int dump_cache(RES* ssl, struct worker* worker);
usr.sbin/unbound/daemon/cachedump.h
93
int load_cache(RES* ssl, struct worker* worker);
usr.sbin/unbound/daemon/daemon.c
190
signal_handling_playback(struct worker* wrk)
usr.sbin/unbound/daemon/daemon.c
451
daemon->env->worker = NULL;
usr.sbin/unbound/daemon/daemon.c
467
daemon->env->worker = NULL;
usr.sbin/unbound/daemon/daemon.c
573
daemon->workers = (struct worker**)calloc((size_t)daemon->num,
usr.sbin/unbound/daemon/daemon.c
574
sizeof(struct worker*));
usr.sbin/unbound/daemon/daemon.c
642
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/daemon.c
644
log_thread_set(&worker->thread_num);
usr.sbin/unbound/daemon/daemon.c
648
tube_close_write(worker->cmd);
usr.sbin/unbound/daemon/daemon.c
649
close_other_pipes(worker->daemon, worker->thread_num);
usr.sbin/unbound/daemon/daemon.c
652
if(worker->daemon->cfg->so_reuseport)
usr.sbin/unbound/daemon/daemon.c
653
port_num = worker->thread_num % worker->daemon->num_ports;
usr.sbin/unbound/daemon/daemon.c
657
if(!worker_init(worker, worker->daemon->cfg,
usr.sbin/unbound/daemon/daemon.c
658
worker->daemon->ports[port_num], 0))
usr.sbin/unbound/daemon/daemon.c
661
worker_work(worker);
usr.sbin/unbound/daemon/daemon.h
115
struct worker** workers;
usr.sbin/unbound/daemon/daemon.h
49
struct worker;
usr.sbin/unbound/daemon/remote.c
1219
do_stats(RES* ssl, struct worker* worker, int reset)
usr.sbin/unbound/daemon/remote.c
1221
struct daemon* daemon = worker->daemon;
usr.sbin/unbound/daemon/remote.c
1229
server_stats_obtain(worker, daemon->workers[i], &s, reset);
usr.sbin/unbound/daemon/remote.c
1240
if(!print_uptime(ssl, worker, reset))
usr.sbin/unbound/daemon/remote.c
1243
if(!print_mem(ssl, worker, daemon, &total))
usr.sbin/unbound/daemon/remote.c
1358
do_zones_add(struct daemon_remote* rc, RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
1373
if(!perform_zone_add(ssl, worker->daemon->local_zones,
usr.sbin/unbound/daemon/remote.c
1416
do_zones_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
1431
if(!perform_zone_remove(ssl, worker->daemon->local_zones,
usr.sbin/unbound/daemon/remote.c
1489
do_datas_add(struct daemon_remote* rc, RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
1505
if(perform_data_add(ssl, worker->daemon->local_zones,
usr.sbin/unbound/daemon/remote.c
1538
do_datas_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
1553
if(!perform_data_remove(ssl, worker->daemon->local_zones,
usr.sbin/unbound/daemon/remote.c
1566
do_view_zone_add(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
1572
v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);
usr.sbin/unbound/daemon/remote.c
1598
do_view_zone_remove(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
1604
v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);
usr.sbin/unbound/daemon/remote.c
1620
do_view_data_add(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
1626
v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);
usr.sbin/unbound/daemon/remote.c
1644
do_view_datas_add(struct daemon_remote* rc, RES* ssl, struct worker* worker,
usr.sbin/unbound/daemon/remote.c
1651
v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);
usr.sbin/unbound/daemon/remote.c
1686
do_view_data_remove(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
1692
v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);
usr.sbin/unbound/daemon/remote.c
1708
do_view_datas_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker,
usr.sbin/unbound/daemon/remote.c
1715
v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);
usr.sbin/unbound/daemon/remote.c
1754
struct worker* worker;
usr.sbin/unbound/daemon/remote.c
1800
*inf->worker->env.now)) {
usr.sbin/unbound/daemon/remote.c
1806
s, cl, tp, (long long)(ttl-*inf->worker->env.now))) {
usr.sbin/unbound/daemon/remote.c
1814
(long long)(d->ttl-*inf->worker->env.now),
usr.sbin/unbound/daemon/remote.c
1827
*inf->worker->env.now, s, sizeof(s))) {
usr.sbin/unbound/daemon/remote.c
1904
addrtree_traverse(d->tree4, 0, *inf->worker->env.now, &k->key,
usr.sbin/unbound/daemon/remote.c
1908
addrtree_traverse(d->tree6, 1, *inf->worker->env.now, &k->key,
usr.sbin/unbound/daemon/remote.c
1920
if(*inf->worker->env.now < d->ttl &&
usr.sbin/unbound/daemon/remote.c
1926
if(!packed_rr_to_string(k, i, *inf->worker->env.now,
usr.sbin/unbound/daemon/remote.c
1943
if(*inf->worker->env.now < d->ttl &&
usr.sbin/unbound/daemon/remote.c
1963
*inf->worker->env.now)) {
usr.sbin/unbound/daemon/remote.c
1971
(long long)(d->ttl-*inf->worker->env.now),
usr.sbin/unbound/daemon/remote.c
1984
*inf->worker->env.now, s, sizeof(s))) {
usr.sbin/unbound/daemon/remote.c
1999
do_cache_lookup_domain(RES* ssl, struct worker* worker, uint8_t* nm,
usr.sbin/unbound/daemon/remote.c
2008
inf.worker = worker;
usr.sbin/unbound/daemon/remote.c
2013
m = modstack_find(worker->env.modstack, "subnetcache");
usr.sbin/unbound/daemon/remote.c
2014
if(m != -1) sn_env = (struct subnet_env*)worker->env.modinfo[m];
usr.sbin/unbound/daemon/remote.c
2023
slabhash_traverse(&worker->env.rrset_cache->table, 0,
usr.sbin/unbound/daemon/remote.c
2025
slabhash_traverse(worker->env.msg_cache, 0, &cache_lookup_msg, &inf);
usr.sbin/unbound/daemon/remote.c
2030
do_cache_lookup(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2071
do_cache_lookup_domain(ssl, worker, nm, nmlen);
usr.sbin/unbound/daemon/remote.c
2079
do_lookup(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2086
(void)print_deleg_lookup(ssl, worker, nm, nmlen, nmlabs);
usr.sbin/unbound/daemon/remote.c
2092
do_cache_remove(struct worker* worker, uint8_t* nm, size_t nmlen,
usr.sbin/unbound/daemon/remote.c
2097
rrset_cache_remove(worker->env.rrset_cache, nm, nmlen, t, c, 0);
usr.sbin/unbound/daemon/remote.c
2099
rrset_cache_remove(worker->env.rrset_cache, nm, nmlen, t, c,
usr.sbin/unbound/daemon/remote.c
2107
slabhash_remove(worker->env.msg_cache, h, &k);
usr.sbin/unbound/daemon/remote.c
2111
slabhash_remove(worker->env.msg_cache, h, &k);
usr.sbin/unbound/daemon/remote.c
2114
if(remcachedb && worker->env.cachedb_enabled)
usr.sbin/unbound/daemon/remote.c
2115
cachedb_msg_remove_qinfo(&worker->env, &k);
usr.sbin/unbound/daemon/remote.c
2140
do_flush_type(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2160
do_cache_remove(worker, nm, nmlen, t, LDNS_RR_CLASS_IN, pc);
usr.sbin/unbound/daemon/remote.c
2168
do_flush_stats(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
2170
worker_stats_clear(worker);
usr.sbin/unbound/daemon/remote.c
2179
struct worker* worker;
usr.sbin/unbound/daemon/remote.c
2225
do_flush_infra(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2231
slabhash_clear(worker->env.infra_cache->hosts);
usr.sbin/unbound/daemon/remote.c
2241
inf.worker = worker;
usr.sbin/unbound/daemon/remote.c
2245
inf.expired = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
2253
slabhash_traverse(worker->env.infra_cache->hosts, 1, &infra_del_host,
usr.sbin/unbound/daemon/remote.c
2260
do_flush_requestlist(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
2262
mesh_delete_all(worker->env.mesh);
usr.sbin/unbound/daemon/remote.c
2299
if(inf->remcachedb && inf->worker->env.cachedb_enabled)
usr.sbin/unbound/daemon/remote.c
2300
cachedb_msg_remove_qinfo(&inf->worker->env, &k->key);
usr.sbin/unbound/daemon/remote.c
2323
do_flush_zone(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2336
inf.worker = worker;
usr.sbin/unbound/daemon/remote.c
2340
inf.expired = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
2346
slabhash_traverse(&worker->env.rrset_cache->table, 1,
usr.sbin/unbound/daemon/remote.c
2349
slabhash_traverse(worker->env.msg_cache, 1, &zone_del_msg, &inf);
usr.sbin/unbound/daemon/remote.c
2352
if(worker->env.key_cache) {
usr.sbin/unbound/daemon/remote.c
2353
slabhash_traverse(worker->env.key_cache->slab, 1,
usr.sbin/unbound/daemon/remote.c
2390
if(inf->remcachedb && inf->worker->env.cachedb_enabled)
usr.sbin/unbound/daemon/remote.c
2391
cachedb_msg_remove_qinfo(&inf->worker->env,
usr.sbin/unbound/daemon/remote.c
2412
do_flush_bogus(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2419
inf.worker = worker;
usr.sbin/unbound/daemon/remote.c
2420
inf.expired = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
2426
slabhash_traverse(&worker->env.rrset_cache->table, 1,
usr.sbin/unbound/daemon/remote.c
2429
slabhash_traverse(worker->env.msg_cache, 1, &bogus_del_msg, &inf);
usr.sbin/unbound/daemon/remote.c
2432
if(worker->env.key_cache) {
usr.sbin/unbound/daemon/remote.c
2433
slabhash_traverse(worker->env.key_cache->slab, 1,
usr.sbin/unbound/daemon/remote.c
2476
if(inf->remcachedb && inf->worker->env.cachedb_enabled)
usr.sbin/unbound/daemon/remote.c
2477
cachedb_msg_remove_qinfo(&inf->worker->env,
usr.sbin/unbound/daemon/remote.c
250
rc->worker = NULL;
usr.sbin/unbound/daemon/remote.c
2500
do_flush_negative(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2507
inf.worker = worker;
usr.sbin/unbound/daemon/remote.c
2508
inf.expired = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
2514
slabhash_traverse(&worker->env.rrset_cache->table, 1,
usr.sbin/unbound/daemon/remote.c
2517
slabhash_traverse(worker->env.msg_cache, 1, &negative_del_msg, &inf);
usr.sbin/unbound/daemon/remote.c
2520
if(worker->env.key_cache) {
usr.sbin/unbound/daemon/remote.c
2521
slabhash_traverse(worker->env.key_cache->slab, 1,
usr.sbin/unbound/daemon/remote.c
2532
do_flush_name(RES* ssl, struct worker* w, char* arg)
usr.sbin/unbound/daemon/remote.c
2678
do_forward(RES* ssl, struct worker* worker, char* args)
usr.sbin/unbound/daemon/remote.c
2680
struct iter_forwards* fwd = worker->env.fwds;
usr.sbin/unbound/daemon/remote.c
2694
mesh_delete_all(worker->env.mesh);
usr.sbin/unbound/daemon/remote.c
2757
do_forward_add(RES* ssl, struct worker* worker, char* args)
usr.sbin/unbound/daemon/remote.c
2759
struct iter_forwards* fwd = worker->env.fwds;
usr.sbin/unbound/daemon/remote.c
2770
if(insecure && worker->env.anchors) {
usr.sbin/unbound/daemon/remote.c
2771
if(!anchors_add_insecure(worker->env.anchors, LDNS_RR_CLASS_IN,
usr.sbin/unbound/daemon/remote.c
2793
do_forward_remove(RES* ssl, struct worker* worker, char* args)
usr.sbin/unbound/daemon/remote.c
2795
struct iter_forwards* fwd = worker->env.fwds;
usr.sbin/unbound/daemon/remote.c
2803
if(insecure && worker->env.anchors)
usr.sbin/unbound/daemon/remote.c
2804
anchors_delete_insecure(worker->env.anchors, LDNS_RR_CLASS_IN,
usr.sbin/unbound/daemon/remote.c
2814
do_stub_add(RES* ssl, struct worker* worker, char* args)
usr.sbin/unbound/daemon/remote.c
2816
struct iter_forwards* fwd = worker->env.fwds;
usr.sbin/unbound/daemon/remote.c
2827
lock_rw_wrlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
2828
if(insecure && worker->env.anchors) {
usr.sbin/unbound/daemon/remote.c
2829
if(!anchors_add_insecure(worker->env.anchors, LDNS_RR_CLASS_IN,
usr.sbin/unbound/daemon/remote.c
2832
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
2840
if(insecure && worker->env.anchors)
usr.sbin/unbound/daemon/remote.c
2841
anchors_delete_insecure(worker->env.anchors,
usr.sbin/unbound/daemon/remote.c
2844
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
2850
if(!hints_add_stub(worker->env.hints, LDNS_RR_CLASS_IN, dp, !prime,
usr.sbin/unbound/daemon/remote.c
2854
if(insecure && worker->env.anchors)
usr.sbin/unbound/daemon/remote.c
2855
anchors_delete_insecure(worker->env.anchors,
usr.sbin/unbound/daemon/remote.c
2858
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
2863
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
2870
do_stub_remove(RES* ssl, struct worker* worker, char* args)
usr.sbin/unbound/daemon/remote.c
2872
struct iter_forwards* fwd = worker->env.fwds;
usr.sbin/unbound/daemon/remote.c
2880
lock_rw_wrlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
2881
if(insecure && worker->env.anchors)
usr.sbin/unbound/daemon/remote.c
2882
anchors_delete_insecure(worker->env.anchors, LDNS_RR_CLASS_IN,
usr.sbin/unbound/daemon/remote.c
2885
hints_delete_stub(worker->env.hints, LDNS_RR_CLASS_IN, nm, nolock);
usr.sbin/unbound/daemon/remote.c
2887
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
2894
do_insecure_add(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2901
if(worker->env.anchors) {
usr.sbin/unbound/daemon/remote.c
2902
if(!anchors_add_insecure(worker->env.anchors,
usr.sbin/unbound/daemon/remote.c
2915
do_insecure_remove(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
2922
if(worker->env.anchors)
usr.sbin/unbound/daemon/remote.c
2923
anchors_delete_insecure(worker->env.anchors,
usr.sbin/unbound/daemon/remote.c
2930
do_insecure_list(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
2934
if(worker->env.anchors) {
usr.sbin/unbound/daemon/remote.c
2935
RBTREE_FOR(a, struct trust_anchor*, worker->env.anchors->tree) {
usr.sbin/unbound/daemon/remote.c
2946
do_status(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
2954
if(!ssl_printf(ssl, "threads: %d\n", worker->daemon->num))
usr.sbin/unbound/daemon/remote.c
2956
if(!ssl_printf(ssl, "modules: %d [", worker->daemon->mods.num))
usr.sbin/unbound/daemon/remote.c
2958
for(i=0; i<worker->daemon->mods.num; i++) {
usr.sbin/unbound/daemon/remote.c
2959
if(!ssl_printf(ssl, " %s", worker->daemon->mods.mod[i]->name))
usr.sbin/unbound/daemon/remote.c
2964
uptime = (time_t)time(NULL) - (time_t)worker->daemon->time_boot.tv_sec;
usr.sbin/unbound/daemon/remote.c
2968
(worker->daemon->reuseport?" reuseport":""),
usr.sbin/unbound/daemon/remote.c
2969
(worker->daemon->rc->accept_list?" control":""),
usr.sbin/unbound/daemon/remote.c
2970
(worker->daemon->rc->accept_list && worker->daemon->rc->use_cert?"(ssl)":""),
usr.sbin/unbound/daemon/remote.c
2971
(worker->daemon->rc->accept_list && worker->daemon->cfg->control_ifs.first && worker->daemon->cfg->control_ifs.first->str && worker->daemon->cfg->control_ifs.first->str[0] == '/'?"(namedpipe)":"")
usr.sbin/unbound/daemon/remote.c
3054
do_dump_requestlist(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
3062
if(!ssl_printf(ssl, "thread #%d\n", worker->thread_num))
usr.sbin/unbound/daemon/remote.c
3067
mesh = worker->env.mesh;
usr.sbin/unbound/daemon/remote.c
3073
get_mesh_age(m, timebuf, sizeof(timebuf), &worker->env);
usr.sbin/unbound/daemon/remote.c
3148
do_dump_infra(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
3151
arg.infra = worker->env.infra_cache;
usr.sbin/unbound/daemon/remote.c
3153
arg.now = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
3160
do_log_reopen(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
3162
struct config_file* cfg = worker->env.cfg;
usr.sbin/unbound/daemon/remote.c
3169
do_auth_zone_reload(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3174
struct auth_zones* az = worker->env.auth_zones;
usr.sbin/unbound/daemon/remote.c
3200
if(!auth_zone_read_zonefile(z, worker->env.cfg)) {
usr.sbin/unbound/daemon/remote.c
3225
xfr->lease_time = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
3226
xfr->soa_zone_acquired = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
3230
z->soa_zone_acquired = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
3232
auth_zone_verify_zonemd(z, &worker->env, &worker->env.mesh->mods,
usr.sbin/unbound/daemon/remote.c
3251
do_auth_zone_transfer(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3256
struct auth_zones* az = worker->env.auth_zones;
usr.sbin/unbound/daemon/remote.c
3259
if(!az || !auth_zones_startprobesequence(az, &worker->env, nm, nmlen,
usr.sbin/unbound/daemon/remote.c
3271
do_set_option(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3276
if(!config_set_option(worker->env.cfg, arg, arg2)) {
usr.sbin/unbound/daemon/remote.c
3282
int m = modstack_find(&worker->env.mesh->mods, "validator");
usr.sbin/unbound/daemon/remote.c
3284
if(m != -1) val_env = (struct val_env*)worker->env.modinfo[m];
usr.sbin/unbound/daemon/remote.c
3286
val_env->date_override = worker->env.cfg->val_date_override;
usr.sbin/unbound/daemon/remote.c
3300
do_get_option(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3303
r = config_get_option(worker->env.cfg, arg, remote_get_opt_ssl, ssl);
usr.sbin/unbound/daemon/remote.c
3312
do_list_forwards(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
3315
struct iter_forwards* fwds = worker->env.fwds;
usr.sbin/unbound/daemon/remote.c
3325
if(worker->env.anchors &&
usr.sbin/unbound/daemon/remote.c
3326
(a=anchor_find(worker->env.anchors, z->name,
usr.sbin/unbound/daemon/remote.c
3344
do_list_stubs(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
3350
lock_rw_rdlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
3351
RBTREE_FOR(z, struct iter_hints_stub*, &worker->env.hints->tree) {
usr.sbin/unbound/daemon/remote.c
3355
if(worker->env.anchors &&
usr.sbin/unbound/daemon/remote.c
3356
(a=anchor_find(worker->env.anchors, z->node.name,
usr.sbin/unbound/daemon/remote.c
3367
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
3371
lock_rw_unlock(&worker->env.hints->lock);
usr.sbin/unbound/daemon/remote.c
3451
do_list_local_data(RES* ssl, struct worker* worker, struct local_zones* zones)
usr.sbin/unbound/daemon/remote.c
3456
char* s = (char*)sldns_buffer_begin(worker->env.scratch_buffer);
usr.sbin/unbound/daemon/remote.c
3457
size_t slen = sldns_buffer_capacity(worker->env.scratch_buffer);
usr.sbin/unbound/daemon/remote.c
3490
do_view_list_local_zones(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3492
struct view* v = views_find_view(worker->env.views,
usr.sbin/unbound/daemon/remote.c
3506
do_view_list_local_data(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3508
struct view* v = views_find_view(worker->env.views,
usr.sbin/unbound/daemon/remote.c
3515
do_list_local_data(ssl, worker, v->local_zones);
usr.sbin/unbound/daemon/remote.c
3574
do_ratelimit_list(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3578
a.infra = worker->env.infra_cache;
usr.sbin/unbound/daemon/remote.c
3579
a.now = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
3581
a.backoff = worker->env.cfg->ratelimit_backoff;
usr.sbin/unbound/daemon/remote.c
3593
do_ip_ratelimit_list(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3597
a.infra = worker->env.infra_cache;
usr.sbin/unbound/daemon/remote.c
3598
a.now = *worker->env.now;
usr.sbin/unbound/daemon/remote.c
3600
a.backoff = worker->env.cfg->ip_ratelimit_backoff;
usr.sbin/unbound/daemon/remote.c
3612
do_rpz_enable_disable(RES* ssl, struct worker* worker, char* arg, int enable) {
usr.sbin/unbound/daemon/remote.c
3616
struct auth_zones *az = worker->env.auth_zones;
usr.sbin/unbound/daemon/remote.c
3649
do_rpz_enable(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3651
do_rpz_enable_disable(ssl, worker, arg, 1);
usr.sbin/unbound/daemon/remote.c
3656
do_rpz_disable(RES* ssl, struct worker* worker, char* arg)
usr.sbin/unbound/daemon/remote.c
3658
do_rpz_enable_disable(ssl, worker, arg, 0);
usr.sbin/unbound/daemon/remote.c
3664
cookie_secret_file_dump(RES* ssl, struct worker* worker) {
usr.sbin/unbound/daemon/remote.c
3665
char const* secret_file = worker->env.cfg->cookie_secret_file;
usr.sbin/unbound/daemon/remote.c
3666
struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;
usr.sbin/unbound/daemon/remote.c
3706
do_activate_cookie_secret(RES* ssl, struct worker* worker) {
usr.sbin/unbound/daemon/remote.c
3707
char const* secret_file = worker->env.cfg->cookie_secret_file;
usr.sbin/unbound/daemon/remote.c
3708
struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;
usr.sbin/unbound/daemon/remote.c
3726
if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) {
usr.sbin/unbound/daemon/remote.c
3733
if(worker->thread_num == 0)
usr.sbin/unbound/daemon/remote.c
3734
(void)cookie_secret_file_dump(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3741
do_drop_cookie_secret(RES* ssl, struct worker* worker) {
usr.sbin/unbound/daemon/remote.c
3742
char const* secret_file = worker->env.cfg->cookie_secret_file;
usr.sbin/unbound/daemon/remote.c
3743
struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;
usr.sbin/unbound/daemon/remote.c
3761
if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) {
usr.sbin/unbound/daemon/remote.c
3768
if(worker->thread_num == 0)
usr.sbin/unbound/daemon/remote.c
3769
(void)cookie_secret_file_dump(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3776
do_add_cookie_secret(RES* ssl, struct worker* worker, char* arg) {
usr.sbin/unbound/daemon/remote.c
3778
char const* secret_file = worker->env.cfg->cookie_secret_file;
usr.sbin/unbound/daemon/remote.c
3779
struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;
usr.sbin/unbound/daemon/remote.c
3786
worker->daemon->cookie_secrets = cookie_secrets_create();
usr.sbin/unbound/daemon/remote.c
3787
if(!worker->daemon->cookie_secrets) {
usr.sbin/unbound/daemon/remote.c
3791
cookie_secrets = worker->daemon->cookie_secrets;
usr.sbin/unbound/daemon/remote.c
3817
if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) {
usr.sbin/unbound/daemon/remote.c
3827
if(worker->thread_num == 0)
usr.sbin/unbound/daemon/remote.c
3828
(void)cookie_secret_file_dump(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3836
do_print_cookie_secrets(RES* ssl, struct worker* worker) {
usr.sbin/unbound/daemon/remote.c
3837
struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;
usr.sbin/unbound/daemon/remote.c
3899
struct worker* worker)
usr.sbin/unbound/daemon/remote.c
3906
do_stop(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3911
do_reload(ssl, worker, 1);
usr.sbin/unbound/daemon/remote.c
3916
do_reload(ssl, worker, 0);
usr.sbin/unbound/daemon/remote.c
3919
do_fast_reload(ssl, worker, s, skipwhite(p+11));
usr.sbin/unbound/daemon/remote.c
3924
do_stats(ssl, worker, 0);
usr.sbin/unbound/daemon/remote.c
3929
do_stats(ssl, worker, 1);
usr.sbin/unbound/daemon/remote.c
3934
do_status(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3940
if(worker->daemon->num > 1) {
usr.sbin/unbound/daemon/remote.c
3946
(void)dump_cache(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3952
if(worker->daemon->num > 1) {
usr.sbin/unbound/daemon/remote.c
3958
if(load_cache(ssl, worker)) send_ok(ssl);
usr.sbin/unbound/daemon/remote.c
3963
do_list_forwards(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3968
do_list_stubs(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3973
do_insecure_list(ssl, worker);
usr.sbin/unbound/daemon/remote.c
3978
do_list_local_zones(ssl, worker->daemon->local_zones);
usr.sbin/unbound/daemon/remote.c
3983
do_list_local_data(ssl, worker, worker->daemon->local_zones);
usr.sbin/unbound/daemon/remote.c
3986
do_view_list_local_zones(ssl, worker, skipwhite(p+21));
usr.sbin/unbound/daemon/remote.c
3989
do_view_list_local_data(ssl, worker, skipwhite(p+20));
usr.sbin/unbound/daemon/remote.c
3992
do_ratelimit_list(ssl, worker, p+14);
usr.sbin/unbound/daemon/remote.c
3995
do_ip_ratelimit_list(ssl, worker, p+17);
usr.sbin/unbound/daemon/remote.c
4000
do_list_auth_zones(ssl, worker->env.auth_zones);
usr.sbin/unbound/daemon/remote.c
4003
do_auth_zone_reload(ssl, worker, skipwhite(p+16));
usr.sbin/unbound/daemon/remote.c
4006
do_auth_zone_transfer(ssl, worker, skipwhite(p+18));
usr.sbin/unbound/daemon/remote.c
4011
do_insecure_add(ssl, worker, skipwhite(p+12));
usr.sbin/unbound/daemon/remote.c
4016
do_insecure_remove(ssl, worker, skipwhite(p+15));
usr.sbin/unbound/daemon/remote.c
4023
do_flush_stats(ssl, worker);
usr.sbin/unbound/daemon/remote.c
4030
do_flush_requestlist(ssl, worker);
usr.sbin/unbound/daemon/remote.c
4033
do_cache_lookup(ssl, worker, skipwhite(p+12));
usr.sbin/unbound/daemon/remote.c
4036
do_lookup(ssl, worker, skipwhite(p+6));
usr.sbin/unbound/daemon/remote.c
4044
do_zones_remove(rc, ssl, worker);
usr.sbin/unbound/daemon/remote.c
4049
do_zones_add(rc, ssl, worker);
usr.sbin/unbound/daemon/remote.c
4054
do_datas_remove(rc, ssl, worker);
usr.sbin/unbound/daemon/remote.c
4059
do_datas_add(rc, ssl, worker);
usr.sbin/unbound/daemon/remote.c
4062
do_view_datas_remove(rc, ssl, worker, skipwhite(p+23));
usr.sbin/unbound/daemon/remote.c
4065
do_view_datas_add(rc, ssl, worker, skipwhite(p+16));
usr.sbin/unbound/daemon/remote.c
4070
do_print_cookie_secrets(ssl, worker);
usr.sbin/unbound/daemon/remote.c
4085
do_zone_remove(ssl, worker->daemon->local_zones, skipwhite(p+17));
usr.sbin/unbound/daemon/remote.c
4087
do_zone_add(ssl, worker->daemon->local_zones, skipwhite(p+10));
usr.sbin/unbound/daemon/remote.c
4089
do_data_remove(ssl, worker->daemon->local_zones, skipwhite(p+17));
usr.sbin/unbound/daemon/remote.c
409
n->com = comm_point_create_raw(rc->worker->base, fd, 0,
usr.sbin/unbound/daemon/remote.c
4091
do_data_add(ssl, worker->daemon->local_zones, skipwhite(p+10));
usr.sbin/unbound/daemon/remote.c
4093
do_forward_add(ssl, worker, skipwhite(p+11));
usr.sbin/unbound/daemon/remote.c
4095
do_forward_remove(ssl, worker, skipwhite(p+14));
usr.sbin/unbound/daemon/remote.c
4097
do_forward(ssl, worker, skipwhite(p+7));
usr.sbin/unbound/daemon/remote.c
4099
do_stub_add(ssl, worker, skipwhite(p+8));
usr.sbin/unbound/daemon/remote.c
4101
do_stub_remove(ssl, worker, skipwhite(p+11));
usr.sbin/unbound/daemon/remote.c
4103
do_view_zone_remove(ssl, worker, skipwhite(p+22));
usr.sbin/unbound/daemon/remote.c
4105
do_view_zone_add(ssl, worker, skipwhite(p+15));
usr.sbin/unbound/daemon/remote.c
4107
do_view_data_remove(ssl, worker, skipwhite(p+22));
usr.sbin/unbound/daemon/remote.c
4109
do_view_data_add(ssl, worker, skipwhite(p+15));
usr.sbin/unbound/daemon/remote.c
4111
do_flush_zone(ssl, worker, skipwhite(p+10));
usr.sbin/unbound/daemon/remote.c
4113
do_flush_type(ssl, worker, skipwhite(p+10));
usr.sbin/unbound/daemon/remote.c
4115
do_flush_infra(ssl, worker, skipwhite(p+11));
usr.sbin/unbound/daemon/remote.c
4117
do_flush_name(ssl, worker, skipwhite(p+5));
usr.sbin/unbound/daemon/remote.c
4121
do_dump_requestlist(ssl, worker);
usr.sbin/unbound/daemon/remote.c
4125
do_dump_infra(ssl, worker);
usr.sbin/unbound/daemon/remote.c
4129
do_log_reopen(ssl, worker);
usr.sbin/unbound/daemon/remote.c
4131
do_set_option(ssl, worker, skipwhite(p+10));
usr.sbin/unbound/daemon/remote.c
4133
do_get_option(ssl, worker, skipwhite(p+10));
usr.sbin/unbound/daemon/remote.c
4135
do_flush_bogus(ssl, worker, skipwhite(p+11));
usr.sbin/unbound/daemon/remote.c
4137
do_flush_negative(ssl, worker, skipwhite(p+14));
usr.sbin/unbound/daemon/remote.c
4139
do_rpz_enable(ssl, worker, skipwhite(p+10));
usr.sbin/unbound/daemon/remote.c
4141
do_rpz_disable(ssl, worker, skipwhite(p+11));
usr.sbin/unbound/daemon/remote.c
4143
do_add_cookie_secret(ssl, worker, skipwhite(p+17));
usr.sbin/unbound/daemon/remote.c
4147
do_drop_cookie_secret(ssl, worker);
usr.sbin/unbound/daemon/remote.c
4151
do_activate_cookie_secret(ssl, worker);
usr.sbin/unbound/daemon/remote.c
4158
daemon_remote_exec(struct worker* worker)
usr.sbin/unbound/daemon/remote.c
4163
if(!tube_read_msg(worker->cmd, &msg, &len, 0)) {
usr.sbin/unbound/daemon/remote.c
4168
execute_cmd(NULL, NULL, NULL, (char*)msg, worker);
usr.sbin/unbound/daemon/remote.c
419
struct listen_port* ports, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
422
rc->worker = worker;
usr.sbin/unbound/daemon/remote.c
4232
execute_cmd(rc, s, res, buf, rc->worker);
usr.sbin/unbound/daemon/remote.c
4703
if(!config_read(*newcfg, fr->worker->daemon->cfgfile,
usr.sbin/unbound/daemon/remote.c
4704
fr->worker->daemon->chroot)) {
usr.sbin/unbound/daemon/remote.c
4707
(fr->worker->daemon->chroot?"<chroot:":""),
usr.sbin/unbound/daemon/remote.c
4708
(fr->worker->daemon->chroot?fr->worker->daemon->chroot:""),
usr.sbin/unbound/daemon/remote.c
4709
(fr->worker->daemon->chroot?"> ":""),
usr.sbin/unbound/daemon/remote.c
4710
fr->worker->daemon->cfgfile, strerror(errno)))
usr.sbin/unbound/daemon/remote.c
4719
(fr->worker->daemon->chroot?"<chroot:":""),
usr.sbin/unbound/daemon/remote.c
4720
(fr->worker->daemon->chroot?fr->worker->daemon->chroot:""),
usr.sbin/unbound/daemon/remote.c
4721
(fr->worker->daemon->chroot?"> ":""),
usr.sbin/unbound/daemon/remote.c
4722
fr->worker->daemon->cfgfile))
usr.sbin/unbound/daemon/remote.c
4770
if(!taglist_equal(fr->worker->daemon->cfg->tagname,
usr.sbin/unbound/daemon/remote.c
4771
fr->worker->daemon->cfg->num_tags, newcfg->tagname,
usr.sbin/unbound/daemon/remote.c
4773
!taglist_change_at_end(fr->worker->daemon->cfg->tagname,
usr.sbin/unbound/daemon/remote.c
4774
fr->worker->daemon->cfg->num_tags, newcfg->tagname,
usr.sbin/unbound/daemon/remote.c
4780
fr->worker->daemon->fast_reload_drop_mesh = fr->fr_drop_mesh;
usr.sbin/unbound/daemon/remote.c
480
n->c = comm_point_create_raw(rc->worker->base, newfd, 0,
usr.sbin/unbound/daemon/remote.c
4890
struct config_file* cfg = fr->worker->env.cfg;
usr.sbin/unbound/daemon/remote.c
4962
struct config_file* cfg = fr->worker->env.cfg;
usr.sbin/unbound/daemon/remote.c
5431
struct module_env* env = &fr->worker->env;
usr.sbin/unbound/daemon/remote.c
5561
fr->worker->daemon)) {
usr.sbin/unbound/daemon/remote.c
5580
if(fr->worker->daemon->tcl->tree.count != 0)
usr.sbin/unbound/daemon/remote.c
5581
fr->worker->daemon->fast_reload_tcl_has_changes = 1;
usr.sbin/unbound/daemon/remote.c
5582
else fr->worker->daemon->fast_reload_tcl_has_changes = 0;
usr.sbin/unbound/daemon/remote.c
5591
fr->worker->daemon->env, &fr->worker->daemon->mods)) {
usr.sbin/unbound/daemon/remote.c
5665
if(fr->worker->env.anchors) {
usr.sbin/unbound/daemon/remote.c
6331
struct daemon* daemon = fr->worker->daemon;
usr.sbin/unbound/daemon/remote.c
685
for(i=1; i<rc->worker->daemon->num; i++) {
usr.sbin/unbound/daemon/remote.c
686
worker_send_cmd(rc->worker->daemon->workers[i],
usr.sbin/unbound/daemon/remote.c
688
if(!tube_write_msg(rc->worker->daemon->workers[i]->cmd,
usr.sbin/unbound/daemon/remote.c
6970
fast_reload_thread_setup(struct worker* worker, int fr_verb, int fr_nopause,
usr.sbin/unbound/daemon/remote.c
6974
int numworkers = worker->daemon->num;
usr.sbin/unbound/daemon/remote.c
6975
worker->daemon->fast_reload_thread = (struct fast_reload_thread*)
usr.sbin/unbound/daemon/remote.c
6976
calloc(1, sizeof(*worker->daemon->fast_reload_thread));
usr.sbin/unbound/daemon/remote.c
6977
if(!worker->daemon->fast_reload_thread)
usr.sbin/unbound/daemon/remote.c
6979
fr = worker->daemon->fast_reload_thread;
usr.sbin/unbound/daemon/remote.c
698
do_stop(RES* ssl, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
6983
worker->daemon->fast_reload_drop_mesh = fr->fr_drop_mesh;
usr.sbin/unbound/daemon/remote.c
6991
if(!create_socketpair(fr->commpair, worker->daemon->rand)) {
usr.sbin/unbound/daemon/remote.c
6993
worker->daemon->fast_reload_thread = NULL;
usr.sbin/unbound/daemon/remote.c
6996
fr->worker = worker;
usr.sbin/unbound/daemon/remote.c
700
worker->need_to_exit = 1;
usr.sbin/unbound/daemon/remote.c
7003
worker->daemon->fast_reload_thread = NULL;
usr.sbin/unbound/daemon/remote.c
7006
if(!create_socketpair(fr->commreload, worker->daemon->rand)) {
usr.sbin/unbound/daemon/remote.c
701
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/remote.c
7011
worker->daemon->fast_reload_thread = NULL;
usr.sbin/unbound/daemon/remote.c
7064
fast_reload_thread->worker->daemon);
usr.sbin/unbound/daemon/remote.c
707
do_reload(RES* ssl, struct worker* worker, int reuse_cache)
usr.sbin/unbound/daemon/remote.c
709
worker->reuse_cache = reuse_cache;
usr.sbin/unbound/daemon/remote.c
710
worker->need_to_exit = 0;
usr.sbin/unbound/daemon/remote.c
711
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/remote.c
7143
struct worker* worker = fr->worker;
usr.sbin/unbound/daemon/remote.c
7148
worker->daemon->fast_reload_thread = NULL;
usr.sbin/unbound/daemon/remote.c
7202
struct daemon* daemon = fr->worker->daemon;
usr.sbin/unbound/daemon/remote.c
7289
fr_worker_pickup_mesh(struct worker* worker)
usr.sbin/unbound/daemon/remote.c
7291
struct mesh_area* mesh = worker->env.mesh;
usr.sbin/unbound/daemon/remote.c
7292
struct config_file* cfg = worker->env.cfg;
usr.sbin/unbound/daemon/remote.c
7293
mesh->use_response_ip = worker->daemon->use_response_ip;
usr.sbin/unbound/daemon/remote.c
7294
mesh->use_rpz = worker->daemon->use_rpz;
usr.sbin/unbound/daemon/remote.c
7353
fr_pickup_auth_locks(struct worker* worker, struct auth_zone* namez,
usr.sbin/unbound/daemon/remote.c
7368
lock_rw_wrlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7369
lock_rw_wrlock(&worker->env.auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7377
*loadxfr = auth_xfer_find(worker->daemon->fast_reload_thread->
usr.sbin/unbound/daemon/remote.c
7380
*xfr = auth_xfer_find(worker->env.auth_zones, nm, nmlen,
usr.sbin/unbound/daemon/remote.c
7392
fr_worker_auth_del(struct worker* worker, struct fast_reload_auth_change* item,
usr.sbin/unbound/daemon/remote.c
7400
item->old_z->zonemd_callback_env->worker == worker){
usr.sbin/unbound/daemon/remote.c
7403
auth_zone_zonemd_stop_lookup(item->old_z, worker->env.mesh);
usr.sbin/unbound/daemon/remote.c
7408
fr_pickup_auth_locks(worker, item->old_z, item->old_z, NULL, &xfr,
usr.sbin/unbound/daemon/remote.c
7410
lock_rw_unlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7411
lock_rw_unlock(&worker->env.auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7415
if(xfr->task_nextprobe->worker == worker ||
usr.sbin/unbound/daemon/remote.c
7416
xfr->task_probe->worker == worker ||
usr.sbin/unbound/daemon/remote.c
7417
xfr->task_transfer->worker == worker) {
usr.sbin/unbound/daemon/remote.c
7419
xfr_disown_tasks(xfr, worker);
usr.sbin/unbound/daemon/remote.c
7424
if(!for_change && (released || worker->thread_num == 0)) {
usr.sbin/unbound/daemon/remote.c
7427
fr_pickup_auth_locks(worker, item->old_z, item->old_z, NULL,
usr.sbin/unbound/daemon/remote.c
7429
lock_rw_unlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7431
if(xfr && xfr->task_nextprobe->worker == NULL &&
usr.sbin/unbound/daemon/remote.c
7432
xfr->task_probe->worker == NULL &&
usr.sbin/unbound/daemon/remote.c
7433
xfr->task_transfer->worker == NULL) {
usr.sbin/unbound/daemon/remote.c
7434
(void)rbtree_delete(&worker->env.auth_zones->xtree,
usr.sbin/unbound/daemon/remote.c
7436
lock_rw_unlock(&worker->env.auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7440
lock_rw_unlock(&worker->env.auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7469
fr_worker_auth_add(struct worker* worker, struct fast_reload_auth_change* item,
usr.sbin/unbound/daemon/remote.c
7475
fr_pickup_auth_locks(worker, item->new_z, NULL, item->new_z, &xfr,
usr.sbin/unbound/daemon/remote.c
7480
xfr = auth_xfer_create(worker->env.auth_zones, item->new_z);
usr.sbin/unbound/daemon/remote.c
7491
auth_zone_pickup_initial_zone(item->new_z, &worker->env);
usr.sbin/unbound/daemon/remote.c
7493
lock_rw_unlock(&worker->env.auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7494
lock_rw_unlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7499
auth_xfer_pickup_initial_zone(xfr, &worker->env);
usr.sbin/unbound/daemon/remote.c
7509
auth_zone_verify_zonemd(item->new_z, &worker->env,
usr.sbin/unbound/daemon/remote.c
7510
&worker->env.mesh->mods, NULL, 0, 1);
usr.sbin/unbound/daemon/remote.c
7516
fr_worker_auth_cha(struct worker* worker, struct fast_reload_auth_change* item)
usr.sbin/unbound/daemon/remote.c
7523
fr_worker_auth_del(worker, item, 1);
usr.sbin/unbound/daemon/remote.c
7525
if(worker->thread_num != 0)
usr.sbin/unbound/daemon/remote.c
753
do_fast_reload(RES* ssl, struct worker* worker, struct rc_state* s, char* arg)
usr.sbin/unbound/daemon/remote.c
7532
fr_pickup_auth_locks(worker, item->new_z, item->old_z, item->new_z,
usr.sbin/unbound/daemon/remote.c
7543
(void)rbtree_delete(&worker->env.auth_zones->xtree,
usr.sbin/unbound/daemon/remote.c
7549
xfr = auth_xfer_create(worker->env.auth_zones, item->new_z);
usr.sbin/unbound/daemon/remote.c
7555
lock_rw_unlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7556
lock_rw_unlock(&worker->env.auth_zones->lock);
usr.sbin/unbound/daemon/remote.c
7567
fr_worker_auth_add(worker, item, 1);
usr.sbin/unbound/daemon/remote.c
7572
fr_worker_pickup_auth_changes(struct worker* worker,
usr.sbin/unbound/daemon/remote.c
7578
fr_worker_auth_del(worker, item, 0);
usr.sbin/unbound/daemon/remote.c
758
(void)worker;
usr.sbin/unbound/daemon/remote.c
7581
if(worker->thread_num == 0) {
usr.sbin/unbound/daemon/remote.c
7582
fr_worker_auth_add(worker, item, 0);
usr.sbin/unbound/daemon/remote.c
7586
fr_worker_auth_cha(worker, item);
usr.sbin/unbound/daemon/remote.c
7593
fr_worker_pickup_outside_network(struct worker* worker)
usr.sbin/unbound/daemon/remote.c
7595
struct outside_network* outnet = worker->back;
usr.sbin/unbound/daemon/remote.c
7596
struct config_file* cfg = worker->env.cfg;
usr.sbin/unbound/daemon/remote.c
7615
fast_reload_worker_pickup_changes(struct worker* worker)
usr.sbin/unbound/daemon/remote.c
7627
fr_worker_pickup_mesh(worker);
usr.sbin/unbound/daemon/remote.c
7631
if(worker->daemon->fast_reload_tcl_has_changes)
usr.sbin/unbound/daemon/remote.c
7632
tcl_remove_old(worker->front);
usr.sbin/unbound/daemon/remote.c
7636
fr_worker_pickup_auth_changes(worker,
usr.sbin/unbound/daemon/remote.c
7637
worker->daemon->fast_reload_thread->auth_zone_change_list);
usr.sbin/unbound/daemon/remote.c
7639
worker->env.cachedb_enabled = worker->daemon->env->cachedb_enabled;
usr.sbin/unbound/daemon/remote.c
7641
fr_worker_pickup_outside_network(worker);
usr.sbin/unbound/daemon/remote.c
7650
struct daemon* daemon = fr->worker->daemon;
usr.sbin/unbound/daemon/remote.c
7655
if(i == fr->worker->thread_num)
usr.sbin/unbound/daemon/remote.c
7671
if(i == fr->worker->thread_num)
usr.sbin/unbound/daemon/remote.c
7677
if(fr->worker->daemon->fast_reload_drop_mesh) {
usr.sbin/unbound/daemon/remote.c
7679
mesh_delete_all(fr->worker->env.mesh);
usr.sbin/unbound/daemon/remote.c
7681
fast_reload_worker_pickup_changes(fr->worker);
usr.sbin/unbound/daemon/remote.c
769
fast_reload_thread_start(ssl, worker, s, fr_verb, fr_nopause,
usr.sbin/unbound/daemon/remote.c
7699
struct daemon* daemon = fr->worker->daemon;
usr.sbin/unbound/daemon/remote.c
7705
if(i == fr->worker->thread_num)
usr.sbin/unbound/daemon/remote.c
7712
fast_reload_worker_pickup_changes(fr->worker);
usr.sbin/unbound/daemon/remote.c
7797
struct worker* worker = fr->worker;
usr.sbin/unbound/daemon/remote.c
7799
while(worker->daemon->fast_reload_thread) {
usr.sbin/unbound/daemon/remote.c
7804
if(worker->daemon->fast_reload_thread)
usr.sbin/unbound/daemon/remote.c
7805
ub_winsock_tcp_wouldblock(worker->daemon->
usr.sbin/unbound/daemon/remote.c
7813
if(worker->daemon->fast_reload_thread)
usr.sbin/unbound/daemon/remote.c
7814
ub_winsock_tcp_wouldblock(worker->daemon->
usr.sbin/unbound/daemon/remote.c
7829
struct worker* worker = fast_reload_thread->worker;
usr.sbin/unbound/daemon/remote.c
7833
if(worker->daemon->fast_reload_thread != NULL) {
usr.sbin/unbound/daemon/remote.c
8052
fr_printq_create(struct comm_point* c, struct worker* worker)
usr.sbin/unbound/daemon/remote.c
8062
printq->worker = worker;
usr.sbin/unbound/daemon/remote.c
8129
struct daemon* daemon = printq->worker->daemon;
usr.sbin/unbound/daemon/remote.c
8145
if(printq->worker->daemon->fast_reload_thread &&
usr.sbin/unbound/daemon/remote.c
8146
printq->worker->daemon->fast_reload_thread->printq == printq)
usr.sbin/unbound/daemon/remote.c
8147
printq->worker->daemon->fast_reload_thread->printq = NULL;
usr.sbin/unbound/daemon/remote.c
8162
fast_reload_thread_start(RES* ssl, struct worker* worker, struct rc_state* s,
usr.sbin/unbound/daemon/remote.c
8165
if(worker->daemon->fast_reload_thread) {
usr.sbin/unbound/daemon/remote.c
8169
if(!fast_reload_thread_setup(worker, fr_verb, fr_nopause,
usr.sbin/unbound/daemon/remote.c
8175
worker->daemon->fast_reload_thread->started = 1;
usr.sbin/unbound/daemon/remote.c
8185
fd_set_nonblock(worker->daemon->fast_reload_thread->commpair[0]);
usr.sbin/unbound/daemon/remote.c
8186
worker->daemon->fast_reload_thread->service_event = ub_event_new(
usr.sbin/unbound/daemon/remote.c
8187
comm_base_internal(worker->base),
usr.sbin/unbound/daemon/remote.c
8188
worker->daemon->fast_reload_thread->commpair[0],
usr.sbin/unbound/daemon/remote.c
8190
worker->daemon->fast_reload_thread);
usr.sbin/unbound/daemon/remote.c
8191
if(!worker->daemon->fast_reload_thread->service_event) {
usr.sbin/unbound/daemon/remote.c
8192
fast_reload_thread_desetup(worker->daemon->fast_reload_thread);
usr.sbin/unbound/daemon/remote.c
8197
if(ub_event_add(worker->daemon->fast_reload_thread->service_event,
usr.sbin/unbound/daemon/remote.c
8199
fast_reload_thread_desetup(worker->daemon->fast_reload_thread);
usr.sbin/unbound/daemon/remote.c
8204
worker->daemon->fast_reload_thread->service_event_is_added = 1;
usr.sbin/unbound/daemon/remote.c
8216
worker->daemon->fast_reload_thread->printq = fr_printq_create(s->c,
usr.sbin/unbound/daemon/remote.c
8217
worker);
usr.sbin/unbound/daemon/remote.c
8218
if(!worker->daemon->fast_reload_thread->printq) {
usr.sbin/unbound/daemon/remote.c
8219
fast_reload_thread_desetup(worker->daemon->fast_reload_thread);
usr.sbin/unbound/daemon/remote.c
8224
worker->daemon->fast_reload_thread->printq->remote = *ssl;
usr.sbin/unbound/daemon/remote.c
8227
comm_point_stop_listening(worker->daemon->fast_reload_thread->printq->client_cp);
usr.sbin/unbound/daemon/remote.c
8230
ub_thread_create(&worker->daemon->fast_reload_thread->tid,
usr.sbin/unbound/daemon/remote.c
8231
fast_reload_thread_main, worker->daemon->fast_reload_thread);
usr.sbin/unbound/daemon/remote.c
8240
struct worker* worker = fast_reload_thread->worker;
usr.sbin/unbound/daemon/remote.c
8244
if(worker->daemon->fast_reload_thread != NULL) {
usr.sbin/unbound/daemon/remote.c
889
print_mem(RES* ssl, struct worker* worker, struct daemon* daemon,
usr.sbin/unbound/daemon/remote.c
908
val = mod_get_mem(&worker->env, "validator");
usr.sbin/unbound/daemon/remote.c
909
iter = mod_get_mem(&worker->env, "iterator");
usr.sbin/unbound/daemon/remote.c
910
respip = mod_get_mem(&worker->env, "respip");
usr.sbin/unbound/daemon/remote.c
912
subnet = mod_get_mem(&worker->env, "subnetcache");
usr.sbin/unbound/daemon/remote.c
915
ipsecmod = mod_get_mem(&worker->env, "ipsecmod");
usr.sbin/unbound/daemon/remote.c
925
dynlib = mod_get_mem(&worker->env, "dynlib");
usr.sbin/unbound/daemon/remote.c
976
print_uptime(RES* ssl, struct worker* worker, int reset)
usr.sbin/unbound/daemon/remote.c
978
struct timeval now = *worker->env.now_tv;
usr.sbin/unbound/daemon/remote.c
980
timeval_subtract(&up, &now, &worker->daemon->time_boot);
usr.sbin/unbound/daemon/remote.c
981
timeval_subtract(&dt, &now, &worker->daemon->time_last_stat);
usr.sbin/unbound/daemon/remote.c
983
worker->daemon->time_last_stat = now;
usr.sbin/unbound/daemon/remote.h
175
struct worker* worker;
usr.sbin/unbound/daemon/remote.h
232
struct worker* worker;
usr.sbin/unbound/daemon/remote.h
290
struct listen_port* ports, struct worker* worker);
usr.sbin/unbound/daemon/remote.h
308
void daemon_remote_exec(struct worker* worker);
usr.sbin/unbound/daemon/remote.h
351
void fast_reload_thread_start(RES* ssl, struct worker* worker,
usr.sbin/unbound/daemon/remote.h
371
void fast_reload_worker_pickup_changes(struct worker* worker);
usr.sbin/unbound/daemon/remote.h
55
struct worker;
usr.sbin/unbound/daemon/remote.h
93
struct worker* worker;
usr.sbin/unbound/daemon/stats.c
100
if((long long)worker->env.mesh->all.count > stats->max_query_list_size)
usr.sbin/unbound/daemon/stats.c
101
stats->max_query_list_size = (long long)worker->env.mesh->all.count;
usr.sbin/unbound/daemon/stats.c
104
void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker)
usr.sbin/unbound/daemon/stats.c
108
stats->sum_query_list_size += worker->env.mesh->all.count;
usr.sbin/unbound/daemon/stats.c
109
if((long long)worker->env.mesh->all.count > stats->max_query_list_size)
usr.sbin/unbound/daemon/stats.c
110
stats->max_query_list_size = (long long)worker->env.mesh->all.count;
usr.sbin/unbound/daemon/stats.c
113
void server_stats_log(struct ub_server_stats* stats, struct worker* worker,
usr.sbin/unbound/daemon/stats.c
132
(unsigned)worker->env.mesh->stats_dropped,
usr.sbin/unbound/daemon/stats.c
133
(unsigned)worker->env.mesh->stats_jostled);
usr.sbin/unbound/daemon/stats.c
140
set_subnet_stats(struct worker* worker, struct ub_server_stats* svr,
usr.sbin/unbound/daemon/stats.c
143
int m = modstack_find(&worker->env.mesh->mods, "subnetcache");
usr.sbin/unbound/daemon/stats.c
147
sne = (struct subnet_env*)worker->env.modinfo[m];
usr.sbin/unbound/daemon/stats.c
148
if(reset && !worker->env.cfg->stat_cumulative) {
usr.sbin/unbound/daemon/stats.c
155
if(reset && !worker->env.cfg->stat_cumulative) {
usr.sbin/unbound/daemon/stats.c
165
set_neg_cache_stats(struct worker* worker, struct ub_server_stats* svr,
usr.sbin/unbound/daemon/stats.c
168
int m = modstack_find(&worker->env.mesh->mods, "validator");
usr.sbin/unbound/daemon/stats.c
173
ve = (struct val_env*)worker->env.modinfo[m];
usr.sbin/unbound/daemon/stats.c
180
if(reset && !worker->env.cfg->stat_cumulative) {
usr.sbin/unbound/daemon/stats.c
189
get_rrset_bogus(struct worker* worker, int reset)
usr.sbin/unbound/daemon/stats.c
191
int m = modstack_find(&worker->env.mesh->mods, "validator");
usr.sbin/unbound/daemon/stats.c
196
ve = (struct val_env*)worker->env.modinfo[m];
usr.sbin/unbound/daemon/stats.c
199
if(reset && !worker->env.cfg->stat_cumulative)
usr.sbin/unbound/daemon/stats.c
207
get_queries_ratelimit(struct worker* worker, int reset)
usr.sbin/unbound/daemon/stats.c
209
int m = modstack_find(&worker->env.mesh->mods, "iterator");
usr.sbin/unbound/daemon/stats.c
214
ie = (struct iter_env*)worker->env.modinfo[m];
usr.sbin/unbound/daemon/stats.c
217
if(reset && !worker->env.cfg->stat_cumulative)
usr.sbin/unbound/daemon/stats.c
226
get_dnscrypt_cache_miss(struct worker* worker, int reset)
usr.sbin/unbound/daemon/stats.c
229
struct dnsc_env* de = worker->daemon->dnscenv;
usr.sbin/unbound/daemon/stats.c
234
if(reset && !worker->env.cfg->stat_cumulative)
usr.sbin/unbound/daemon/stats.c
242
get_dnscrypt_replay(struct worker* worker, int reset)
usr.sbin/unbound/daemon/stats.c
245
struct dnsc_env* de = worker->daemon->dnscenv;
usr.sbin/unbound/daemon/stats.c
249
if(reset && !worker->env.cfg->stat_cumulative)
usr.sbin/unbound/daemon/stats.c
257
server_stats_compile(struct worker* worker, struct ub_stats_info* s, int reset)
usr.sbin/unbound/daemon/stats.c
262
s->svr = worker->stats;
usr.sbin/unbound/daemon/stats.c
263
s->mesh_num_states = (long long)worker->env.mesh->all.count;
usr.sbin/unbound/daemon/stats.c
264
s->mesh_num_reply_states = (long long)worker->env.mesh->num_reply_states;
usr.sbin/unbound/daemon/stats.c
265
s->mesh_jostled = (long long)worker->env.mesh->stats_jostled;
usr.sbin/unbound/daemon/stats.c
266
s->mesh_dropped = (long long)worker->env.mesh->stats_dropped;
usr.sbin/unbound/daemon/stats.c
267
s->mesh_replies_sent = (long long)worker->env.mesh->replies_sent;
usr.sbin/unbound/daemon/stats.c
268
s->mesh_replies_sum_wait_sec = (long long)worker->env.mesh->replies_sum_wait.tv_sec;
usr.sbin/unbound/daemon/stats.c
269
s->mesh_replies_sum_wait_usec = (long long)worker->env.mesh->replies_sum_wait.tv_usec;
usr.sbin/unbound/daemon/stats.c
270
s->mesh_time_median = timehist_quartile(worker->env.mesh->histogram,
usr.sbin/unbound/daemon/stats.c
274
s->svr.ans_secure += (long long)worker->env.mesh->ans_secure;
usr.sbin/unbound/daemon/stats.c
275
s->svr.ans_bogus += (long long)worker->env.mesh->ans_bogus;
usr.sbin/unbound/daemon/stats.c
276
s->svr.val_ops += (long long)worker->env.mesh->val_ops;
usr.sbin/unbound/daemon/stats.c
277
s->svr.ans_rcode_nodata += (long long)worker->env.mesh->ans_nodata;
usr.sbin/unbound/daemon/stats.c
278
s->svr.ans_expired += (long long)worker->env.mesh->ans_expired;
usr.sbin/unbound/daemon/stats.c
280
s->svr.ans_rcode[i] += (long long)worker->env.mesh->ans_rcode[i];
usr.sbin/unbound/daemon/stats.c
282
s->svr.rpz_action[i] += (long long)worker->env.mesh->rpz_action[i];
usr.sbin/unbound/daemon/stats.c
283
timehist_export(worker->env.mesh->histogram, s->svr.hist,
usr.sbin/unbound/daemon/stats.c
286
(long long)worker->env.mesh->num_queries_discard_timeout;
usr.sbin/unbound/daemon/stats.c
288
(long long)worker->env.mesh->num_queries_wait_limit;
usr.sbin/unbound/daemon/stats.c
290
(long long)worker->env.mesh->num_dns_error_reports;
usr.sbin/unbound/daemon/stats.c
292
s->svr.unwanted_replies = (long long)worker->back->unwanted_replies;
usr.sbin/unbound/daemon/stats.c
293
s->svr.qtcp_outgoing = (long long)worker->back->num_tcp_outgoing;
usr.sbin/unbound/daemon/stats.c
294
s->svr.qudp_outgoing = (long long)worker->back->num_udp_outgoing;
usr.sbin/unbound/daemon/stats.c
297
s->svr.rrset_bogus = (long long)get_rrset_bogus(worker, reset);
usr.sbin/unbound/daemon/stats.c
300
s->svr.queries_ratelimited = (long long)get_queries_ratelimit(worker, reset);
usr.sbin/unbound/daemon/stats.c
303
get_slabhash_stats(worker->env.msg_cache,
usr.sbin/unbound/daemon/stats.c
305
get_slabhash_stats(&worker->env.rrset_cache->table,
usr.sbin/unbound/daemon/stats.c
307
s->svr.infra_cache_count = (long long)count_slabhash_entries(worker->env.infra_cache->hosts);
usr.sbin/unbound/daemon/stats.c
308
if(worker->env.key_cache)
usr.sbin/unbound/daemon/stats.c
309
s->svr.key_cache_count = (long long)count_slabhash_entries(worker->env.key_cache->slab);
usr.sbin/unbound/daemon/stats.c
313
if(worker->daemon->dnscenv) {
usr.sbin/unbound/daemon/stats.c
315
(long long)get_dnscrypt_cache_miss(worker, reset);
usr.sbin/unbound/daemon/stats.c
317
worker->daemon->dnscenv->shared_secrets_cache);
usr.sbin/unbound/daemon/stats.c
319
worker->daemon->dnscenv->nonces_cache);
usr.sbin/unbound/daemon/stats.c
321
(long long)get_dnscrypt_replay(worker, reset);
usr.sbin/unbound/daemon/stats.c
334
if(worker->env.auth_zones) {
usr.sbin/unbound/daemon/stats.c
335
s->svr.num_query_authzone_up += (long long)worker->env.mesh->num_query_authzone_up;
usr.sbin/unbound/daemon/stats.c
336
s->svr.num_query_authzone_down += (long long)worker->env.mesh->num_query_authzone_down;
usr.sbin/unbound/daemon/stats.c
346
worker->daemon->doq_table);
usr.sbin/unbound/daemon/stats.c
352
set_neg_cache_stats(worker, &s->svr, reset);
usr.sbin/unbound/daemon/stats.c
355
set_subnet_stats(worker, &s->svr, reset);
usr.sbin/unbound/daemon/stats.c
361
s->svr.num_query_cachedb = (long long)worker->env.mesh->ans_cachedb;
usr.sbin/unbound/daemon/stats.c
368
for(lp = worker->front->cps; lp; lp = lp->next) {
usr.sbin/unbound/daemon/stats.c
373
if(reset && !worker->env.cfg->stat_cumulative) {
usr.sbin/unbound/daemon/stats.c
374
worker_stats_clear(worker);
usr.sbin/unbound/daemon/stats.c
378
void server_stats_obtain(struct worker* worker, struct worker* who,
usr.sbin/unbound/daemon/stats.c
383
if(worker == who) {
usr.sbin/unbound/daemon/stats.c
385
server_stats_compile(worker, s, reset);
usr.sbin/unbound/daemon/stats.c
394
if(tube_wait_timeout(worker->cmd, STATS_THREAD_WAIT) == 0) {
usr.sbin/unbound/daemon/stats.c
423
if(!tube_read_msg(worker->cmd, &reply, &len, 0))
usr.sbin/unbound/daemon/stats.c
432
void server_stats_reply(struct worker* worker, int reset)
usr.sbin/unbound/daemon/stats.c
435
server_stats_compile(worker, &s, reset);
usr.sbin/unbound/daemon/stats.c
437
if(!tube_write_msg(worker->daemon->workers[0]->cmd,
usr.sbin/unbound/daemon/stats.c
96
void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker)
usr.sbin/unbound/daemon/stats.c
99
stats->sum_query_list_size += worker->env.mesh->all.count;
usr.sbin/unbound/daemon/stats.h
100
void server_stats_reply(struct worker* worker, int reset);
usr.sbin/unbound/daemon/stats.h
46
struct worker;
usr.sbin/unbound/daemon/stats.h
64
void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker);
usr.sbin/unbound/daemon/stats.h
67
void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker);
usr.sbin/unbound/daemon/stats.h
70
void server_stats_log(struct ub_server_stats* stats, struct worker* worker,
usr.sbin/unbound/daemon/stats.h
80
void server_stats_obtain(struct worker* worker, struct worker* who,
usr.sbin/unbound/daemon/stats.h
91
void server_stats_compile(struct worker* worker, struct ub_stats_info* s,
usr.sbin/unbound/daemon/worker.c
1017
struct worker* worker, struct comm_reply* repinfo)
usr.sbin/unbound/daemon/worker.c
1019
chaos_replystr(pkt, (char**)&str, 1, edns, worker, repinfo);
usr.sbin/unbound/daemon/worker.c
1030
chaos_trustanchor(sldns_buffer* pkt, struct edns_data* edns, struct worker* w,
usr.sbin/unbound/daemon/worker.c
1090
answer_chaos(struct worker* w, struct query_info* qinfo,
usr.sbin/unbound/daemon/worker.c
1152
answer_notify(struct worker* w, struct query_info* qinfo,
usr.sbin/unbound/daemon/worker.c
117
worker_mem_report(struct worker* ATTR_UNUSED(worker),
usr.sbin/unbound/daemon/worker.c
1204
struct worker* worker, struct comm_reply* repinfo,
usr.sbin/unbound/daemon/worker.c
1215
if(worker->stats.extended)
usr.sbin/unbound/daemon/worker.c
1216
worker->stats.unwanted_queries++;
usr.sbin/unbound/daemon/worker.c
1227
if(worker->stats.extended)
usr.sbin/unbound/daemon/worker.c
1228
worker->stats.unwanted_queries++;
usr.sbin/unbound/daemon/worker.c
1229
worker_check_request(c->buffer, worker, check_result);
usr.sbin/unbound/daemon/worker.c
132
front = listen_get_mem(worker->front);
usr.sbin/unbound/daemon/worker.c
133
back = outnet_get_mem(worker->back);
usr.sbin/unbound/daemon/worker.c
134
msg = slabhash_get_mem(worker->env.msg_cache);
usr.sbin/unbound/daemon/worker.c
135
rrset = slabhash_get_mem(&worker->env.rrset_cache->table);
usr.sbin/unbound/daemon/worker.c
136
infra = infra_get_mem(worker->env.infra_cache);
usr.sbin/unbound/daemon/worker.c
137
mesh = mesh_get_mem(worker->env.mesh);
usr.sbin/unbound/daemon/worker.c
138
ac = alloc_get_mem(worker->alloc);
usr.sbin/unbound/daemon/worker.c
139
superac = alloc_get_mem(&worker->daemon->superalloc);
usr.sbin/unbound/daemon/worker.c
1392
struct worker* worker, struct comm_reply* repinfo,
usr.sbin/unbound/daemon/worker.c
1397
*acladdr = acl_addr_lookup(worker->daemon->acl,
usr.sbin/unbound/daemon/worker.c
140
anch = anchors_get_mem(worker->env.anchors);
usr.sbin/unbound/daemon/worker.c
1400
*acladdr = acl_addr_lookup(worker->daemon->acl,
usr.sbin/unbound/daemon/worker.c
1408
return deny_refuse(c, *acl, acl_deny, acl_refuse, worker, repinfo,
usr.sbin/unbound/daemon/worker.c
1414
struct worker* worker, struct comm_reply* repinfo,
usr.sbin/unbound/daemon/worker.c
1419
worker, repinfo, acladdr, ede, check_result);
usr.sbin/unbound/daemon/worker.c
1425
check_ip_ratelimit(struct worker* worker, struct sockaddr_storage* addr,
usr.sbin/unbound/daemon/worker.c
1428
if(!infra_ip_ratelimit_inc(worker->env.infra_cache, addr, addrlen,
usr.sbin/unbound/daemon/worker.c
1429
*worker->env.now, has_cookie,
usr.sbin/unbound/daemon/worker.c
143
for(i=0; i<worker->env.mesh->mods.num; i++) {
usr.sbin/unbound/daemon/worker.c
1430
worker->env.cfg->ip_ratelimit_backoff, pkt)) {
usr.sbin/unbound/daemon/worker.c
1432
if(!has_cookie && worker->env.cfg->ip_ratelimit_factor != 0 &&
usr.sbin/unbound/daemon/worker.c
1433
ub_random_max(worker->env.rnd,
usr.sbin/unbound/daemon/worker.c
1434
worker->env.cfg->ip_ratelimit_factor) == 0) {
usr.sbin/unbound/daemon/worker.c
144
fptr_ok(fptr_whitelist_mod_get_mem(worker->env.mesh->
usr.sbin/unbound/daemon/worker.c
1451
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/worker.c
146
if(strcmp(worker->env.mesh->mods.mod[i]->name, "validator")==0)
usr.sbin/unbound/daemon/worker.c
147
val += (*worker->env.mesh->mods.mod[i]->get_mem)
usr.sbin/unbound/daemon/worker.c
148
(&worker->env, i);
usr.sbin/unbound/daemon/worker.c
1485
if (worker->env.cfg->sock_queue_timeout && timeval_isset(&c->recv_tv)) {
usr.sbin/unbound/daemon/worker.c
1486
timeval_subtract(&wait_time, worker->env.now_tv, &c->recv_tv);
usr.sbin/unbound/daemon/worker.c
1488
if (worker->stats.max_query_time_us < wait_queue_time)
usr.sbin/unbound/daemon/worker.c
1489
worker->stats.max_query_time_us = wait_queue_time;
usr.sbin/unbound/daemon/worker.c
1491
(long long)(worker->env.cfg->sock_queue_timeout * 1000000)) {
usr.sbin/unbound/daemon/worker.c
1493
worker->stats.num_queries_timed_out++;
usr.sbin/unbound/daemon/worker.c
1499
repinfo->max_udp_size = worker->daemon->cfg->max_udp_size;
usr.sbin/unbound/daemon/worker.c
150
else if(strcmp(worker->env.mesh->mods.mod[i]->name,
usr.sbin/unbound/daemon/worker.c
1500
if(!dnsc_handle_curved_request(worker->daemon->dnscenv, repinfo)) {
usr.sbin/unbound/daemon/worker.c
1501
worker->stats.num_query_dnscrypt_crypted_malformed++;
usr.sbin/unbound/daemon/worker.c
1507
worker_check_request(c->buffer, worker, &check_result);
usr.sbin/unbound/daemon/worker.c
152
subnet += (*worker->env.mesh->mods.mod[i]->get_mem)
usr.sbin/unbound/daemon/worker.c
1527
worker->daemon->dnscenv->provider_name) == 0)) {
usr.sbin/unbound/daemon/worker.c
153
(&worker->env, i);
usr.sbin/unbound/daemon/worker.c
1530
worker->daemon->dnscenv->provider_name,
usr.sbin/unbound/daemon/worker.c
1534
worker->stats.num_query_dnscrypt_cleartext++;
usr.sbin/unbound/daemon/worker.c
1537
worker->stats.num_query_dnscrypt_cert++;
usr.sbin/unbound/daemon/worker.c
1540
worker->stats.num_query_dnscrypt_crypted++;
usr.sbin/unbound/daemon/worker.c
1547
if(worker->dtenv.log_client_query_messages) {
usr.sbin/unbound/daemon/worker.c
155
else iter += (*worker->env.mesh->mods.mod[i]->get_mem)
usr.sbin/unbound/daemon/worker.c
1550
dt_msg_send_client_query(&worker->dtenv, &repinfo->client_addr, (void*)repinfo->c->socket->addr, c->type, c->ssl, c->buffer,
usr.sbin/unbound/daemon/worker.c
1551
((worker->env.cfg->sock_queue_timeout && timeval_isset(&c->recv_tv))?&c->recv_tv:NULL));
usr.sbin/unbound/daemon/worker.c
1556
if((ret=deny_refuse_all(c, &acl, worker, repinfo, &acladdr,
usr.sbin/unbound/daemon/worker.c
1557
worker->env.cfg->ede, 1, &check_result)) != -1) {
usr.sbin/unbound/daemon/worker.c
156
(&worker->env, i);
usr.sbin/unbound/daemon/worker.c
1563
if((ret=deny_refuse_all(c, &acl, worker, repinfo, &acladdr,
usr.sbin/unbound/daemon/worker.c
1564
worker->env.cfg->ede, 0, &check_result)) != -1) {
usr.sbin/unbound/daemon/worker.c
1570
worker_check_request(c->buffer, worker, &check_result);
usr.sbin/unbound/daemon/worker.c
158
me = sizeof(*worker) + sizeof(*worker->base) + sizeof(*worker->comsig)
usr.sbin/unbound/daemon/worker.c
1584
worker->stats.num_queries++;
usr.sbin/unbound/daemon/worker.c
1585
pre_edns_ip_ratelimit = !worker->env.cfg->do_answer_cookie
usr.sbin/unbound/daemon/worker.c
159
+ comm_point_get_mem(worker->cmd_com)
usr.sbin/unbound/daemon/worker.c
1594
if(!check_ip_ratelimit(worker, &repinfo->client_addr,
usr.sbin/unbound/daemon/worker.c
1596
worker->stats.num_queries_ip_ratelimited++;
usr.sbin/unbound/daemon/worker.c
160
+ sizeof(worker->rndstate)
usr.sbin/unbound/daemon/worker.c
1607
if(worker_err_ratelimit(worker, LDNS_RCODE_FORMERR) == -1) {
usr.sbin/unbound/daemon/worker.c
161
+ regional_get_mem(worker->scratchpad)
usr.sbin/unbound/daemon/worker.c
1617
if(worker->env.cfg->log_queries) {
usr.sbin/unbound/daemon/worker.c
162
+ sizeof(*worker->env.scratch_buffer)
usr.sbin/unbound/daemon/worker.c
163
+ sldns_buffer_capacity(worker->env.scratch_buffer);
usr.sbin/unbound/daemon/worker.c
1631
if(worker->stats.extended) {
usr.sbin/unbound/daemon/worker.c
1632
worker->stats.qtype[qinfo.qtype]++;
usr.sbin/unbound/daemon/worker.c
164
if(worker->daemon->env->fwds)
usr.sbin/unbound/daemon/worker.c
1645
if(worker_err_ratelimit(worker, LDNS_RCODE_FORMERR) == -1) {
usr.sbin/unbound/daemon/worker.c
165
log_info("forwards=%u", (unsigned)forwards_get_mem(worker->env.fwds));
usr.sbin/unbound/daemon/worker.c
1653
if(worker->stats.extended) {
usr.sbin/unbound/daemon/worker.c
1654
worker->stats.qtype[qinfo.qtype]++;
usr.sbin/unbound/daemon/worker.c
1659
c->buffer, &edns, worker->env.cfg, c, repinfo,
usr.sbin/unbound/daemon/worker.c
166
if(worker->daemon->env->hints)
usr.sbin/unbound/daemon/worker.c
1660
(worker->env.now ? *worker->env.now : time(NULL)),
usr.sbin/unbound/daemon/worker.c
1661
worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
1662
worker->daemon->cookie_secrets)) != 0) {
usr.sbin/unbound/daemon/worker.c
167
log_info("hints=%u", (unsigned)hints_get_mem(worker->env.hints));
usr.sbin/unbound/daemon/worker.c
1672
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
168
if(worker->thread_num == 0)
usr.sbin/unbound/daemon/worker.c
1686
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
169
me += acl_list_get_mem(worker->daemon->acl);
usr.sbin/unbound/daemon/worker.c
1690
worker->daemon->cfg->harden_short_bufsize) {
usr.sbin/unbound/daemon/worker.c
1700
server_stats_downstream_cookie(&worker->stats, &edns);
usr.sbin/unbound/daemon/worker.c
1706
if(!check_ip_ratelimit(worker, &repinfo->client_addr,
usr.sbin/unbound/daemon/worker.c
1709
worker->stats.num_queries_ip_ratelimited++;
usr.sbin/unbound/daemon/worker.c
1710
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1734
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1743
worker->scratchpad, LDNS_EDE_OTHER,
usr.sbin/unbound/daemon/worker.c
1751
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1755
if(edns.udp_size > worker->daemon->cfg->max_udp_size &&
usr.sbin/unbound/daemon/worker.c
1762
edns.udp_size = worker->daemon->cfg->max_udp_size;
usr.sbin/unbound/daemon/worker.c
1776
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1779
if(worker->stats.extended)
usr.sbin/unbound/daemon/worker.c
1780
server_stats_insquery(&worker->stats, c, qinfo.qtype,
usr.sbin/unbound/daemon/worker.c
1784
if(qinfo.qclass == LDNS_RR_CLASS_CH && answer_chaos(worker, &qinfo,
usr.sbin/unbound/daemon/worker.c
1786
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1791
answer_notify(worker, &qinfo, &edns, c->buffer,
usr.sbin/unbound/daemon/worker.c
1793
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1796
if(local_zones_answer(worker->daemon->local_zones, &worker->env, &qinfo,
usr.sbin/unbound/daemon/worker.c
1797
&edns, c->buffer, worker->scratchpad, repinfo, acladdr->taglist,
usr.sbin/unbound/daemon/worker.c
1800
acladdr->tag_datas_size, worker->daemon->cfg->tagname,
usr.sbin/unbound/daemon/worker.c
1801
worker->daemon->cfg->num_tags, acladdr->view)) {
usr.sbin/unbound/daemon/worker.c
1802
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1809
if(worker->env.auth_zones &&
usr.sbin/unbound/daemon/worker.c
1810
rpz_callback_from_worker_request(worker->env.auth_zones,
usr.sbin/unbound/daemon/worker.c
1811
&worker->env, &qinfo, &edns, c->buffer, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
1812
repinfo, acladdr->taglist, acladdr->taglen, &worker->stats,
usr.sbin/unbound/daemon/worker.c
1814
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1821
if(worker->env.auth_zones &&
usr.sbin/unbound/daemon/worker.c
1822
auth_zones_downstream_answer(worker->env.auth_zones,
usr.sbin/unbound/daemon/worker.c
1823
&worker->env, &qinfo, &edns, repinfo, c->buffer,
usr.sbin/unbound/daemon/worker.c
1824
worker->scratchpad)) {
usr.sbin/unbound/daemon/worker.c
1825
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1840
if((ret=deny_refuse_non_local(c, acl, worker, repinfo, acladdr,
usr.sbin/unbound/daemon/worker.c
1841
worker->env.cfg->ede, &check_result)) != -1)
usr.sbin/unbound/daemon/worker.c
1843
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1860
if(worker->env.cfg->ede) {
usr.sbin/unbound/daemon/worker.c
1862
worker->scratchpad, LDNS_EDE_NOT_AUTHORITATIVE, "");
usr.sbin/unbound/daemon/worker.c
1867
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1879
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1887
if((worker->daemon->use_response_ip || worker->daemon->use_rpz) &&
usr.sbin/unbound/daemon/worker.c
1912
if(!edns_bypass_cache_stage(edns.opt_list_in, &worker->env)) {
usr.sbin/unbound/daemon/worker.c
1916
if((e=slabhash_lookup(worker->env.msg_cache, h, lookup_qinfo, 0))) {
usr.sbin/unbound/daemon/worker.c
1919
if(answer_from_cache(worker, &qinfo, cinfo, &need_drop,
usr.sbin/unbound/daemon/worker.c
1929
if((worker->env.cfg->prefetch &&
usr.sbin/unbound/daemon/worker.c
1930
rep->prefetch_ttl <= *worker->env.now) ||
usr.sbin/unbound/daemon/worker.c
1931
(worker->env.cfg->serve_expired &&
usr.sbin/unbound/daemon/worker.c
1932
rep->ttl < *worker->env.now &&
usr.sbin/unbound/daemon/worker.c
1933
!(*worker->env.now < rep->serve_expired_norec_ttl))) {
usr.sbin/unbound/daemon/worker.c
1934
time_t leeway = rep->ttl - *worker->env.now;
usr.sbin/unbound/daemon/worker.c
1935
if(rep->ttl < *worker->env.now)
usr.sbin/unbound/daemon/worker.c
1939
reply_and_prefetch(worker, lookup_qinfo,
usr.sbin/unbound/daemon/worker.c
1947
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1952
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1970
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1983
if(answer_norec_from_cache(worker, &qinfo,
usr.sbin/unbound/daemon/worker.c
1987
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
1995
server_stats_querymiss(&worker->stats, worker);
usr.sbin/unbound/daemon/worker.c
2006
mesh_new_client(worker->env.mesh, &qinfo, cinfo,
usr.sbin/unbound/daemon/worker.c
2010
regional_free_all(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
2011
worker_mem_report(worker, NULL);
usr.sbin/unbound/daemon/worker.c
2022
worker->stats.ans_expired++;
usr.sbin/unbound/daemon/worker.c
2024
server_stats_insrcode(&worker->stats, c->buffer);
usr.sbin/unbound/daemon/worker.c
2025
if(worker->stats.extended) {
usr.sbin/unbound/daemon/worker.c
2026
if(is_secure_answer) worker->stats.ans_secure++;
usr.sbin/unbound/daemon/worker.c
2032
if(worker->dtenv.log_client_response_messages && rc !=0) {
usr.sbin/unbound/daemon/worker.c
2035
dt_msg_send_client_response(&worker->dtenv, &repinfo->client_addr, (void*)repinfo->c->socket->addr, c->type, c->ssl, c->buffer);
usr.sbin/unbound/daemon/worker.c
2038
if(worker->env.cfg->log_replies)
usr.sbin/unbound/daemon/worker.c
204
for(i=0; i<worker->env.mesh->mods.num; i++) {
usr.sbin/unbound/daemon/worker.c
205
fptr_ok(fptr_whitelist_mod_get_mem(worker->env.mesh->
usr.sbin/unbound/daemon/worker.c
2050
(worker->env.cfg->log_destaddr?(void*)repinfo->c->socket->addr:NULL),
usr.sbin/unbound/daemon/worker.c
2056
(worker->env.cfg->log_destaddr?(void*)repinfo->c->socket->addr:NULL),
usr.sbin/unbound/daemon/worker.c
207
if(strcmp(worker->env.mesh->mods.mod[i]->name, "validator")==0)
usr.sbin/unbound/daemon/worker.c
2073
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/worker.c
2077
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/worker.c
208
val += (*worker->env.mesh->mods.mod[i]->get_mem)
usr.sbin/unbound/daemon/worker.c
2084
worker->need_to_exit = 1;
usr.sbin/unbound/daemon/worker.c
2085
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/worker.c
2089
worker->need_to_exit = 1;
usr.sbin/unbound/daemon/worker.c
209
(&worker->env, i);
usr.sbin/unbound/daemon/worker.c
2090
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/worker.c
2094
worker->need_to_exit = 1;
usr.sbin/unbound/daemon/worker.c
2095
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/worker.c
2105
worker_restart_timer(struct worker* worker)
usr.sbin/unbound/daemon/worker.c
2107
if(worker->env.cfg->stat_interval > 0) {
usr.sbin/unbound/daemon/worker.c
211
else if(strcmp(worker->env.mesh->mods.mod[i]->name,
usr.sbin/unbound/daemon/worker.c
2110
tv.tv_sec = worker->env.cfg->stat_interval;
usr.sbin/unbound/daemon/worker.c
2113
comm_timer_set(worker->stat_timer, &tv);
usr.sbin/unbound/daemon/worker.c
2119
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/worker.c
2120
server_stats_log(&worker->stats, worker, worker->thread_num);
usr.sbin/unbound/daemon/worker.c
2121
mesh_stats(worker->env.mesh, "mesh has");
usr.sbin/unbound/daemon/worker.c
2122
worker_mem_report(worker, NULL);
usr.sbin/unbound/daemon/worker.c
2124
if (worker->daemon->cfg->shm_enable) {
usr.sbin/unbound/daemon/worker.c
2125
shm_main_run(worker);
usr.sbin/unbound/daemon/worker.c
2127
if(!worker->daemon->cfg->stat_cumulative) {
usr.sbin/unbound/daemon/worker.c
2128
worker_stats_clear(worker);
usr.sbin/unbound/daemon/worker.c
213
subnet += (*worker->env.mesh->mods.mod[i]->get_mem)
usr.sbin/unbound/daemon/worker.c
2131
worker_restart_timer(worker);
usr.sbin/unbound/daemon/worker.c
2136
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/worker.c
2139
tv.tv_sec = (time_t)autr_probe_timer(&worker->env);
usr.sbin/unbound/daemon/worker.c
214
(&worker->env, i);
usr.sbin/unbound/daemon/worker.c
2143
comm_timer_set(worker->env.probe_timer, &tv);
usr.sbin/unbound/daemon/worker.c
2146
struct worker*
usr.sbin/unbound/daemon/worker.c
2150
struct worker* worker = (struct worker*)calloc(1,
usr.sbin/unbound/daemon/worker.c
2151
sizeof(struct worker));
usr.sbin/unbound/daemon/worker.c
2152
if(!worker)
usr.sbin/unbound/daemon/worker.c
2154
worker->numports = n;
usr.sbin/unbound/daemon/worker.c
2155
worker->ports = (int*)memdup(ports, sizeof(int)*n);
usr.sbin/unbound/daemon/worker.c
2156
if(!worker->ports) {
usr.sbin/unbound/daemon/worker.c
2157
free(worker);
usr.sbin/unbound/daemon/worker.c
2160
worker->daemon = daemon;
usr.sbin/unbound/daemon/worker.c
2161
worker->thread_num = id;
usr.sbin/unbound/daemon/worker.c
2162
if(!(worker->cmd = tube_create())) {
usr.sbin/unbound/daemon/worker.c
2163
free(worker->ports);
usr.sbin/unbound/daemon/worker.c
2164
free(worker);
usr.sbin/unbound/daemon/worker.c
2168
if(!(worker->rndstate = ub_initstate(daemon->rand))) {
usr.sbin/unbound/daemon/worker.c
2170
tube_delete(worker->cmd);
usr.sbin/unbound/daemon/worker.c
2171
free(worker->ports);
usr.sbin/unbound/daemon/worker.c
2172
free(worker);
usr.sbin/unbound/daemon/worker.c
2176
return worker;
usr.sbin/unbound/daemon/worker.c
2180
worker_init(struct worker* worker, struct config_file *cfg,
usr.sbin/unbound/daemon/worker.c
2184
struct dt_env* dtenv = &worker->dtenv;
usr.sbin/unbound/daemon/worker.c
2189
worker->thread_tid = gettid();
usr.sbin/unbound/daemon/worker.c
2191
worker->need_to_exit = 0;
usr.sbin/unbound/daemon/worker.c
2192
worker->base = comm_base_create(do_sigs);
usr.sbin/unbound/daemon/worker.c
2193
if(!worker->base) {
usr.sbin/unbound/daemon/worker.c
2195
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2198
comm_base_set_slow_accept_handlers(worker->base, &worker_stop_accept,
usr.sbin/unbound/daemon/worker.c
2199
&worker_start_accept, worker);
usr.sbin/unbound/daemon/worker.c
220
(unsigned)slabhash_get_mem(worker->env.msg_cache),
usr.sbin/unbound/daemon/worker.c
221
(unsigned)slabhash_get_mem(&worker->env.rrset_cache->table),
usr.sbin/unbound/daemon/worker.c
2213
worker->comsig = comm_signal_create(worker->base,
usr.sbin/unbound/daemon/worker.c
2214
worker_sighandler, worker);
usr.sbin/unbound/daemon/worker.c
2215
if(!worker->comsig
usr.sbin/unbound/daemon/worker.c
2217
|| !comm_signal_bind(worker->comsig, SIGHUP)
usr.sbin/unbound/daemon/worker.c
222
(unsigned)infra_get_mem(worker->env.infra_cache),
usr.sbin/unbound/daemon/worker.c
2220
|| !comm_signal_bind(worker->comsig, SIGQUIT)
usr.sbin/unbound/daemon/worker.c
2222
|| !comm_signal_bind(worker->comsig, SIGTERM)
usr.sbin/unbound/daemon/worker.c
2224
|| !comm_signal_bind(worker->comsig, SIGBREAK)
usr.sbin/unbound/daemon/worker.c
2226
|| !comm_signal_bind(worker->comsig, SIGINT)) {
usr.sbin/unbound/daemon/worker.c
2228
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2232
if(!daemon_remote_open_accept(worker->daemon->rc,
usr.sbin/unbound/daemon/worker.c
2233
worker->daemon->rc_ports, worker)) {
usr.sbin/unbound/daemon/worker.c
2234
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2238
wsvc_setup_worker(worker);
usr.sbin/unbound/daemon/worker.c
2241
worker->comsig = NULL;
usr.sbin/unbound/daemon/worker.c
2245
log_assert(worker->daemon->dtenv != NULL);
usr.sbin/unbound/daemon/worker.c
2246
memcpy(&worker->dtenv, worker->daemon->dtenv, sizeof(struct dt_env));
usr.sbin/unbound/daemon/worker.c
2247
if(!dt_init(&worker->dtenv, worker->base))
usr.sbin/unbound/daemon/worker.c
2251
worker->front = listen_create(worker->base, ports,
usr.sbin/unbound/daemon/worker.c
2258
worker->daemon->tcl, worker->daemon->listen_dot_sslctx,
usr.sbin/unbound/daemon/worker.c
2259
worker->daemon->listen_doh_sslctx,
usr.sbin/unbound/daemon/worker.c
226
(unsigned)slabhash_get_mem(worker->env.msg_cache),
usr.sbin/unbound/daemon/worker.c
2260
worker->daemon->listen_quic_sslctx,
usr.sbin/unbound/daemon/worker.c
2261
dtenv, worker->daemon->doq_table, worker->env.rnd,
usr.sbin/unbound/daemon/worker.c
2262
cfg, worker_handle_request, worker);
usr.sbin/unbound/daemon/worker.c
2263
if(!worker->front) {
usr.sbin/unbound/daemon/worker.c
2265
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2268
worker->back = outside_network_create(worker->base,
usr.sbin/unbound/daemon/worker.c
227
(unsigned)slabhash_get_mem(&worker->env.rrset_cache->table),
usr.sbin/unbound/daemon/worker.c
2272
worker->daemon->env->infra_cache, worker->rndstate,
usr.sbin/unbound/daemon/worker.c
2273
cfg->use_caps_bits_for_id, worker->ports, worker->numports,
usr.sbin/unbound/daemon/worker.c
2275
&worker_alloc_cleanup, worker,
usr.sbin/unbound/daemon/worker.c
2277
worker->daemon->connect_dot_sslctx, cfg->delay_close,
usr.sbin/unbound/daemon/worker.c
228
(unsigned)infra_get_mem(worker->env.infra_cache),
usr.sbin/unbound/daemon/worker.c
2281
if(!worker->back) {
usr.sbin/unbound/daemon/worker.c
2283
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2286
iterator_set_ip46_support(&worker->daemon->mods, worker->daemon->env,
usr.sbin/unbound/daemon/worker.c
2287
worker->back);
usr.sbin/unbound/daemon/worker.c
2289
if(!tube_setup_bg_listen(worker->cmd, worker->base,
usr.sbin/unbound/daemon/worker.c
2290
&worker_handle_control_cmd, worker)) {
usr.sbin/unbound/daemon/worker.c
2292
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2295
worker->stat_timer = comm_timer_create(worker->base,
usr.sbin/unbound/daemon/worker.c
2296
worker_stat_timer_cb, worker);
usr.sbin/unbound/daemon/worker.c
2297
if(!worker->stat_timer) {
usr.sbin/unbound/daemon/worker.c
2303
worker->scratchpad = regional_create_custom(cfg->msg_buffer_size);
usr.sbin/unbound/daemon/worker.c
2304
if(!worker->scratchpad) {
usr.sbin/unbound/daemon/worker.c
2306
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2310
server_stats_init(&worker->stats, cfg);
usr.sbin/unbound/daemon/worker.c
2311
worker->alloc = worker->daemon->worker_allocs[worker->thread_num];
usr.sbin/unbound/daemon/worker.c
2312
alloc_set_id_cleanup(worker->alloc, &worker_alloc_cleanup, worker);
usr.sbin/unbound/daemon/worker.c
2313
worker->env = *worker->daemon->env;
usr.sbin/unbound/daemon/worker.c
2314
comm_base_timept(worker->base, &worker->env.now, &worker->env.now_tv);
usr.sbin/unbound/daemon/worker.c
2315
worker->env.worker = worker;
usr.sbin/unbound/daemon/worker.c
2316
worker->env.worker_base = worker->base;
usr.sbin/unbound/daemon/worker.c
2317
worker->env.send_query = &worker_send_query;
usr.sbin/unbound/daemon/worker.c
2318
worker->env.alloc = worker->alloc;
usr.sbin/unbound/daemon/worker.c
2319
worker->env.outnet = worker->back;
usr.sbin/unbound/daemon/worker.c
2320
worker->env.rnd = worker->rndstate;
usr.sbin/unbound/daemon/worker.c
2326
worker->env.scratch = regional_create_custom(cfg->msg_buffer_size);
usr.sbin/unbound/daemon/worker.c
2327
if(!worker->env.scratch) {
usr.sbin/unbound/daemon/worker.c
2329
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2332
worker->env.mesh = mesh_create(&worker->daemon->mods, &worker->env);
usr.sbin/unbound/daemon/worker.c
2333
if(!worker->env.mesh) {
usr.sbin/unbound/daemon/worker.c
2335
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2339
worker->env.mesh->use_response_ip = worker->daemon->use_response_ip;
usr.sbin/unbound/daemon/worker.c
2340
worker->env.mesh->use_rpz = worker->daemon->use_rpz;
usr.sbin/unbound/daemon/worker.c
2342
worker->env.detach_subs = &mesh_detach_subs;
usr.sbin/unbound/daemon/worker.c
2343
worker->env.attach_sub = &mesh_attach_sub;
usr.sbin/unbound/daemon/worker.c
2344
worker->env.add_sub = &mesh_add_sub;
usr.sbin/unbound/daemon/worker.c
2345
worker->env.kill_sub = &mesh_state_delete;
usr.sbin/unbound/daemon/worker.c
2346
worker->env.detect_cycle = &mesh_detect_cycle;
usr.sbin/unbound/daemon/worker.c
2347
worker->env.scratch_buffer = sldns_buffer_new(cfg->msg_buffer_size);
usr.sbin/unbound/daemon/worker.c
2348
if(!worker->env.scratch_buffer) {
usr.sbin/unbound/daemon/worker.c
235
worker_send_cmd(struct worker* worker, enum worker_commands cmd)
usr.sbin/unbound/daemon/worker.c
2350
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2354
if(autr_get_num_anchors(worker->env.anchors) > 0
usr.sbin/unbound/daemon/worker.c
2356
&& worker->thread_num == 0
usr.sbin/unbound/daemon/worker.c
2362
worker->env.probe_timer = comm_timer_create(worker->base,
usr.sbin/unbound/daemon/worker.c
2363
worker_probe_timer_cb, worker);
usr.sbin/unbound/daemon/worker.c
2364
if(!worker->env.probe_timer) {
usr.sbin/unbound/daemon/worker.c
2368
comm_timer_set(worker->env.probe_timer, &tv);
usr.sbin/unbound/daemon/worker.c
2372
if(worker->env.auth_zones
usr.sbin/unbound/daemon/worker.c
2374
&& worker->thread_num == 0
usr.sbin/unbound/daemon/worker.c
2377
auth_xfer_pickup_initial(worker->env.auth_zones, &worker->env);
usr.sbin/unbound/daemon/worker.c
2378
auth_zones_pickup_zonemd_verify(worker->env.auth_zones,
usr.sbin/unbound/daemon/worker.c
2379
&worker->env);
usr.sbin/unbound/daemon/worker.c
238
if(!tube_write_msg(worker->cmd, (uint8_t*)&c, sizeof(c), 0)) {
usr.sbin/unbound/daemon/worker.c
2382
if(worker->daemon->cfg->dnstap
usr.sbin/unbound/daemon/worker.c
2384
&& worker->thread_num == 0
usr.sbin/unbound/daemon/worker.c
2388
worker->base), worker->daemon->num)) {
usr.sbin/unbound/daemon/worker.c
2390
worker_delete(worker);
usr.sbin/unbound/daemon/worker.c
2395
worker_mem_report(worker, NULL);
usr.sbin/unbound/daemon/worker.c
2397
if(worker->env.cfg->stat_interval > 0) {
usr.sbin/unbound/daemon/worker.c
2399
worker->env.cfg->stat_interval);
usr.sbin/unbound/daemon/worker.c
2400
worker_restart_timer(worker);
usr.sbin/unbound/daemon/worker.c
2407
worker_work(struct worker* worker)
usr.sbin/unbound/daemon/worker.c
2409
comm_base_dispatch(worker->base);
usr.sbin/unbound/daemon/worker.c
2413
worker_delete(struct worker* worker)
usr.sbin/unbound/daemon/worker.c
2415
if(!worker)
usr.sbin/unbound/daemon/worker.c
2417
if(worker->env.mesh && verbosity >= VERB_OPS) {
usr.sbin/unbound/daemon/worker.c
2418
server_stats_log(&worker->stats, worker, worker->thread_num);
usr.sbin/unbound/daemon/worker.c
2419
mesh_stats(worker->env.mesh, "mesh has");
usr.sbin/unbound/daemon/worker.c
2420
worker_mem_report(worker, NULL);
usr.sbin/unbound/daemon/worker.c
2422
outside_network_quit_prepare(worker->back);
usr.sbin/unbound/daemon/worker.c
2423
mesh_delete(worker->env.mesh);
usr.sbin/unbound/daemon/worker.c
2424
sldns_buffer_free(worker->env.scratch_buffer);
usr.sbin/unbound/daemon/worker.c
2425
listen_delete(worker->front);
usr.sbin/unbound/daemon/worker.c
2426
outside_network_delete(worker->back);
usr.sbin/unbound/daemon/worker.c
2427
comm_signal_delete(worker->comsig);
usr.sbin/unbound/daemon/worker.c
2428
tube_delete(worker->cmd);
usr.sbin/unbound/daemon/worker.c
2429
comm_timer_delete(worker->stat_timer);
usr.sbin/unbound/daemon/worker.c
2430
comm_timer_delete(worker->env.probe_timer);
usr.sbin/unbound/daemon/worker.c
2431
free(worker->ports);
usr.sbin/unbound/daemon/worker.c
2432
if(worker->thread_num == 0) {
usr.sbin/unbound/daemon/worker.c
2434
wsvc_desetup_worker(worker);
usr.sbin/unbound/daemon/worker.c
2438
if(worker->daemon->cfg->dnstap
usr.sbin/unbound/daemon/worker.c
2440
&& worker->thread_num == 0
usr.sbin/unbound/daemon/worker.c
2443
dt_io_thread_stop(worker->dtenv.dtio);
usr.sbin/unbound/daemon/worker.c
2445
dt_deinit(&worker->dtenv);
usr.sbin/unbound/daemon/worker.c
2447
comm_base_delete(worker->base);
usr.sbin/unbound/daemon/worker.c
2448
ub_randfree(worker->rndstate);
usr.sbin/unbound/daemon/worker.c
2450
regional_destroy(worker->env.scratch);
usr.sbin/unbound/daemon/worker.c
2451
regional_destroy(worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
2452
free(worker);
usr.sbin/unbound/daemon/worker.c
2462
struct worker* worker = q->env->worker;
usr.sbin/unbound/daemon/worker.c
2468
e->qsent = outnet_serviced_query(worker->back, qinfo, flags, dnssec,
usr.sbin/unbound/daemon/worker.c
2471
worker_handle_service_reply, e, worker->back->udp_buff, q->env,
usr.sbin/unbound/daemon/worker.c
248
struct worker* worker = e->qstate->env->worker;
usr.sbin/unbound/daemon/worker.c
2482
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/worker.c
2483
slabhash_clear(&worker->env.rrset_cache->table);
usr.sbin/unbound/daemon/worker.c
2484
slabhash_clear(worker->env.msg_cache);
usr.sbin/unbound/daemon/worker.c
2487
void worker_stats_clear(struct worker* worker)
usr.sbin/unbound/daemon/worker.c
2489
server_stats_init(&worker->stats, worker->env.cfg);
usr.sbin/unbound/daemon/worker.c
2490
mesh_stats_clear(worker->env.mesh);
usr.sbin/unbound/daemon/worker.c
2491
worker->back->unwanted_replies = 0;
usr.sbin/unbound/daemon/worker.c
2492
worker->back->num_tcp_outgoing = 0;
usr.sbin/unbound/daemon/worker.c
2493
worker->back->num_udp_outgoing = 0;
usr.sbin/unbound/daemon/worker.c
2498
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/worker.c
2499
listen_start_accept(worker->front);
usr.sbin/unbound/daemon/worker.c
2500
if(worker->thread_num == 0)
usr.sbin/unbound/daemon/worker.c
2501
daemon_remote_start_accept(worker->daemon->rc);
usr.sbin/unbound/daemon/worker.c
2506
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/worker.c
2507
listen_stop_accept(worker->front);
usr.sbin/unbound/daemon/worker.c
2508
if(worker->thread_num == 0)
usr.sbin/unbound/daemon/worker.c
2509
daemon_remote_stop_accept(worker->daemon->rc);
usr.sbin/unbound/daemon/worker.c
253
mesh_report_reply(worker->env.mesh, e, reply_info, error);
usr.sbin/unbound/daemon/worker.c
254
worker_mem_report(worker, sq);
usr.sbin/unbound/daemon/worker.c
265
mesh_report_reply(worker->env.mesh, e, reply_info,
usr.sbin/unbound/daemon/worker.c
267
worker_mem_report(worker, sq);
usr.sbin/unbound/daemon/worker.c
270
mesh_report_reply(worker->env.mesh, e, reply_info, NETEVENT_NOERROR);
usr.sbin/unbound/daemon/worker.c
271
worker_mem_report(worker, sq);
usr.sbin/unbound/daemon/worker.c
281
worker_err_ratelimit(struct worker* worker, int err)
usr.sbin/unbound/daemon/worker.c
283
if(worker->err_limit_time == *worker->env.now) {
usr.sbin/unbound/daemon/worker.c
285
if(worker->err_limit_count++ > ERROR_RATELIMIT)
usr.sbin/unbound/daemon/worker.c
289
worker->err_limit_time = *worker->env.now;
usr.sbin/unbound/daemon/worker.c
290
worker->err_limit_count = 1;
usr.sbin/unbound/daemon/worker.c
310
worker_check_request(sldns_buffer* pkt, struct worker* worker,
usr.sbin/unbound/daemon/worker.c
321
worker->daemon->cfg->harden_large_queries) {
usr.sbin/unbound/daemon/worker.c
334
out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);
usr.sbin/unbound/daemon/worker.c
341
out->value = worker_err_ratelimit(worker, LDNS_RCODE_NOTIMPL);
usr.sbin/unbound/daemon/worker.c
347
out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);
usr.sbin/unbound/daemon/worker.c
355
out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);
usr.sbin/unbound/daemon/worker.c
361
out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);
usr.sbin/unbound/daemon/worker.c
367
out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);
usr.sbin/unbound/daemon/worker.c
382
worker_send_reload_ack(struct worker* worker)
usr.sbin/unbound/daemon/worker.c
387
uint8_t c = (uint8_t)worker->thread_num;
usr.sbin/unbound/daemon/worker.c
390
ret = send(worker->daemon->fast_reload_thread->commreload[1],
usr.sbin/unbound/daemon/worker.c
416
worker_stop_and_wait(struct worker* worker)
usr.sbin/unbound/daemon/worker.c
420
worker_send_reload_ack(worker);
usr.sbin/unbound/daemon/worker.c
422
if(!tube_read_msg(worker->cmd, &buf, &len, 0)) {
usr.sbin/unbound/daemon/worker.c
437
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/worker.c
443
if(worker->daemon->fast_reload_drop_mesh) {
usr.sbin/unbound/daemon/worker.c
445
mesh_delete_all(worker->env.mesh);
usr.sbin/unbound/daemon/worker.c
447
fast_reload_worker_pickup_changes(worker);
usr.sbin/unbound/daemon/worker.c
448
worker_send_reload_ack(worker);
usr.sbin/unbound/daemon/worker.c
456
struct worker* worker = (struct worker*)arg;
usr.sbin/unbound/daemon/worker.c
461
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/worker.c
473
comm_base_exit(worker->base);
usr.sbin/unbound/daemon/worker.c
477
server_stats_reply(worker, 1);
usr.sbin/unbound/daemon/worker.c
481
server_stats_reply(worker, 0);
usr.sbin/unbound/daemon/worker.c
485
daemon_remote_exec(worker);
usr.sbin/unbound/daemon/worker.c
489
worker_stop_and_wait(worker);
usr.sbin/unbound/daemon/worker.c
493
fast_reload_worker_pickup_changes(worker);
usr.sbin/unbound/daemon/worker.c
494
worker_send_reload_ack(worker);
usr.sbin/unbound/daemon/worker.c
552
answer_norec_from_cache(struct worker* worker, struct query_info* qinfo,
usr.sbin/unbound/daemon/worker.c
567
time_t timenow = *worker->env.now;
usr.sbin/unbound/daemon/worker.c
569
int must_validate = (!has_cd_bit || worker->env.cfg->ignore_cd)
usr.sbin/unbound/daemon/worker.c
570
&& worker->env.need_to_validate;
usr.sbin/unbound/daemon/worker.c
574
dp = dns_cache_find_delegation(&worker->env, qinfo->qname,
usr.sbin/unbound/daemon/worker.c
576
worker->scratchpad, &msg, timenow, 0, NULL, 0);
usr.sbin/unbound/daemon/worker.c
597
if(!inplace_cb_reply_servfail_call(&worker->env, qinfo, NULL,
usr.sbin/unbound/daemon/worker.c
598
msg->rep, LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
599
worker->env.now_tv))
usr.sbin/unbound/daemon/worker.c
602
if(worker->env.cfg->ede &&
usr.sbin/unbound/daemon/worker.c
605
worker->scratchpad, msg->rep->reason_bogus,
usr.sbin/unbound/daemon/worker.c
610
if(worker->stats.extended) {
usr.sbin/unbound/daemon/worker.c
611
worker->stats.ans_bogus++;
usr.sbin/unbound/daemon/worker.c
612
worker->stats.ans_rcode[LDNS_RCODE_SERVFAIL]++;
usr.sbin/unbound/daemon/worker.c
618
if(worker->env.cfg->val_clean_additional)
usr.sbin/unbound/daemon/worker.c
635
if(worker->env.cfg->disable_edns_do && (edns->bits & EDNS_DO))
usr.sbin/unbound/daemon/worker.c
637
if(!inplace_cb_reply_cache_call(&worker->env, qinfo, NULL, msg->rep,
usr.sbin/unbound/daemon/worker.c
638
(int)(flags&LDNS_RCODE_MASK), edns, repinfo, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
639
worker->env.now_tv))
usr.sbin/unbound/daemon/worker.c
644
if(worker->env.cfg->ede && has_cd_bit &&
usr.sbin/unbound/daemon/worker.c
649
worker->scratchpad, msg->rep->reason_bogus,
usr.sbin/unbound/daemon/worker.c
653
repinfo->c->buffer, 0, 1, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
655
if(!inplace_cb_reply_servfail_call(&worker->env, qinfo, NULL, NULL,
usr.sbin/unbound/daemon/worker.c
656
LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
657
worker->env.now_tv))
usr.sbin/unbound/daemon/worker.c
662
if(worker->stats.extended) {
usr.sbin/unbound/daemon/worker.c
663
if(secure) worker->stats.ans_secure++;
usr.sbin/unbound/daemon/worker.c
664
server_stats_insrcode(&worker->stats, repinfo->c->buffer);
usr.sbin/unbound/daemon/worker.c
675
apply_respip_action(struct worker* worker, const struct query_info* qinfo,
usr.sbin/unbound/daemon/worker.c
690
alias_rrset, 0, worker->scratchpad, az, NULL,
usr.sbin/unbound/daemon/worker.c
691
worker->env.views, worker->env.respip_set))
usr.sbin/unbound/daemon/worker.c
709
if(worker->stats.extended && actinfo.rpz_used) {
usr.sbin/unbound/daemon/worker.c
711
worker->stats.rpz_action[RPZ_DISABLED_ACTION]++;
usr.sbin/unbound/daemon/worker.c
713
worker->stats.rpz_action[RPZ_CNAME_OVERRIDE_ACTION]++;
usr.sbin/unbound/daemon/worker.c
715
worker->stats.rpz_action[
usr.sbin/unbound/daemon/worker.c
732
answer_from_cache(struct worker* worker, struct query_info* qinfo,
usr.sbin/unbound/daemon/worker.c
739
time_t timenow = *worker->env.now;
usr.sbin/unbound/daemon/worker.c
744
int must_validate = (!has_cd_bit || worker->env.cfg->ignore_cd)
usr.sbin/unbound/daemon/worker.c
745
&& worker->env.need_to_validate;
usr.sbin/unbound/daemon/worker.c
751
if(worker->env.cfg->serve_expired &&
usr.sbin/unbound/daemon/worker.c
756
(!worker->env.cfg->serve_expired_client_timeout ||
usr.sbin/unbound/daemon/worker.c
759
&& !(worker->env.cachedb_enabled &&
usr.sbin/unbound/daemon/worker.c
760
worker->env.cfg->cachedb_check_when_serve_expired)
usr.sbin/unbound/daemon/worker.c
799
if(worker->env.cfg->disable_edns_do && (edns->bits & EDNS_DO))
usr.sbin/unbound/daemon/worker.c
801
if(!inplace_cb_reply_servfail_call(&worker->env, qinfo, NULL, rep,
usr.sbin/unbound/daemon/worker.c
802
LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
803
worker->env.now_tv))
usr.sbin/unbound/daemon/worker.c
806
if(worker->env.cfg->ede && rep->reason_bogus != LDNS_EDE_NONE) {
usr.sbin/unbound/daemon/worker.c
808
worker->scratchpad, rep->reason_bogus,
usr.sbin/unbound/daemon/worker.c
813
rrset_array_unlock_touch(worker->env.rrset_cache,
usr.sbin/unbound/daemon/worker.c
814
worker->scratchpad, rep->ref, rep->rrset_count);
usr.sbin/unbound/daemon/worker.c
815
if(worker->stats.extended) {
usr.sbin/unbound/daemon/worker.c
816
worker->stats.ans_bogus ++;
usr.sbin/unbound/daemon/worker.c
817
worker->stats.ans_rcode[LDNS_RCODE_SERVFAIL] ++;
usr.sbin/unbound/daemon/worker.c
841
if(worker->env.cfg->disable_edns_do && (edns->bits & EDNS_DO))
usr.sbin/unbound/daemon/worker.c
844
if((worker->daemon->use_response_ip || worker->daemon->use_rpz) &&
usr.sbin/unbound/daemon/worker.c
845
!partial_rep && !apply_respip_action(worker, qinfo, cinfo, rep,
usr.sbin/unbound/daemon/worker.c
847
&encode_rep, worker->env.auth_zones)) {
usr.sbin/unbound/daemon/worker.c
851
must_validate, &encode_rep, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
852
worker->env.auth_zones, worker->env.views,
usr.sbin/unbound/daemon/worker.c
853
worker->env.respip_set)) {
usr.sbin/unbound/daemon/worker.c
868
worker->scratchpad);
usr.sbin/unbound/daemon/worker.c
874
worker->env.cfg->ede_serve_expired && worker->env.cfg->ede) {
usr.sbin/unbound/daemon/worker.c
876
worker->scratchpad, LDNS_EDE_STALE_ANSWER, "");
usr.sbin/unbound/daemon/worker.c
881
worker->env.cfg->ede && has_cd_bit &&
usr.sbin/unbound/daemon/worker.c
884
worker->scratchpad, encode_rep->reason_bogus,
usr.sbin/unbound/daemon/worker.c
887
if(!inplace_cb_reply_cache_call(&worker->env, qinfo, NULL, encode_rep,
usr.sbin/unbound/daemon/worker.c
888
(int)(flags&LDNS_RCODE_MASK), edns, repinfo, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
889
worker->env.now_tv))
usr.sbin/unbound/daemon/worker.c
892
repinfo->c->buffer, timenow, 1, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
895
if(!inplace_cb_reply_servfail_call(&worker->env, qinfo,
usr.sbin/unbound/daemon/worker.c
897
worker->scratchpad, worker->env.now_tv))
usr.sbin/unbound/daemon/worker.c
905
rrset_array_unlock_touch(worker->env.rrset_cache, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
911
rrset_array_unlock_touch(worker->env.rrset_cache,
usr.sbin/unbound/daemon/worker.c
912
worker->scratchpad, rep->ref, rep->rrset_count);
usr.sbin/unbound/daemon/worker.c
918
reply_and_prefetch(struct worker* worker, struct query_info* qinfo,
usr.sbin/unbound/daemon/worker.c
933
server_stats_prefetch(&worker->stats, worker);
usr.sbin/unbound/daemon/worker.c
938
if(modstack_find(&worker->env.mesh->mods, "subnetcache") != -1
usr.sbin/unbound/daemon/worker.c
939
&& worker->env.unique_mesh) {
usr.sbin/unbound/daemon/worker.c
940
mesh_new_prefetch(worker->env.mesh, qinfo, flags, leeway +
usr.sbin/unbound/daemon/worker.c
950
mesh_new_prefetch(worker->env.mesh, qinfo, flags, leeway +
usr.sbin/unbound/daemon/worker.c
966
struct worker* worker, struct comm_reply* repinfo)
usr.sbin/unbound/daemon/worker.c
975
if(!inplace_cb_reply_local_call(&worker->env, NULL, NULL, NULL,
usr.sbin/unbound/daemon/worker.c
976
LDNS_RCODE_NOERROR, edns, repinfo, worker->scratchpad,
usr.sbin/unbound/daemon/worker.c
977
worker->env.now_tv))
usr.sbin/unbound/daemon/worker.h
153
struct worker* worker_create(struct daemon* daemon, int id, int* ports, int n);
usr.sbin/unbound/daemon/worker.h
164
int worker_init(struct worker* worker, struct config_file *cfg,
usr.sbin/unbound/daemon/worker.h
170
void worker_work(struct worker* worker);
usr.sbin/unbound/daemon/worker.h
175
void worker_delete(struct worker* worker);
usr.sbin/unbound/daemon/worker.h
182
void worker_send_cmd(struct worker* worker, enum worker_commands cmd);
usr.sbin/unbound/daemon/worker.h
188
void worker_stats_clear(struct worker* worker);
usr.sbin/unbound/libunbound/libunbound.c
173
ctx->env->worker = NULL;
usr.sbin/unbound/libunbound/libworker.c
174
w->env->worker = (struct worker*)w;
usr.sbin/unbound/libunbound/libworker.c
884
struct libworker* w = (struct libworker*)q->env->worker;
usr.sbin/unbound/libunbound/libworker.c
906
struct libworker* lw = (struct libworker*)e->qstate->env->worker;
usr.sbin/unbound/services/authzone.c
5402
xfr->task_transfer->worker = NULL;
usr.sbin/unbound/services/authzone.c
5592
log_assert(xfr->task_transfer->worker == env->worker);
usr.sbin/unbound/services/authzone.c
5636
if(xfr->task_nextprobe->worker == NULL)
usr.sbin/unbound/services/authzone.c
6117
if(xfr->task_nextprobe->worker == NULL)
usr.sbin/unbound/services/authzone.c
6330
log_assert(xfr->task_transfer->worker == NULL);
usr.sbin/unbound/services/authzone.c
6333
xfr->task_transfer->worker = env->worker;
usr.sbin/unbound/services/authzone.c
6357
xfr->task_probe->worker = NULL;
usr.sbin/unbound/services/authzone.c
6545
if(xfr->task_transfer->worker == NULL) {
usr.sbin/unbound/services/authzone.c
6710
if(xfr->task_nextprobe->worker == NULL)
usr.sbin/unbound/services/authzone.c
6738
if(xfr->task_nextprobe->worker == NULL)
usr.sbin/unbound/services/authzone.c
6750
if(xfr->task_nextprobe->worker == NULL)
usr.sbin/unbound/services/authzone.c
6832
xfr->task_nextprobe->worker = NULL;
usr.sbin/unbound/services/authzone.c
6887
if(xfr->task_probe->worker == NULL) {
usr.sbin/unbound/services/authzone.c
6893
if(xfr->task_transfer->worker == NULL) {
usr.sbin/unbound/services/authzone.c
6902
xfr->task_probe->worker = env->worker;
usr.sbin/unbound/services/authzone.c
6935
log_assert(xfr->task_nextprobe->worker == NULL ||
usr.sbin/unbound/services/authzone.c
6936
xfr->task_nextprobe->worker == env->worker);
usr.sbin/unbound/services/authzone.c
6988
xfr->task_nextprobe->worker = env->worker;
usr.sbin/unbound/services/authzone.c
6998
if(xfr->task_probe->worker == NULL)
usr.sbin/unbound/services/authzone.c
7028
if(x->task_nextprobe && x->task_nextprobe->worker == NULL) {
usr.sbin/unbound/services/authzone.c
7059
if(x->task_nextprobe && x->task_nextprobe->worker != NULL) {
usr.sbin/unbound/services/authzone.c
7062
if(x->task_probe && x->task_probe->worker != NULL) {
usr.sbin/unbound/services/authzone.c
7065
if(x->task_transfer && x->task_transfer->worker != NULL) {
usr.sbin/unbound/services/authzone.c
7135
lock_protect(&xfr->lock, &xfr->task_nextprobe->worker,
usr.sbin/unbound/services/authzone.c
7136
sizeof(xfr->task_nextprobe->worker));
usr.sbin/unbound/services/authzone.c
7137
lock_protect(&xfr->lock, &xfr->task_probe->worker,
usr.sbin/unbound/services/authzone.c
7138
sizeof(xfr->task_probe->worker));
usr.sbin/unbound/services/authzone.c
7139
lock_protect(&xfr->lock, &xfr->task_transfer->worker,
usr.sbin/unbound/services/authzone.c
7140
sizeof(xfr->task_transfer->worker));
usr.sbin/unbound/services/authzone.c
8753
void xfr_disown_tasks(struct auth_xfer* xfr, struct worker* worker)
usr.sbin/unbound/services/authzone.c
8755
if(xfr->task_nextprobe->worker == worker) {
usr.sbin/unbound/services/authzone.c
8758
if(xfr->task_probe->worker == worker) {
usr.sbin/unbound/services/authzone.c
8761
if(xfr->task_transfer->worker == worker) {
usr.sbin/unbound/services/authzone.h
299
struct worker* worker;
usr.sbin/unbound/services/authzone.h
325
struct worker* worker;
usr.sbin/unbound/services/authzone.h
373
struct worker* worker;
usr.sbin/unbound/services/authzone.h
58
struct worker;
usr.sbin/unbound/services/authzone.h
829
void xfr_disown_tasks(struct auth_xfer* xfr, struct worker* worker);
usr.sbin/unbound/services/rpz.c
2360
if(ms->env->worker)
usr.sbin/unbound/services/rpz.c
2361
ms->env->worker->stats.rpz_action[action]++;
usr.sbin/unbound/services/rpz.c
2422
if(ms->env->worker)
usr.sbin/unbound/services/rpz.c
2423
ms->env->worker->stats.rpz_action[action]++;
usr.sbin/unbound/services/rpz.c
2581
if(ms->env->worker)
usr.sbin/unbound/services/rpz.c
2582
ms->env->worker->stats.rpz_action[r->action_override]++;
usr.sbin/unbound/testcode/fake_event.c
1733
void daemon_remote_exec(struct worker* ATTR_UNUSED(worker))
usr.sbin/unbound/testcode/fake_event.c
72
struct worker;
usr.sbin/unbound/testcode/testbound.c
639
struct listen_port* ATTR_UNUSED(ports), struct worker* worker)
usr.sbin/unbound/testcode/testbound.c
641
struct replay_runtime* runtime = (struct replay_runtime*)worker->base;
usr.sbin/unbound/testcode/testbound.c
642
runtime->daemon = worker->daemon;
usr.sbin/unbound/testcode/testbound.c
677
void wsvc_setup_worker(struct worker* ATTR_UNUSED(worker))
usr.sbin/unbound/testcode/testbound.c
684
void wsvc_desetup_worker(struct worker* ATTR_UNUSED(worker))
usr.sbin/unbound/testcode/testbound.c
730
void fast_reload_worker_pickup_changes(struct worker* ATTR_UNUSED(worker))
usr.sbin/unbound/util/module.c
266
if(env->worker) {
usr.sbin/unbound/util/module.c
301
if(env->worker) {
usr.sbin/unbound/util/module.h
168
struct worker;
usr.sbin/unbound/util/module.h
487
struct worker* worker;
usr.sbin/unbound/util/shm_side/shm_main.c
224
void shm_main_run(struct worker *worker)
usr.sbin/unbound/util/shm_side/shm_main.c
234
worker->thread_num, worker->daemon, (unsigned)worker->env.now_tv->tv_sec, (unsigned)worker->daemon->time_boot.tv_sec);
usr.sbin/unbound/util/shm_side/shm_main.c
237
offset = worker->thread_num + 1;
usr.sbin/unbound/util/shm_side/shm_main.c
238
stat_total = worker->daemon->shm_info->ptr_arr;
usr.sbin/unbound/util/shm_side/shm_main.c
239
stat_info = worker->daemon->shm_info->ptr_arr + offset;
usr.sbin/unbound/util/shm_side/shm_main.c
242
server_stats_compile(worker, stat_info, 0);
usr.sbin/unbound/util/shm_side/shm_main.c
245
if (worker->thread_num == 0) {
usr.sbin/unbound/util/shm_side/shm_main.c
252
shm_stat = worker->daemon->shm_info->ptr_ctl;
usr.sbin/unbound/util/shm_side/shm_main.c
253
shm_stat->time.now_sec = (long long)worker->env.now_tv->tv_sec;
usr.sbin/unbound/util/shm_side/shm_main.c
254
shm_stat->time.now_usec = (long long)worker->env.now_tv->tv_usec;
usr.sbin/unbound/util/shm_side/shm_main.c
257
stat_timeval_subtract(&shm_stat->time.up_sec, &shm_stat->time.up_usec, worker->env.now_tv, &worker->daemon->time_boot);
usr.sbin/unbound/util/shm_side/shm_main.c
258
stat_timeval_subtract(&shm_stat->time.elapsed_sec, &shm_stat->time.elapsed_usec, worker->env.now_tv, &worker->daemon->time_last_stat);
usr.sbin/unbound/util/shm_side/shm_main.c
260
shm_stat->mem.msg = (long long)slabhash_get_mem(worker->env.msg_cache);
usr.sbin/unbound/util/shm_side/shm_main.c
261
shm_stat->mem.rrset = (long long)slabhash_get_mem(&worker->env.rrset_cache->table);
usr.sbin/unbound/util/shm_side/shm_main.c
264
if(worker->daemon->dnscenv) {
usr.sbin/unbound/util/shm_side/shm_main.c
266
worker->daemon->dnscenv->shared_secrets_cache);
usr.sbin/unbound/util/shm_side/shm_main.c
268
worker->daemon->dnscenv->nonces_cache);
usr.sbin/unbound/util/shm_side/shm_main.c
271
shm_stat->mem.val = (long long)mod_get_mem(&worker->env,
usr.sbin/unbound/util/shm_side/shm_main.c
273
shm_stat->mem.iter = (long long)mod_get_mem(&worker->env,
usr.sbin/unbound/util/shm_side/shm_main.c
275
shm_stat->mem.respip = (long long)mod_get_mem(&worker->env,
usr.sbin/unbound/util/shm_side/shm_main.c
283
shm_stat->mem.subnet = (long long)mod_get_mem(&worker->env,
usr.sbin/unbound/util/shm_side/shm_main.c
291
shm_stat->mem.ipsecmod = (long long)mod_get_mem(&worker->env,
usr.sbin/unbound/util/shm_side/shm_main.c
295
shm_stat->mem.dynlib = (long long)mod_get_mem(&worker->env,
usr.sbin/unbound/util/shm_side/shm_main.c
303
stat_total->mesh_time_median /= (double)worker->daemon->num;
usr.sbin/unbound/util/shm_side/shm_main.c
306
(void)worker;
usr.sbin/unbound/util/shm_side/shm_main.h
45
struct worker;
usr.sbin/unbound/util/shm_side/shm_main.h
66
void shm_main_run(struct worker *worker);
usr.sbin/unbound/validator/autotrust.c
1211
env->worker?*(int*)env->worker:0, llvalue);