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

238

struct worker* worker;

sbin/unwind/libunbound/daemon/remote.h

298

struct listen_port* ports, struct worker* worker);

sbin/unwind/libunbound/daemon/remote.h

316

void daemon_remote_exec(struct worker* worker);

sbin/unwind/libunbound/daemon/remote.h

359

void fast_reload_thread_start(RES* ssl, struct worker* worker,

sbin/unwind/libunbound/daemon/remote.h

379

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

147

struct worker* worker_create(struct daemon* daemon, int id);

sbin/unwind/libunbound/daemon/worker.h

158

int worker_init(struct worker* worker, struct config_file *cfg,

sbin/unwind/libunbound/daemon/worker.h

164

void worker_work(struct worker* worker);

sbin/unwind/libunbound/daemon/worker.h

169

void worker_delete(struct worker* worker);

sbin/unwind/libunbound/daemon/worker.h

176

void worker_send_cmd(struct worker* worker, enum worker_commands cmd);

sbin/unwind/libunbound/daemon/worker.h

182

void worker_stats_clear(struct worker* worker);

sbin/unwind/libunbound/libunbound/libunbound.c

173

ctx->env->worker = NULL;

sbin/unwind/libunbound/libunbound/libworker.c

175

w->env->worker = (struct worker*)w;

sbin/unwind/libunbound/libunbound/libworker.c

893

struct libworker* w = (struct libworker*)q->env->worker;

sbin/unwind/libunbound/libunbound/libworker.c

915

struct libworker* lw = (struct libworker*)e->qstate->env->worker;

sbin/unwind/libunbound/services/authzone.c

5454

xfr->task_transfer->worker = NULL;

sbin/unwind/libunbound/services/authzone.c

5644

log_assert(xfr->task_transfer->worker == env->worker);

sbin/unwind/libunbound/services/authzone.c

5688

if(xfr->task_nextprobe->worker == NULL)

sbin/unwind/libunbound/services/authzone.c

6177

if(xfr->task_nextprobe->worker == NULL)

sbin/unwind/libunbound/services/authzone.c

6390

log_assert(xfr->task_transfer->worker == NULL);

sbin/unwind/libunbound/services/authzone.c

6393

xfr->task_transfer->worker = env->worker;

sbin/unwind/libunbound/services/authzone.c

6417

xfr->task_probe->worker = NULL;

sbin/unwind/libunbound/services/authzone.c

6605

if(xfr->task_transfer->worker == NULL) {

sbin/unwind/libunbound/services/authzone.c

6784

if(xfr->task_transfer->worker == NULL) {

sbin/unwind/libunbound/services/authzone.c

6792

if(xfr->task_nextprobe->worker == NULL)

sbin/unwind/libunbound/services/authzone.c

6820

if(xfr->task_nextprobe->worker == NULL)

sbin/unwind/libunbound/services/authzone.c

6832

if(xfr->task_nextprobe->worker == NULL)

sbin/unwind/libunbound/services/authzone.c

6922

xfr->task_nextprobe->worker = NULL;

sbin/unwind/libunbound/services/authzone.c

6965

if(xfr->task_probe->worker == NULL) {

sbin/unwind/libunbound/services/authzone.c

6973

if(xfr->task_transfer->worker == NULL) {

sbin/unwind/libunbound/services/authzone.c

6982

xfr->task_probe->worker = env->worker;

sbin/unwind/libunbound/services/authzone.c

7015

log_assert(xfr->task_nextprobe->worker == NULL ||

sbin/unwind/libunbound/services/authzone.c

7016

xfr->task_nextprobe->worker == env->worker);

sbin/unwind/libunbound/services/authzone.c

7068

xfr->task_nextprobe->worker = env->worker;

sbin/unwind/libunbound/services/authzone.c

7078

if(xfr->task_probe->worker == NULL)

sbin/unwind/libunbound/services/authzone.c

7108

if(x->task_nextprobe && x->task_nextprobe->worker == NULL) {

sbin/unwind/libunbound/services/authzone.c

7139

if(x->task_nextprobe && x->task_nextprobe->worker != NULL) {

sbin/unwind/libunbound/services/authzone.c

7142

if(x->task_probe && x->task_probe->worker != NULL) {

sbin/unwind/libunbound/services/authzone.c

7145

if(x->task_transfer && x->task_transfer->worker != NULL) {

sbin/unwind/libunbound/services/authzone.c

7215

lock_protect(&xfr->lock, &xfr->task_nextprobe->worker,

sbin/unwind/libunbound/services/authzone.c

7216

sizeof(xfr->task_nextprobe->worker));

sbin/unwind/libunbound/services/authzone.c

7217

lock_protect(&xfr->lock, &xfr->task_probe->worker,

sbin/unwind/libunbound/services/authzone.c

7218

sizeof(xfr->task_probe->worker));

sbin/unwind/libunbound/services/authzone.c

7219

lock_protect(&xfr->lock, &xfr->task_transfer->worker,

sbin/unwind/libunbound/services/authzone.c

7220

sizeof(xfr->task_transfer->worker));

sbin/unwind/libunbound/services/authzone.c

8833

void xfr_disown_tasks(struct auth_xfer* xfr, struct worker* worker)

sbin/unwind/libunbound/services/authzone.c

8835

if(xfr->task_nextprobe->worker == worker) {

sbin/unwind/libunbound/services/authzone.c

8838

if(xfr->task_probe->worker == worker) {

sbin/unwind/libunbound/services/authzone.c

8841

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

2361

if(ms->env->worker)

sbin/unwind/libunbound/services/rpz.c

2362

ms->env->worker->stats.rpz_action[action]++;

sbin/unwind/libunbound/services/rpz.c

2423

if(ms->env->worker)

sbin/unwind/libunbound/services/rpz.c

2424

ms->env->worker->stats.rpz_action[action]++;

sbin/unwind/libunbound/services/rpz.c

2584

if(ms->env->worker)

sbin/unwind/libunbound/services/rpz.c

2585

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

492

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

270

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

191

signal_handling_playback(struct worker* wrk)

usr.sbin/unbound/daemon/daemon.c

709

daemon->env->worker = NULL;

usr.sbin/unbound/daemon/daemon.c

725

daemon->env->worker = NULL;

usr.sbin/unbound/daemon/daemon.c

837

daemon->workers = (struct worker**)calloc((size_t)daemon->num,

usr.sbin/unbound/daemon/daemon.c

838

sizeof(struct worker*));

usr.sbin/unbound/daemon/daemon.c

901

set_log_thread_id(struct worker* worker, struct config_file* cfg)

usr.sbin/unbound/daemon/daemon.c

904

log_assert(worker);

usr.sbin/unbound/daemon/daemon.c

906

worker->thread_tid = gettid();

usr.sbin/unbound/daemon/daemon.c

908

log_thread_set(&worker->thread_tid);

usr.sbin/unbound/daemon/daemon.c

911

log_thread_set(&worker->thread_num);

usr.sbin/unbound/daemon/daemon.c

922

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/daemon.c

924

log_assert(worker->thr_id);

usr.sbin/unbound/daemon/daemon.c

925

set_log_thread_id(worker, worker->daemon->cfg);

usr.sbin/unbound/daemon/daemon.c

929

snprintf(name, sizeof(name), "unbound/%u", worker->thread_num);

usr.sbin/unbound/daemon/daemon.c

930

ub_thread_setname(worker->thr_id, name);

usr.sbin/unbound/daemon/daemon.c

935

tube_close_write(worker->cmd);

usr.sbin/unbound/daemon/daemon.c

936

close_other_pipes(worker->daemon, worker->thread_num);

usr.sbin/unbound/daemon/daemon.c

939

if(worker->daemon->cfg->so_reuseport)

usr.sbin/unbound/daemon/daemon.c

940

port_num = worker->thread_num % worker->daemon->num_ports;

usr.sbin/unbound/daemon/daemon.c

944

if(!worker_init(worker, worker->daemon->cfg,

usr.sbin/unbound/daemon/daemon.c

945

worker->daemon->ports[port_num], 0))

usr.sbin/unbound/daemon/daemon.c

948

worker_work(worker);

usr.sbin/unbound/daemon/daemon.h

130

struct worker** workers;

usr.sbin/unbound/daemon/daemon.h

49

struct worker;

usr.sbin/unbound/daemon/remote.c

1000

print_uptime(RES* ssl, struct worker* worker, int reset)

usr.sbin/unbound/daemon/remote.c

1002

struct timeval now = *worker->env.now_tv;

usr.sbin/unbound/daemon/remote.c

1004

timeval_subtract(&up, &now, &worker->daemon->time_boot);

usr.sbin/unbound/daemon/remote.c

1005

timeval_subtract(&dt, &now, &worker->daemon->time_last_stat);

usr.sbin/unbound/daemon/remote.c

1007

worker->daemon->time_last_stat = now;

usr.sbin/unbound/daemon/remote.c

1243

do_stats(RES* ssl, struct worker* worker, int reset)

usr.sbin/unbound/daemon/remote.c

1245

struct daemon* daemon = worker->daemon;

usr.sbin/unbound/daemon/remote.c

1253

server_stats_obtain(worker, daemon->workers[i], &s, reset);

usr.sbin/unbound/daemon/remote.c

1264

if(!print_uptime(ssl, worker, reset))

usr.sbin/unbound/daemon/remote.c

1267

if(!print_mem(ssl, worker, daemon, &total))

usr.sbin/unbound/daemon/remote.c

1382

do_zones_add(struct daemon_remote* rc, RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

1397

if(!perform_zone_add(ssl, worker->daemon->local_zones,

usr.sbin/unbound/daemon/remote.c

1440

do_zones_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

1455

if(!perform_zone_remove(ssl, worker->daemon->local_zones,

usr.sbin/unbound/daemon/remote.c

1513

do_datas_add(struct daemon_remote* rc, RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

1529

if(perform_data_add(ssl, worker->daemon->local_zones,

usr.sbin/unbound/daemon/remote.c

1562

do_datas_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

1577

if(!perform_data_remove(ssl, worker->daemon->local_zones,

usr.sbin/unbound/daemon/remote.c

1590

do_view_zone_add(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

1596

v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);

usr.sbin/unbound/daemon/remote.c

1622

do_view_zone_remove(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

1628

v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);

usr.sbin/unbound/daemon/remote.c

1644

do_view_data_add(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

1650

v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);

usr.sbin/unbound/daemon/remote.c

1676

do_view_datas_add(struct daemon_remote* rc, RES* ssl, struct worker* worker,

usr.sbin/unbound/daemon/remote.c

1683

v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);

usr.sbin/unbound/daemon/remote.c

1726

do_view_data_remove(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

1732

v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);

usr.sbin/unbound/daemon/remote.c

1748

do_view_datas_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker,

usr.sbin/unbound/daemon/remote.c

1755

v = views_find_view(worker->env.views, arg, 1 /* get write lock*/);

usr.sbin/unbound/daemon/remote.c

1794

struct worker* worker;

usr.sbin/unbound/daemon/remote.c

1840

*inf->worker->env.now)) {

usr.sbin/unbound/daemon/remote.c

1846

s, cl, tp, (long long)(ttl-*inf->worker->env.now))) {

usr.sbin/unbound/daemon/remote.c

1854

(long long)(d->ttl-*inf->worker->env.now),

usr.sbin/unbound/daemon/remote.c

1867

*inf->worker->env.now, s, sizeof(s))) {

usr.sbin/unbound/daemon/remote.c

1944

addrtree_traverse(d->tree4, 0, *inf->worker->env.now, &k->key,

usr.sbin/unbound/daemon/remote.c

1948

addrtree_traverse(d->tree6, 1, *inf->worker->env.now, &k->key,

usr.sbin/unbound/daemon/remote.c

1960

if(*inf->worker->env.now < d->ttl &&

usr.sbin/unbound/daemon/remote.c

1966

if(!packed_rr_to_string(k, i, *inf->worker->env.now,

usr.sbin/unbound/daemon/remote.c

1983

if(*inf->worker->env.now < d->ttl &&

usr.sbin/unbound/daemon/remote.c

2003

*inf->worker->env.now)) {

usr.sbin/unbound/daemon/remote.c

2011

(long long)(d->ttl-*inf->worker->env.now),

usr.sbin/unbound/daemon/remote.c

2024

*inf->worker->env.now, s, sizeof(s))) {

usr.sbin/unbound/daemon/remote.c

2039

do_cache_lookup_domain(RES* ssl, struct worker* worker, uint8_t* nm,

usr.sbin/unbound/daemon/remote.c

2048

inf.worker = worker;

usr.sbin/unbound/daemon/remote.c

2053

m = modstack_find(worker->env.modstack, "subnetcache");

usr.sbin/unbound/daemon/remote.c

2054

if(m != -1) sn_env = (struct subnet_env*)worker->env.modinfo[m];

usr.sbin/unbound/daemon/remote.c

2063

slabhash_traverse(&worker->env.rrset_cache->table, 0,

usr.sbin/unbound/daemon/remote.c

2065

slabhash_traverse(worker->env.msg_cache, 0, &cache_lookup_msg, &inf);

usr.sbin/unbound/daemon/remote.c

2070

do_cache_lookup(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2111

do_cache_lookup_domain(ssl, worker, nm, nmlen);

usr.sbin/unbound/daemon/remote.c

2119

do_lookup(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2126

(void)print_deleg_lookup(ssl, worker, nm, nmlen, nmlabs);

usr.sbin/unbound/daemon/remote.c

2132

do_cache_remove(struct worker* worker, uint8_t* nm, size_t nmlen,

usr.sbin/unbound/daemon/remote.c

2137

rrset_cache_remove(worker->env.rrset_cache, nm, nmlen, t, c, 0);

usr.sbin/unbound/daemon/remote.c

2139

rrset_cache_remove(worker->env.rrset_cache, nm, nmlen, t, c,

usr.sbin/unbound/daemon/remote.c

2147

slabhash_remove(worker->env.msg_cache, h, &k);

usr.sbin/unbound/daemon/remote.c

2151

slabhash_remove(worker->env.msg_cache, h, &k);

usr.sbin/unbound/daemon/remote.c

2154

if(remcachedb && worker->env.cachedb_enabled)

usr.sbin/unbound/daemon/remote.c

2155

cachedb_msg_remove_qinfo(&worker->env, &k);

usr.sbin/unbound/daemon/remote.c

2180

do_flush_type(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2200

do_cache_remove(worker, nm, nmlen, t, LDNS_RR_CLASS_IN, pc);

usr.sbin/unbound/daemon/remote.c

2208

do_flush_stats(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

2210

worker_stats_clear(worker);

usr.sbin/unbound/daemon/remote.c

2219

struct worker* worker;

usr.sbin/unbound/daemon/remote.c

2265

do_flush_infra(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2271

slabhash_clear(worker->env.infra_cache->hosts);

usr.sbin/unbound/daemon/remote.c

2281

inf.worker = worker;

usr.sbin/unbound/daemon/remote.c

2285

inf.expired = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

2293

slabhash_traverse(worker->env.infra_cache->hosts, 1, &infra_del_host,

usr.sbin/unbound/daemon/remote.c

2300

do_flush_requestlist(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

2302

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/remote.c

2339

if(inf->remcachedb && inf->worker->env.cachedb_enabled)

usr.sbin/unbound/daemon/remote.c

2340

cachedb_msg_remove_qinfo(&inf->worker->env, &k->key);

usr.sbin/unbound/daemon/remote.c

2363

do_flush_zone(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2376

inf.worker = worker;

usr.sbin/unbound/daemon/remote.c

2380

inf.expired = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

2386

slabhash_traverse(&worker->env.rrset_cache->table, 1,

usr.sbin/unbound/daemon/remote.c

2389

slabhash_traverse(worker->env.msg_cache, 1, &zone_del_msg, &inf);

usr.sbin/unbound/daemon/remote.c

2392

if(worker->env.key_cache) {

usr.sbin/unbound/daemon/remote.c

2393

slabhash_traverse(worker->env.key_cache->slab, 1,

usr.sbin/unbound/daemon/remote.c

2430

if(inf->remcachedb && inf->worker->env.cachedb_enabled)

usr.sbin/unbound/daemon/remote.c

2431

cachedb_msg_remove_qinfo(&inf->worker->env,

usr.sbin/unbound/daemon/remote.c

2452

do_flush_bogus(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2459

inf.worker = worker;

usr.sbin/unbound/daemon/remote.c

2460

inf.expired = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

2466

slabhash_traverse(&worker->env.rrset_cache->table, 1,

usr.sbin/unbound/daemon/remote.c

2469

slabhash_traverse(worker->env.msg_cache, 1, &bogus_del_msg, &inf);

usr.sbin/unbound/daemon/remote.c

2472

if(worker->env.key_cache) {

usr.sbin/unbound/daemon/remote.c

2473

slabhash_traverse(worker->env.key_cache->slab, 1,

usr.sbin/unbound/daemon/remote.c

250

rc->worker = NULL;

usr.sbin/unbound/daemon/remote.c

2516

if(inf->remcachedb && inf->worker->env.cachedb_enabled)

usr.sbin/unbound/daemon/remote.c

2517

cachedb_msg_remove_qinfo(&inf->worker->env,

usr.sbin/unbound/daemon/remote.c

2540

do_flush_negative(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2547

inf.worker = worker;

usr.sbin/unbound/daemon/remote.c

2548

inf.expired = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

2554

slabhash_traverse(&worker->env.rrset_cache->table, 1,

usr.sbin/unbound/daemon/remote.c

2557

slabhash_traverse(worker->env.msg_cache, 1, &negative_del_msg, &inf);

usr.sbin/unbound/daemon/remote.c

2560

if(worker->env.key_cache) {

usr.sbin/unbound/daemon/remote.c

2561

slabhash_traverse(worker->env.key_cache->slab, 1,

usr.sbin/unbound/daemon/remote.c

2572

do_flush_name(RES* ssl, struct worker* w, char* arg)

usr.sbin/unbound/daemon/remote.c

2718

do_forward(RES* ssl, struct worker* worker, char* args)

usr.sbin/unbound/daemon/remote.c

2720

struct iter_forwards* fwd = worker->env.fwds;

usr.sbin/unbound/daemon/remote.c

2734

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/remote.c

2797

do_forward_add(RES* ssl, struct worker* worker, char* args)

usr.sbin/unbound/daemon/remote.c

2799

struct iter_forwards* fwd = worker->env.fwds;

usr.sbin/unbound/daemon/remote.c

2810

if(insecure && worker->env.anchors) {

usr.sbin/unbound/daemon/remote.c

2811

if(!anchors_add_insecure(worker->env.anchors, LDNS_RR_CLASS_IN,

usr.sbin/unbound/daemon/remote.c

2833

do_forward_remove(RES* ssl, struct worker* worker, char* args)

usr.sbin/unbound/daemon/remote.c

2835

struct iter_forwards* fwd = worker->env.fwds;

usr.sbin/unbound/daemon/remote.c

2843

if(insecure && worker->env.anchors)

usr.sbin/unbound/daemon/remote.c

2844

anchors_delete_insecure(worker->env.anchors, LDNS_RR_CLASS_IN,

usr.sbin/unbound/daemon/remote.c

2854

do_stub_add(RES* ssl, struct worker* worker, char* args)

usr.sbin/unbound/daemon/remote.c

2856

struct iter_forwards* fwd = worker->env.fwds;

usr.sbin/unbound/daemon/remote.c

2867

lock_rw_wrlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

2868

if(insecure && worker->env.anchors) {

usr.sbin/unbound/daemon/remote.c

2869

if(!anchors_add_insecure(worker->env.anchors, LDNS_RR_CLASS_IN,

usr.sbin/unbound/daemon/remote.c

2872

lock_rw_unlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

2880

if(insecure && worker->env.anchors)

usr.sbin/unbound/daemon/remote.c

2881

anchors_delete_insecure(worker->env.anchors,

usr.sbin/unbound/daemon/remote.c

2884

lock_rw_unlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

2890

if(!hints_add_stub(worker->env.hints, LDNS_RR_CLASS_IN, dp, !prime,

usr.sbin/unbound/daemon/remote.c

2894

if(insecure && worker->env.anchors)

usr.sbin/unbound/daemon/remote.c

2895

anchors_delete_insecure(worker->env.anchors,

usr.sbin/unbound/daemon/remote.c

2898

lock_rw_unlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

2903

lock_rw_unlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

2910

do_stub_remove(RES* ssl, struct worker* worker, char* args)

usr.sbin/unbound/daemon/remote.c

2912

struct iter_forwards* fwd = worker->env.fwds;

usr.sbin/unbound/daemon/remote.c

2920

lock_rw_wrlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

2921

if(insecure && worker->env.anchors)

usr.sbin/unbound/daemon/remote.c

2922

anchors_delete_insecure(worker->env.anchors, LDNS_RR_CLASS_IN,

usr.sbin/unbound/daemon/remote.c

2925

hints_delete_stub(worker->env.hints, LDNS_RR_CLASS_IN, nm, nolock);

usr.sbin/unbound/daemon/remote.c

2927

lock_rw_unlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

2934

do_insecure_add(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2941

if(worker->env.anchors) {

usr.sbin/unbound/daemon/remote.c

2942

if(!anchors_add_insecure(worker->env.anchors,

usr.sbin/unbound/daemon/remote.c

2955

do_insecure_remove(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

2962

if(worker->env.anchors)

usr.sbin/unbound/daemon/remote.c

2963

anchors_delete_insecure(worker->env.anchors,

usr.sbin/unbound/daemon/remote.c

2970

do_insecure_list(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

2974

if(worker->env.anchors) {

usr.sbin/unbound/daemon/remote.c

2975

RBTREE_FOR(a, struct trust_anchor*, worker->env.anchors->tree) {

usr.sbin/unbound/daemon/remote.c

2986

do_status(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

2994

if(!ssl_printf(ssl, "threads: %d\n", worker->daemon->num))

usr.sbin/unbound/daemon/remote.c

2996

if(!ssl_printf(ssl, "modules: %d [", worker->daemon->mods.num))

usr.sbin/unbound/daemon/remote.c

2998

for(i=0; i<worker->daemon->mods.num; i++) {

usr.sbin/unbound/daemon/remote.c

2999

if(!ssl_printf(ssl, " %s", worker->daemon->mods.mod[i]->name))

usr.sbin/unbound/daemon/remote.c

3004

uptime = (time_t)time(NULL) - (time_t)worker->daemon->time_boot.tv_sec;

usr.sbin/unbound/daemon/remote.c

3008

(worker->daemon->reuseport?" reuseport":""),

usr.sbin/unbound/daemon/remote.c

3009

(worker->daemon->rc->accept_list?" control":""),

usr.sbin/unbound/daemon/remote.c

3010

(worker->daemon->rc->accept_list && worker->daemon->rc->use_cert?"(ssl)":""),

usr.sbin/unbound/daemon/remote.c

3011

(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

3094

do_dump_requestlist(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

3102

if(!ssl_printf(ssl, "thread #%d\n", worker->thread_num))

usr.sbin/unbound/daemon/remote.c

3107

mesh = worker->env.mesh;

usr.sbin/unbound/daemon/remote.c

3113

get_mesh_age(m, timebuf, sizeof(timebuf), &worker->env);

usr.sbin/unbound/daemon/remote.c

3188

do_dump_infra(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

3191

arg.infra = worker->env.infra_cache;

usr.sbin/unbound/daemon/remote.c

3193

arg.now = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

3200

do_log_reopen(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

3202

struct config_file* cfg = worker->env.cfg;

usr.sbin/unbound/daemon/remote.c

3209

do_auth_zone_reload(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3214

struct auth_zones* az = worker->env.auth_zones;

usr.sbin/unbound/daemon/remote.c

3240

if(!auth_zone_read_zonefile(z, worker->env.cfg)) {

usr.sbin/unbound/daemon/remote.c

3265

xfr->lease_time = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

3266

xfr->soa_zone_acquired = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

3270

z->soa_zone_acquired = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

3272

auth_zone_verify_zonemd(z, &worker->env, &worker->env.mesh->mods,

usr.sbin/unbound/daemon/remote.c

3291

do_auth_zone_transfer(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3296

struct auth_zones* az = worker->env.auth_zones;

usr.sbin/unbound/daemon/remote.c

3299

if(!az || !auth_zones_startprobesequence(az, &worker->env, nm, nmlen,

usr.sbin/unbound/daemon/remote.c

3311

do_set_option(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3316

if(!config_set_option(worker->env.cfg, arg, arg2)) {

usr.sbin/unbound/daemon/remote.c

3322

int m = modstack_find(&worker->env.mesh->mods, "validator");

usr.sbin/unbound/daemon/remote.c

3324

if(m != -1) val_env = (struct val_env*)worker->env.modinfo[m];

usr.sbin/unbound/daemon/remote.c

3326

val_env->date_override = worker->env.cfg->val_date_override;

usr.sbin/unbound/daemon/remote.c

3340

do_get_option(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3343

r = config_get_option(worker->env.cfg, arg, remote_get_opt_ssl, ssl);

usr.sbin/unbound/daemon/remote.c

3352

do_list_forwards(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

3355

struct iter_forwards* fwds = worker->env.fwds;

usr.sbin/unbound/daemon/remote.c

3365

if(worker->env.anchors &&

usr.sbin/unbound/daemon/remote.c

3366

(a=anchor_find(worker->env.anchors, z->name,

usr.sbin/unbound/daemon/remote.c

3384

do_list_stubs(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

3390

lock_rw_rdlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

3391

RBTREE_FOR(z, struct iter_hints_stub*, &worker->env.hints->tree) {

usr.sbin/unbound/daemon/remote.c

3395

if(worker->env.anchors &&

usr.sbin/unbound/daemon/remote.c

3396

(a=anchor_find(worker->env.anchors, z->node.name,

usr.sbin/unbound/daemon/remote.c

3407

lock_rw_unlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

3411

lock_rw_unlock(&worker->env.hints->lock);

usr.sbin/unbound/daemon/remote.c

3491

do_list_local_data(RES* ssl, struct worker* worker, struct local_zones* zones)

usr.sbin/unbound/daemon/remote.c

3496

char* s = (char*)sldns_buffer_begin(worker->env.scratch_buffer);

usr.sbin/unbound/daemon/remote.c

3497

size_t slen = sldns_buffer_capacity(worker->env.scratch_buffer);

usr.sbin/unbound/daemon/remote.c

3530

do_view_list_local_zones(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3532

struct view* v = views_find_view(worker->env.views,

usr.sbin/unbound/daemon/remote.c

3546

do_view_list_local_data(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3548

struct view* v = views_find_view(worker->env.views,

usr.sbin/unbound/daemon/remote.c

3555

do_list_local_data(ssl, worker, v->local_zones);

usr.sbin/unbound/daemon/remote.c

3614

do_ratelimit_list(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3618

a.infra = worker->env.infra_cache;

usr.sbin/unbound/daemon/remote.c

3619

a.now = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

3621

a.backoff = worker->env.cfg->ratelimit_backoff;

usr.sbin/unbound/daemon/remote.c

3633

do_ip_ratelimit_list(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3637

a.infra = worker->env.infra_cache;

usr.sbin/unbound/daemon/remote.c

3638

a.now = *worker->env.now;

usr.sbin/unbound/daemon/remote.c

3640

a.backoff = worker->env.cfg->ip_ratelimit_backoff;

usr.sbin/unbound/daemon/remote.c

3652

do_rpz_enable_disable(RES* ssl, struct worker* worker, char* arg, int enable) {

usr.sbin/unbound/daemon/remote.c

3656

struct auth_zones *az = worker->env.auth_zones;

usr.sbin/unbound/daemon/remote.c

3689

do_rpz_enable(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3691

do_rpz_enable_disable(ssl, worker, arg, 1);

usr.sbin/unbound/daemon/remote.c

3696

do_rpz_disable(RES* ssl, struct worker* worker, char* arg)

usr.sbin/unbound/daemon/remote.c

3698

do_rpz_enable_disable(ssl, worker, arg, 0);

usr.sbin/unbound/daemon/remote.c

3704

cookie_secret_file_dump(RES* ssl, struct worker* worker) {

usr.sbin/unbound/daemon/remote.c

3705

char const* secret_file = worker->env.cfg->cookie_secret_file;

usr.sbin/unbound/daemon/remote.c

3706

struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;

usr.sbin/unbound/daemon/remote.c

3746

do_activate_cookie_secret(RES* ssl, struct worker* worker) {

usr.sbin/unbound/daemon/remote.c

3747

char const* secret_file = worker->env.cfg->cookie_secret_file;

usr.sbin/unbound/daemon/remote.c

3748

struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;

usr.sbin/unbound/daemon/remote.c

3766

if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) {

usr.sbin/unbound/daemon/remote.c

3773

if(worker->thread_num == 0)

usr.sbin/unbound/daemon/remote.c

3774

(void)cookie_secret_file_dump(ssl, worker);

usr.sbin/unbound/daemon/remote.c

3781

do_drop_cookie_secret(RES* ssl, struct worker* worker) {

usr.sbin/unbound/daemon/remote.c

3782

char const* secret_file = worker->env.cfg->cookie_secret_file;

usr.sbin/unbound/daemon/remote.c

3783

struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;

usr.sbin/unbound/daemon/remote.c

3801

if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) {

usr.sbin/unbound/daemon/remote.c

3808

if(worker->thread_num == 0)

usr.sbin/unbound/daemon/remote.c

3809

(void)cookie_secret_file_dump(ssl, worker);

usr.sbin/unbound/daemon/remote.c

3816

do_add_cookie_secret(RES* ssl, struct worker* worker, char* arg) {

usr.sbin/unbound/daemon/remote.c

3818

char const* secret_file = worker->env.cfg->cookie_secret_file;

usr.sbin/unbound/daemon/remote.c

3819

struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;

usr.sbin/unbound/daemon/remote.c

3826

worker->daemon->cookie_secrets = cookie_secrets_create();

usr.sbin/unbound/daemon/remote.c

3827

if(!worker->daemon->cookie_secrets) {

usr.sbin/unbound/daemon/remote.c

3831

cookie_secrets = worker->daemon->cookie_secrets;

usr.sbin/unbound/daemon/remote.c

3857

if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) {

usr.sbin/unbound/daemon/remote.c

3867

if(worker->thread_num == 0)

usr.sbin/unbound/daemon/remote.c

3868

(void)cookie_secret_file_dump(ssl, worker);

usr.sbin/unbound/daemon/remote.c

3876

do_print_cookie_secrets(RES* ssl, struct worker* worker) {

usr.sbin/unbound/daemon/remote.c

3877

struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets;

usr.sbin/unbound/daemon/remote.c

3939

struct worker* worker)

usr.sbin/unbound/daemon/remote.c

3946

do_stop(ssl, worker);

usr.sbin/unbound/daemon/remote.c

3951

do_reload(ssl, worker, 1);

usr.sbin/unbound/daemon/remote.c

3956

do_reload(ssl, worker, 0);

usr.sbin/unbound/daemon/remote.c

3959

do_fast_reload(ssl, worker, s, skipwhite(p+11));

usr.sbin/unbound/daemon/remote.c

3964

do_stats(ssl, worker, 0);

usr.sbin/unbound/daemon/remote.c

3969

do_stats(ssl, worker, 1);

usr.sbin/unbound/daemon/remote.c

3974

do_status(ssl, worker);

usr.sbin/unbound/daemon/remote.c

3980

if(worker->daemon->num > 1) {

usr.sbin/unbound/daemon/remote.c

3986

(void)dump_cache(ssl, worker);

usr.sbin/unbound/daemon/remote.c

3992

if(worker->daemon->num > 1) {

usr.sbin/unbound/daemon/remote.c

3998

if(load_cache(ssl, worker)) send_ok(ssl);

usr.sbin/unbound/daemon/remote.c

4003

do_list_forwards(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4008

do_list_stubs(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4013

do_insecure_list(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4018

do_list_local_zones(ssl, worker->daemon->local_zones);

usr.sbin/unbound/daemon/remote.c

4023

do_list_local_data(ssl, worker, worker->daemon->local_zones);

usr.sbin/unbound/daemon/remote.c

4026

do_view_list_local_zones(ssl, worker, skipwhite(p+21));

usr.sbin/unbound/daemon/remote.c

4029

do_view_list_local_data(ssl, worker, skipwhite(p+20));

usr.sbin/unbound/daemon/remote.c

4032

do_ratelimit_list(ssl, worker, p+14);

usr.sbin/unbound/daemon/remote.c

4035

do_ip_ratelimit_list(ssl, worker, p+17);

usr.sbin/unbound/daemon/remote.c

4040

do_list_auth_zones(ssl, worker->env.auth_zones);

usr.sbin/unbound/daemon/remote.c

4043

do_auth_zone_reload(ssl, worker, skipwhite(p+16));

usr.sbin/unbound/daemon/remote.c

4046

do_auth_zone_transfer(ssl, worker, skipwhite(p+18));

usr.sbin/unbound/daemon/remote.c

4051

do_insecure_add(ssl, worker, skipwhite(p+12));

usr.sbin/unbound/daemon/remote.c

4056

do_insecure_remove(ssl, worker, skipwhite(p+15));

usr.sbin/unbound/daemon/remote.c

4063

do_flush_stats(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4070

do_flush_requestlist(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4073

do_cache_lookup(ssl, worker, skipwhite(p+12));

usr.sbin/unbound/daemon/remote.c

4076

do_lookup(ssl, worker, skipwhite(p+6));

usr.sbin/unbound/daemon/remote.c

4084

do_zones_remove(rc, ssl, worker);

usr.sbin/unbound/daemon/remote.c

4089

do_zones_add(rc, ssl, worker);

usr.sbin/unbound/daemon/remote.c

4094

do_datas_remove(rc, ssl, worker);

usr.sbin/unbound/daemon/remote.c

4099

do_datas_add(rc, ssl, worker);

usr.sbin/unbound/daemon/remote.c

4102

do_view_datas_remove(rc, ssl, worker, skipwhite(p+23));

usr.sbin/unbound/daemon/remote.c

4105

do_view_datas_add(rc, ssl, worker, skipwhite(p+16));

usr.sbin/unbound/daemon/remote.c

4110

do_print_cookie_secrets(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4125

do_zone_remove(ssl, worker->daemon->local_zones, skipwhite(p+17));

usr.sbin/unbound/daemon/remote.c

4127

do_zone_add(ssl, worker->daemon->local_zones, skipwhite(p+10));

usr.sbin/unbound/daemon/remote.c

4129

do_data_remove(ssl, worker->daemon->local_zones, skipwhite(p+17));

usr.sbin/unbound/daemon/remote.c

4131

do_data_add(ssl, worker->daemon->local_zones, skipwhite(p+10));

usr.sbin/unbound/daemon/remote.c

4133

do_forward_add(ssl, worker, skipwhite(p+11));

usr.sbin/unbound/daemon/remote.c

4135

do_forward_remove(ssl, worker, skipwhite(p+14));

usr.sbin/unbound/daemon/remote.c

4137

do_forward(ssl, worker, skipwhite(p+7));

usr.sbin/unbound/daemon/remote.c

4139

do_stub_add(ssl, worker, skipwhite(p+8));

usr.sbin/unbound/daemon/remote.c

4141

do_stub_remove(ssl, worker, skipwhite(p+11));

usr.sbin/unbound/daemon/remote.c

4143

do_view_zone_remove(ssl, worker, skipwhite(p+22));

usr.sbin/unbound/daemon/remote.c

4145

do_view_zone_add(ssl, worker, skipwhite(p+15));

usr.sbin/unbound/daemon/remote.c

4147

do_view_data_remove(ssl, worker, skipwhite(p+22));

usr.sbin/unbound/daemon/remote.c

4149

do_view_data_add(ssl, worker, skipwhite(p+15));

usr.sbin/unbound/daemon/remote.c

4151

do_flush_zone(ssl, worker, skipwhite(p+10));

usr.sbin/unbound/daemon/remote.c

4153

do_flush_type(ssl, worker, skipwhite(p+10));

usr.sbin/unbound/daemon/remote.c

4155

do_flush_infra(ssl, worker, skipwhite(p+11));

usr.sbin/unbound/daemon/remote.c

4157

do_flush_name(ssl, worker, skipwhite(p+5));

usr.sbin/unbound/daemon/remote.c

4161

do_dump_requestlist(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4165

do_dump_infra(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4169

do_log_reopen(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4171

do_set_option(ssl, worker, skipwhite(p+10));

usr.sbin/unbound/daemon/remote.c

4173

do_get_option(ssl, worker, skipwhite(p+10));

usr.sbin/unbound/daemon/remote.c

4175

do_flush_bogus(ssl, worker, skipwhite(p+11));

usr.sbin/unbound/daemon/remote.c

4177

do_flush_negative(ssl, worker, skipwhite(p+14));

usr.sbin/unbound/daemon/remote.c

4179

do_rpz_enable(ssl, worker, skipwhite(p+10));

usr.sbin/unbound/daemon/remote.c

4181

do_rpz_disable(ssl, worker, skipwhite(p+11));

usr.sbin/unbound/daemon/remote.c

4183

do_add_cookie_secret(ssl, worker, skipwhite(p+17));

usr.sbin/unbound/daemon/remote.c

4187

do_drop_cookie_secret(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4191

do_activate_cookie_secret(ssl, worker);

usr.sbin/unbound/daemon/remote.c

4198

daemon_remote_exec(struct worker* worker)

usr.sbin/unbound/daemon/remote.c

4203

if(!tube_read_msg(worker->cmd, &msg, &len, 0)) {

usr.sbin/unbound/daemon/remote.c

4208

execute_cmd(NULL, NULL, NULL, (char*)msg, worker);

usr.sbin/unbound/daemon/remote.c

4272

execute_cmd(rc, s, res, buf, rc->worker);

usr.sbin/unbound/daemon/remote.c

429

n->com = comm_point_create_raw(rc->worker->base, fd, 0,

usr.sbin/unbound/daemon/remote.c

439

struct listen_port* ports, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

442

rc->worker = worker;

usr.sbin/unbound/daemon/remote.c

4763

if(!config_read(*newcfg, fr->worker->daemon->cfgfile,

usr.sbin/unbound/daemon/remote.c

4764

fr->worker->daemon->chroot)) {

usr.sbin/unbound/daemon/remote.c

4767

(fr->worker->daemon->chroot?"<chroot:":""),

usr.sbin/unbound/daemon/remote.c

4768

(fr->worker->daemon->chroot?fr->worker->daemon->chroot:""),

usr.sbin/unbound/daemon/remote.c

4769

(fr->worker->daemon->chroot?"> ":""),

usr.sbin/unbound/daemon/remote.c

4770

fr->worker->daemon->cfgfile, strerror(errno)))

usr.sbin/unbound/daemon/remote.c

4779

(fr->worker->daemon->chroot?"<chroot:":""),

usr.sbin/unbound/daemon/remote.c

4780

(fr->worker->daemon->chroot?fr->worker->daemon->chroot:""),

usr.sbin/unbound/daemon/remote.c

4781

(fr->worker->daemon->chroot?"> ":""),

usr.sbin/unbound/daemon/remote.c

4782

fr->worker->daemon->cfgfile))

usr.sbin/unbound/daemon/remote.c

4830

if(!taglist_equal(fr->worker->daemon->cfg->tagname,

usr.sbin/unbound/daemon/remote.c

4831

fr->worker->daemon->cfg->num_tags, newcfg->tagname,

usr.sbin/unbound/daemon/remote.c

4833

!taglist_change_at_end(fr->worker->daemon->cfg->tagname,

usr.sbin/unbound/daemon/remote.c

4834

fr->worker->daemon->cfg->num_tags, newcfg->tagname,

usr.sbin/unbound/daemon/remote.c

4840

fr->worker->daemon->fast_reload_drop_mesh = fr->fr_drop_mesh;

usr.sbin/unbound/daemon/remote.c

4950

struct config_file* cfg = fr->worker->env.cfg;

usr.sbin/unbound/daemon/remote.c

500

n->c = comm_point_create_raw(rc->worker->base, newfd, 0,

usr.sbin/unbound/daemon/remote.c

5020

struct config_file* cfg = fr->worker->env.cfg;

usr.sbin/unbound/daemon/remote.c

5505

struct module_env* env = &fr->worker->env;

usr.sbin/unbound/daemon/remote.c

5607

struct daemon* daemon = fr->worker->daemon;

usr.sbin/unbound/daemon/remote.c

5700

if(!ct_create_sslctxs(ct, newcfg, fr->worker->daemon)) {

usr.sbin/unbound/daemon/remote.c

5732

fr->worker->daemon)) {

usr.sbin/unbound/daemon/remote.c

5751

if(fr->worker->daemon->tcl->tree.count != 0)

usr.sbin/unbound/daemon/remote.c

5752

fr->worker->daemon->fast_reload_tcl_has_changes = 1;

usr.sbin/unbound/daemon/remote.c

5753

else fr->worker->daemon->fast_reload_tcl_has_changes = 0;

usr.sbin/unbound/daemon/remote.c

5762

fr->worker->daemon->env, &fr->worker->daemon->mods)) {

usr.sbin/unbound/daemon/remote.c

5836

if(fr->worker->env.anchors) {

usr.sbin/unbound/daemon/remote.c

6555

struct daemon* daemon = fr->worker->daemon;

usr.sbin/unbound/daemon/remote.c

705

for(i=1; i<rc->worker->daemon->num; i++) {

usr.sbin/unbound/daemon/remote.c

706

worker_send_cmd(rc->worker->daemon->workers[i],

usr.sbin/unbound/daemon/remote.c

708

if(!tube_write_msg(rc->worker->daemon->workers[i]->cmd,

usr.sbin/unbound/daemon/remote.c

718

do_stop(RES* ssl, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

720

worker->need_to_exit = 1;

usr.sbin/unbound/daemon/remote.c

7209

fast_reload_thread_setup(struct worker* worker, int fr_verb, int fr_nopause,

usr.sbin/unbound/daemon/remote.c

721

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/remote.c

7213

int numworkers = worker->daemon->num;

usr.sbin/unbound/daemon/remote.c

7214

worker->daemon->fast_reload_thread = (struct fast_reload_thread*)

usr.sbin/unbound/daemon/remote.c

7215

calloc(1, sizeof(*worker->daemon->fast_reload_thread));

usr.sbin/unbound/daemon/remote.c

7216

if(!worker->daemon->fast_reload_thread)

usr.sbin/unbound/daemon/remote.c

7218

fr = worker->daemon->fast_reload_thread;

usr.sbin/unbound/daemon/remote.c

7222

worker->daemon->fast_reload_drop_mesh = fr->fr_drop_mesh;

usr.sbin/unbound/daemon/remote.c

7230

if(!create_socketpair(fr->commpair, worker->daemon->rand)) {

usr.sbin/unbound/daemon/remote.c

7232

worker->daemon->fast_reload_thread = NULL;

usr.sbin/unbound/daemon/remote.c

7235

fr->worker = worker;

usr.sbin/unbound/daemon/remote.c

7242

worker->daemon->fast_reload_thread = NULL;

usr.sbin/unbound/daemon/remote.c

7245

if(!create_socketpair(fr->commreload, worker->daemon->rand)) {

usr.sbin/unbound/daemon/remote.c

7250

worker->daemon->fast_reload_thread = NULL;

usr.sbin/unbound/daemon/remote.c

7257

fr->thread_tid_log = worker->env.cfg->log_thread_id;

usr.sbin/unbound/daemon/remote.c

727

do_reload(RES* ssl, struct worker* worker, int reuse_cache)

usr.sbin/unbound/daemon/remote.c

729

worker->reuse_cache = reuse_cache;

usr.sbin/unbound/daemon/remote.c

730

worker->need_to_exit = 0;

usr.sbin/unbound/daemon/remote.c

7306

fast_reload_thread->worker->daemon);

usr.sbin/unbound/daemon/remote.c

731

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/remote.c

7385

struct worker* worker = fr->worker;

usr.sbin/unbound/daemon/remote.c

7390

worker->daemon->fast_reload_thread = NULL;

usr.sbin/unbound/daemon/remote.c

7444

struct daemon* daemon = fr->worker->daemon;

usr.sbin/unbound/daemon/remote.c

7531

fr_worker_pickup_mesh(struct worker* worker)

usr.sbin/unbound/daemon/remote.c

7533

struct mesh_area* mesh = worker->env.mesh;

usr.sbin/unbound/daemon/remote.c

7534

struct config_file* cfg = worker->env.cfg;

usr.sbin/unbound/daemon/remote.c

7535

mesh->use_response_ip = worker->daemon->use_response_ip;

usr.sbin/unbound/daemon/remote.c

7536

mesh->use_rpz = worker->daemon->use_rpz;

usr.sbin/unbound/daemon/remote.c

7595

fr_pickup_auth_locks(struct worker* worker, struct auth_zone* namez,

usr.sbin/unbound/daemon/remote.c

7610

lock_rw_wrlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7611

lock_rw_wrlock(&worker->env.auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7619

*loadxfr = auth_xfer_find(worker->daemon->fast_reload_thread->

usr.sbin/unbound/daemon/remote.c

7622

*xfr = auth_xfer_find(worker->env.auth_zones, nm, nmlen,

usr.sbin/unbound/daemon/remote.c

7634

fr_worker_auth_del(struct worker* worker, struct fast_reload_auth_change* item,

usr.sbin/unbound/daemon/remote.c

7642

item->old_z->zonemd_callback_env->worker == worker){

usr.sbin/unbound/daemon/remote.c

7645

auth_zone_zonemd_stop_lookup(item->old_z, worker->env.mesh);

usr.sbin/unbound/daemon/remote.c

7650

fr_pickup_auth_locks(worker, item->old_z, item->old_z, NULL, &xfr,

usr.sbin/unbound/daemon/remote.c

7652

lock_rw_unlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7653

lock_rw_unlock(&worker->env.auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7657

if(xfr->task_nextprobe->worker == worker ||

usr.sbin/unbound/daemon/remote.c

7658

xfr->task_probe->worker == worker ||

usr.sbin/unbound/daemon/remote.c

7659

xfr->task_transfer->worker == worker) {

usr.sbin/unbound/daemon/remote.c

7661

xfr_disown_tasks(xfr, worker);

usr.sbin/unbound/daemon/remote.c

7666

if(!for_change && (released || worker->thread_num == 0)) {

usr.sbin/unbound/daemon/remote.c

7669

fr_pickup_auth_locks(worker, item->old_z, item->old_z, NULL,

usr.sbin/unbound/daemon/remote.c

7671

lock_rw_unlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7673

if(xfr && xfr->task_nextprobe->worker == NULL &&

usr.sbin/unbound/daemon/remote.c

7674

xfr->task_probe->worker == NULL &&

usr.sbin/unbound/daemon/remote.c

7675

xfr->task_transfer->worker == NULL) {

usr.sbin/unbound/daemon/remote.c

7676

(void)rbtree_delete(&worker->env.auth_zones->xtree,

usr.sbin/unbound/daemon/remote.c

7678

lock_rw_unlock(&worker->env.auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7682

lock_rw_unlock(&worker->env.auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7711

fr_worker_auth_add(struct worker* worker, struct fast_reload_auth_change* item,

usr.sbin/unbound/daemon/remote.c

7717

fr_pickup_auth_locks(worker, item->new_z, NULL, item->new_z, &xfr,

usr.sbin/unbound/daemon/remote.c

7722

xfr = auth_xfer_create(worker->env.auth_zones, item->new_z);

usr.sbin/unbound/daemon/remote.c

773

do_fast_reload(RES* ssl, struct worker* worker, struct rc_state* s, char* arg)

usr.sbin/unbound/daemon/remote.c

7733

auth_zone_pickup_initial_zone(item->new_z, &worker->env);

usr.sbin/unbound/daemon/remote.c

7735

lock_rw_unlock(&worker->env.auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7736

lock_rw_unlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7741

auth_xfer_pickup_initial_zone(xfr, &worker->env);

usr.sbin/unbound/daemon/remote.c

7751

auth_zone_verify_zonemd(item->new_z, &worker->env,

usr.sbin/unbound/daemon/remote.c

7752

&worker->env.mesh->mods, NULL, 0, 1);

usr.sbin/unbound/daemon/remote.c

7758

fr_worker_auth_cha(struct worker* worker, struct fast_reload_auth_change* item)

usr.sbin/unbound/daemon/remote.c

7765

fr_worker_auth_del(worker, item, 1);

usr.sbin/unbound/daemon/remote.c

7767

if(worker->thread_num != 0)

usr.sbin/unbound/daemon/remote.c

7774

fr_pickup_auth_locks(worker, item->new_z, item->old_z, item->new_z,

usr.sbin/unbound/daemon/remote.c

778

(void)worker;

usr.sbin/unbound/daemon/remote.c

7785

(void)rbtree_delete(&worker->env.auth_zones->xtree,

usr.sbin/unbound/daemon/remote.c

7791

xfr = auth_xfer_create(worker->env.auth_zones, item->new_z);

usr.sbin/unbound/daemon/remote.c

7797

lock_rw_unlock(&worker->daemon->fast_reload_thread->old_auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7798

lock_rw_unlock(&worker->env.auth_zones->lock);

usr.sbin/unbound/daemon/remote.c

7809

fr_worker_auth_add(worker, item, 1);

usr.sbin/unbound/daemon/remote.c

7814

fr_worker_pickup_auth_changes(struct worker* worker,

usr.sbin/unbound/daemon/remote.c

7820

fr_worker_auth_del(worker, item, 0);

usr.sbin/unbound/daemon/remote.c

7823

if(worker->thread_num == 0) {

usr.sbin/unbound/daemon/remote.c

7824

fr_worker_auth_add(worker, item, 0);

usr.sbin/unbound/daemon/remote.c

7828

fr_worker_auth_cha(worker, item);

usr.sbin/unbound/daemon/remote.c

7835

fr_worker_pickup_listen_dnsport(struct worker* worker)

usr.sbin/unbound/daemon/remote.c

7837

struct listen_dnsport* front = worker->front;

usr.sbin/unbound/daemon/remote.c

7838

struct daemon* daemon = worker->daemon;

usr.sbin/unbound/daemon/remote.c

7839

if(worker->daemon->fast_reload_thread->sslctxs_changed) {

usr.sbin/unbound/daemon/remote.c

7873

fr_worker_pickup_outside_network(struct worker* worker)

usr.sbin/unbound/daemon/remote.c

7875

struct outside_network* outnet = worker->back;

usr.sbin/unbound/daemon/remote.c

7876

struct config_file* cfg = worker->env.cfg;

usr.sbin/unbound/daemon/remote.c

7886

if(worker->daemon->fast_reload_thread->sslctxs_changed)

usr.sbin/unbound/daemon/remote.c

7887

outnet->sslctx = worker->daemon->connect_dot_sslctx;

usr.sbin/unbound/daemon/remote.c

789

fast_reload_thread_start(ssl, worker, s, fr_verb, fr_nopause,

usr.sbin/unbound/daemon/remote.c

7899

fr_worker_pickup_dnstap_changes(struct worker* worker)

usr.sbin/unbound/daemon/remote.c

7901

struct dt_env* w_dtenv = &worker->dtenv;

usr.sbin/unbound/daemon/remote.c

7902

struct dt_env* d_dtenv = worker->daemon->dtenv;

usr.sbin/unbound/daemon/remote.c

7903

log_assert(d_dtenv != NULL || !worker->daemon->cfg->dnstap);

usr.sbin/unbound/daemon/remote.c

7932

fast_reload_worker_pickup_changes(struct worker* worker)

usr.sbin/unbound/daemon/remote.c

7944

fr_worker_pickup_mesh(worker);

usr.sbin/unbound/daemon/remote.c

7948

if(worker->daemon->fast_reload_tcl_has_changes)

usr.sbin/unbound/daemon/remote.c

7949

tcl_remove_old(worker->front);

usr.sbin/unbound/daemon/remote.c

7953

fr_worker_pickup_auth_changes(worker,

usr.sbin/unbound/daemon/remote.c

7954

worker->daemon->fast_reload_thread->auth_zone_change_list);

usr.sbin/unbound/daemon/remote.c

7956

worker->env.cachedb_enabled = worker->daemon->env->cachedb_enabled;

usr.sbin/unbound/daemon/remote.c

7958

fr_worker_pickup_listen_dnsport(worker);

usr.sbin/unbound/daemon/remote.c

7959

fr_worker_pickup_outside_network(worker);

usr.sbin/unbound/daemon/remote.c

7961

fr_worker_pickup_dnstap_changes(worker);

usr.sbin/unbound/daemon/remote.c

7971

struct daemon* daemon = fr->worker->daemon;

usr.sbin/unbound/daemon/remote.c

7976

if(i == fr->worker->thread_num)

usr.sbin/unbound/daemon/remote.c

7992

if(i == fr->worker->thread_num)

usr.sbin/unbound/daemon/remote.c

7998

if(fr->worker->daemon->fast_reload_drop_mesh) {

usr.sbin/unbound/daemon/remote.c

8000

mesh_delete_all(fr->worker->env.mesh);

usr.sbin/unbound/daemon/remote.c

8002

fast_reload_worker_pickup_changes(fr->worker);

usr.sbin/unbound/daemon/remote.c

8020

struct daemon* daemon = fr->worker->daemon;

usr.sbin/unbound/daemon/remote.c

8026

if(i == fr->worker->thread_num)

usr.sbin/unbound/daemon/remote.c

8033

fast_reload_worker_pickup_changes(fr->worker);

usr.sbin/unbound/daemon/remote.c

8118

struct worker* worker = fr->worker;

usr.sbin/unbound/daemon/remote.c

8120

while(worker->daemon->fast_reload_thread) {

usr.sbin/unbound/daemon/remote.c

8125

if(worker->daemon->fast_reload_thread)

usr.sbin/unbound/daemon/remote.c

8126

ub_winsock_tcp_wouldblock(worker->daemon->

usr.sbin/unbound/daemon/remote.c

8134

if(worker->daemon->fast_reload_thread)

usr.sbin/unbound/daemon/remote.c

8135

ub_winsock_tcp_wouldblock(worker->daemon->

usr.sbin/unbound/daemon/remote.c

8150

struct worker* worker = fast_reload_thread->worker;

usr.sbin/unbound/daemon/remote.c

8154

if(worker->daemon->fast_reload_thread != NULL) {

usr.sbin/unbound/daemon/remote.c

8373

fr_printq_create(struct comm_point* c, struct worker* worker)

usr.sbin/unbound/daemon/remote.c

8383

printq->worker = worker;

usr.sbin/unbound/daemon/remote.c

8450

struct daemon* daemon = printq->worker->daemon;

usr.sbin/unbound/daemon/remote.c

8466

if(printq->worker->daemon->fast_reload_thread &&

usr.sbin/unbound/daemon/remote.c

8467

printq->worker->daemon->fast_reload_thread->printq == printq)

usr.sbin/unbound/daemon/remote.c

8468

printq->worker->daemon->fast_reload_thread->printq = NULL;

usr.sbin/unbound/daemon/remote.c

8483

fast_reload_thread_start(RES* ssl, struct worker* worker, struct rc_state* s,

usr.sbin/unbound/daemon/remote.c

8486

if(worker->daemon->fast_reload_thread) {

usr.sbin/unbound/daemon/remote.c

8490

if(!fast_reload_thread_setup(worker, fr_verb, fr_nopause,

usr.sbin/unbound/daemon/remote.c

8496

worker->daemon->fast_reload_thread->started = 1;

usr.sbin/unbound/daemon/remote.c

8506

fd_set_nonblock(worker->daemon->fast_reload_thread->commpair[0]);

usr.sbin/unbound/daemon/remote.c

8507

worker->daemon->fast_reload_thread->service_event = ub_event_new(

usr.sbin/unbound/daemon/remote.c

8508

comm_base_internal(worker->base),

usr.sbin/unbound/daemon/remote.c

8509

worker->daemon->fast_reload_thread->commpair[0],

usr.sbin/unbound/daemon/remote.c

8511

worker->daemon->fast_reload_thread);

usr.sbin/unbound/daemon/remote.c

8512

if(!worker->daemon->fast_reload_thread->service_event) {

usr.sbin/unbound/daemon/remote.c

8513

fast_reload_thread_desetup(worker->daemon->fast_reload_thread);

usr.sbin/unbound/daemon/remote.c

8518

if(ub_event_add(worker->daemon->fast_reload_thread->service_event,

usr.sbin/unbound/daemon/remote.c

8520

fast_reload_thread_desetup(worker->daemon->fast_reload_thread);

usr.sbin/unbound/daemon/remote.c

8525

worker->daemon->fast_reload_thread->service_event_is_added = 1;

usr.sbin/unbound/daemon/remote.c

8537

worker->daemon->fast_reload_thread->printq = fr_printq_create(s->c,

usr.sbin/unbound/daemon/remote.c

8538

worker);

usr.sbin/unbound/daemon/remote.c

8539

if(!worker->daemon->fast_reload_thread->printq) {

usr.sbin/unbound/daemon/remote.c

8540

fast_reload_thread_desetup(worker->daemon->fast_reload_thread);

usr.sbin/unbound/daemon/remote.c

8545

worker->daemon->fast_reload_thread->printq->remote = *ssl;

usr.sbin/unbound/daemon/remote.c

8548

comm_point_stop_listening(worker->daemon->fast_reload_thread->printq->client_cp);

usr.sbin/unbound/daemon/remote.c

8551

ub_thread_create(&worker->daemon->fast_reload_thread->tid,

usr.sbin/unbound/daemon/remote.c

8552

fast_reload_thread_main, worker->daemon->fast_reload_thread);

usr.sbin/unbound/daemon/remote.c

8561

struct worker* worker = fast_reload_thread->worker;

usr.sbin/unbound/daemon/remote.c

8565

if(worker->daemon->fast_reload_thread != NULL) {

usr.sbin/unbound/daemon/remote.c

913

print_mem(RES* ssl, struct worker* worker, struct daemon* daemon,

usr.sbin/unbound/daemon/remote.c

932

val = mod_get_mem(&worker->env, "validator");

usr.sbin/unbound/daemon/remote.c

933

iter = mod_get_mem(&worker->env, "iterator");

usr.sbin/unbound/daemon/remote.c

934

respip = mod_get_mem(&worker->env, "respip");

usr.sbin/unbound/daemon/remote.c

936

subnet = mod_get_mem(&worker->env, "subnetcache");

usr.sbin/unbound/daemon/remote.c

939

ipsecmod = mod_get_mem(&worker->env, "ipsecmod");

usr.sbin/unbound/daemon/remote.c

949

dynlib = mod_get_mem(&worker->env, "dynlib");

usr.sbin/unbound/daemon/remote.h

175

struct worker* worker;

usr.sbin/unbound/daemon/remote.h

238

struct worker* worker;

usr.sbin/unbound/daemon/remote.h

298

struct listen_port* ports, struct worker* worker);

usr.sbin/unbound/daemon/remote.h

316

void daemon_remote_exec(struct worker* worker);

usr.sbin/unbound/daemon/remote.h

359

void fast_reload_thread_start(RES* ssl, struct worker* worker,

usr.sbin/unbound/daemon/remote.h

379

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_num_reply_addrs = (long long)worker->env.mesh->num_reply_addrs;

usr.sbin/unbound/daemon/stats.c

266

s->mesh_jostled = (long long)worker->env.mesh->stats_jostled;

usr.sbin/unbound/daemon/stats.c

267

s->mesh_dropped = (long long)worker->env.mesh->stats_dropped;

usr.sbin/unbound/daemon/stats.c

268

s->mesh_replies_sent = (long long)worker->env.mesh->replies_sent;

usr.sbin/unbound/daemon/stats.c

269

s->mesh_replies_sum_wait_sec = (long long)worker->env.mesh->replies_sum_wait.tv_sec;

usr.sbin/unbound/daemon/stats.c

270

s->mesh_replies_sum_wait_usec = (long long)worker->env.mesh->replies_sum_wait.tv_usec;

usr.sbin/unbound/daemon/stats.c

271

s->mesh_time_median = timehist_quartile(worker->env.mesh->histogram,

usr.sbin/unbound/daemon/stats.c

275

s->svr.ans_secure += (long long)worker->env.mesh->ans_secure;

usr.sbin/unbound/daemon/stats.c

276

s->svr.ans_bogus += (long long)worker->env.mesh->ans_bogus;

usr.sbin/unbound/daemon/stats.c

277

s->svr.val_ops += (long long)worker->env.mesh->val_ops;

usr.sbin/unbound/daemon/stats.c

278

s->svr.ans_rcode_nodata += (long long)worker->env.mesh->ans_nodata;

usr.sbin/unbound/daemon/stats.c

279

s->svr.ans_expired += (long long)worker->env.mesh->ans_expired;

usr.sbin/unbound/daemon/stats.c

281

s->svr.ans_rcode[i] += (long long)worker->env.mesh->ans_rcode[i];

usr.sbin/unbound/daemon/stats.c

283

s->svr.rpz_action[i] += (long long)worker->env.mesh->rpz_action[i];

usr.sbin/unbound/daemon/stats.c

284

timehist_export(worker->env.mesh->histogram, s->svr.hist,

usr.sbin/unbound/daemon/stats.c

287

(long long)worker->env.mesh->num_queries_discard_timeout;

usr.sbin/unbound/daemon/stats.c

289

(long long)worker->env.mesh->num_queries_replyaddr_limit;

usr.sbin/unbound/daemon/stats.c

291

(long long)worker->env.mesh->num_queries_wait_limit;

usr.sbin/unbound/daemon/stats.c

293

(long long)worker->env.mesh->num_dns_error_reports;

usr.sbin/unbound/daemon/stats.c

295

s->svr.unwanted_replies = (long long)worker->back->unwanted_replies;

usr.sbin/unbound/daemon/stats.c

296

s->svr.qtcp_outgoing = (long long)worker->back->num_tcp_outgoing;

usr.sbin/unbound/daemon/stats.c

297

s->svr.qudp_outgoing = (long long)worker->back->num_udp_outgoing;

usr.sbin/unbound/daemon/stats.c

300

s->svr.rrset_bogus = (long long)get_rrset_bogus(worker, reset);

usr.sbin/unbound/daemon/stats.c

303

s->svr.queries_ratelimited = (long long)get_queries_ratelimit(worker, reset);

usr.sbin/unbound/daemon/stats.c

306

get_slabhash_stats(worker->env.msg_cache,

usr.sbin/unbound/daemon/stats.c

308

get_slabhash_stats(&worker->env.rrset_cache->table,

usr.sbin/unbound/daemon/stats.c

310

s->svr.infra_cache_count = (long long)count_slabhash_entries(worker->env.infra_cache->hosts);

usr.sbin/unbound/daemon/stats.c

311

if(worker->env.key_cache)

usr.sbin/unbound/daemon/stats.c

312

s->svr.key_cache_count = (long long)count_slabhash_entries(worker->env.key_cache->slab);

usr.sbin/unbound/daemon/stats.c

316

if(worker->daemon->dnscenv) {

usr.sbin/unbound/daemon/stats.c

318

(long long)get_dnscrypt_cache_miss(worker, reset);

usr.sbin/unbound/daemon/stats.c

320

worker->daemon->dnscenv->shared_secrets_cache);

usr.sbin/unbound/daemon/stats.c

322

worker->daemon->dnscenv->nonces_cache);

usr.sbin/unbound/daemon/stats.c

324

(long long)get_dnscrypt_replay(worker, reset);

usr.sbin/unbound/daemon/stats.c

337

if(worker->env.auth_zones) {

usr.sbin/unbound/daemon/stats.c

338

s->svr.num_query_authzone_up += (long long)worker->env.mesh->num_query_authzone_up;

usr.sbin/unbound/daemon/stats.c

339

s->svr.num_query_authzone_down += (long long)worker->env.mesh->num_query_authzone_down;

usr.sbin/unbound/daemon/stats.c

349

worker->daemon->doq_table);

usr.sbin/unbound/daemon/stats.c

355

set_neg_cache_stats(worker, &s->svr, reset);

usr.sbin/unbound/daemon/stats.c

358

set_subnet_stats(worker, &s->svr, reset);

usr.sbin/unbound/daemon/stats.c

364

s->svr.num_query_cachedb = (long long)worker->env.mesh->ans_cachedb;

usr.sbin/unbound/daemon/stats.c

371

for(lp = worker->front->cps; lp; lp = lp->next) {

usr.sbin/unbound/daemon/stats.c

376

if(reset && !worker->env.cfg->stat_cumulative) {

usr.sbin/unbound/daemon/stats.c

377

worker_stats_clear(worker);

usr.sbin/unbound/daemon/stats.c

381

void server_stats_obtain(struct worker* worker, struct worker* who,

usr.sbin/unbound/daemon/stats.c

386

if(worker == who) {

usr.sbin/unbound/daemon/stats.c

388

server_stats_compile(worker, s, reset);

usr.sbin/unbound/daemon/stats.c

397

if(tube_wait_timeout(worker->cmd, STATS_THREAD_WAIT) == 0) {

usr.sbin/unbound/daemon/stats.c

426

if(!tube_read_msg(worker->cmd, &reply, &len, 0))

usr.sbin/unbound/daemon/stats.c

435

void server_stats_reply(struct worker* worker, int reset)

usr.sbin/unbound/daemon/stats.c

438

server_stats_compile(worker, &s, reset);

usr.sbin/unbound/daemon/stats.c

440

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

1004

struct worker* worker, struct comm_reply* repinfo)

usr.sbin/unbound/daemon/worker.c

1014

if(!inplace_cb_reply_local_call(&worker->env, NULL, NULL, NULL,

usr.sbin/unbound/daemon/worker.c

1015

LDNS_RCODE_NOERROR, edns, repinfo, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

1016

worker->env.now_tv))

usr.sbin/unbound/daemon/worker.c

1056

struct worker* worker, struct comm_reply* repinfo)

usr.sbin/unbound/daemon/worker.c

1058

chaos_replystr(pkt, (char**)&str, 1, edns, worker, repinfo);

usr.sbin/unbound/daemon/worker.c

1069

chaos_trustanchor(sldns_buffer* pkt, struct edns_data* edns, struct worker* w,

usr.sbin/unbound/daemon/worker.c

1129

answer_chaos(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

1191

answer_notify(struct worker* w, struct query_info* qinfo,

usr.sbin/unbound/daemon/worker.c

1243

struct worker* worker, struct comm_reply* repinfo,

usr.sbin/unbound/daemon/worker.c

1254

if(worker->stats.extended)

usr.sbin/unbound/daemon/worker.c

1255

worker->stats.unwanted_queries++;

usr.sbin/unbound/daemon/worker.c

1266

if(worker->stats.extended)

usr.sbin/unbound/daemon/worker.c

1267

worker->stats.unwanted_queries++;

usr.sbin/unbound/daemon/worker.c

1268

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

1397

struct worker* worker, struct comm_reply* repinfo,

usr.sbin/unbound/daemon/worker.c

140

anch = anchors_get_mem(worker->env.anchors);

usr.sbin/unbound/daemon/worker.c

1402

*acladdr = acl_addr_lookup(worker->daemon->acl,

usr.sbin/unbound/daemon/worker.c

1405

*acladdr = acl_addr_lookup(worker->daemon->acl,

usr.sbin/unbound/daemon/worker.c

1413

return deny_refuse(c, *acl, acl_deny, acl_refuse, worker, repinfo,

usr.sbin/unbound/daemon/worker.c

1419

struct worker* worker, struct comm_reply* repinfo,

usr.sbin/unbound/daemon/worker.c

1424

worker, repinfo, acladdr, ede, check_result);

usr.sbin/unbound/daemon/worker.c

143

for(i=0; i<worker->env.mesh->mods.num; i++) {

usr.sbin/unbound/daemon/worker.c

1430

check_ip_ratelimit(struct worker* worker, struct sockaddr_storage* addr,

usr.sbin/unbound/daemon/worker.c

1433

if(!infra_ip_ratelimit_inc(worker->env.infra_cache, addr, addrlen,

usr.sbin/unbound/daemon/worker.c

1434

*worker->env.now, has_cookie,

usr.sbin/unbound/daemon/worker.c

1435

worker->env.cfg->ip_ratelimit_backoff, pkt)) {

usr.sbin/unbound/daemon/worker.c

1437

if(!has_cookie && worker->env.cfg->ip_ratelimit_factor != 0 &&

usr.sbin/unbound/daemon/worker.c

1438

ub_random_max(worker->env.rnd,

usr.sbin/unbound/daemon/worker.c

1439

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

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

1474

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/worker.c

148

(&worker->env, i);

usr.sbin/unbound/daemon/worker.c

150

else if(strcmp(worker->env.mesh->mods.mod[i]->name,

usr.sbin/unbound/daemon/worker.c

1508

if (worker->env.cfg->sock_queue_timeout && timeval_isset(&c->recv_tv)) {

usr.sbin/unbound/daemon/worker.c

1509

timeval_subtract(&wait_time, worker->env.now_tv, &c->recv_tv);

usr.sbin/unbound/daemon/worker.c

1511

if (worker->stats.max_query_time_us < wait_queue_time)

usr.sbin/unbound/daemon/worker.c

1512

worker->stats.max_query_time_us = wait_queue_time;

usr.sbin/unbound/daemon/worker.c

1514

(long long)(worker->env.cfg->sock_queue_timeout * 1000000)) {

usr.sbin/unbound/daemon/worker.c

1516

worker->stats.num_queries_timed_out++;

usr.sbin/unbound/daemon/worker.c

152

subnet += (*worker->env.mesh->mods.mod[i]->get_mem)

usr.sbin/unbound/daemon/worker.c

1522

repinfo->max_udp_size = worker->daemon->cfg->max_udp_size;

usr.sbin/unbound/daemon/worker.c

1523

if(!dnsc_handle_curved_request(worker->daemon->dnscenv, repinfo)) {

usr.sbin/unbound/daemon/worker.c

1524

worker->stats.num_query_dnscrypt_crypted_malformed++;

usr.sbin/unbound/daemon/worker.c

153

(&worker->env, i);

usr.sbin/unbound/daemon/worker.c

1530

worker_check_request(c->buffer, worker, &check_result);

usr.sbin/unbound/daemon/worker.c

1548

if(worker_err_ratelimit(worker, LDNS_RCODE_FORMERR) == -1) {

usr.sbin/unbound/daemon/worker.c

155

else iter += (*worker->env.mesh->mods.mod[i]->get_mem)

usr.sbin/unbound/daemon/worker.c

1559

worker->daemon->dnscenv->provider_name) == 0)) {

usr.sbin/unbound/daemon/worker.c

156

(&worker->env, i);

usr.sbin/unbound/daemon/worker.c

1562

worker->daemon->dnscenv->provider_name,

usr.sbin/unbound/daemon/worker.c

1565

if(worker_err_ratelimit(worker, LDNS_RCODE_SERVFAIL) == -1) {

usr.sbin/unbound/daemon/worker.c

1571

worker->stats.num_query_dnscrypt_cleartext++;

usr.sbin/unbound/daemon/worker.c

1575

worker->stats.num_query_dnscrypt_cert++;

usr.sbin/unbound/daemon/worker.c

1578

worker->stats.num_query_dnscrypt_crypted++;

usr.sbin/unbound/daemon/worker.c

158

me = sizeof(*worker) + sizeof(*worker->base) + sizeof(*worker->comsig)

usr.sbin/unbound/daemon/worker.c

1585

if(worker->dtenv.log_client_query_messages) {

usr.sbin/unbound/daemon/worker.c

1588

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

1589

((worker->env.cfg->sock_queue_timeout && timeval_isset(&c->recv_tv))?&c->recv_tv:NULL));

usr.sbin/unbound/daemon/worker.c

159

+ comm_point_get_mem(worker->cmd_com)

usr.sbin/unbound/daemon/worker.c

1594

if((ret=deny_refuse_all(c, &acl, worker, repinfo, &acladdr,

usr.sbin/unbound/daemon/worker.c

1595

worker->env.cfg->ede, 1, &check_result)) != -1) {

usr.sbin/unbound/daemon/worker.c

160

+ sizeof(worker->rndstate)

usr.sbin/unbound/daemon/worker.c

1601

if((ret=deny_refuse_all(c, &acl, worker, repinfo, &acladdr,

usr.sbin/unbound/daemon/worker.c

1602

worker->env.cfg->ede, 0, &check_result)) != -1) {

usr.sbin/unbound/daemon/worker.c

1608

worker_check_request(c->buffer, worker, &check_result);

usr.sbin/unbound/daemon/worker.c

161

+ regional_get_mem(worker->scratchpad)

usr.sbin/unbound/daemon/worker.c

162

+ sizeof(*worker->env.scratch_buffer)

usr.sbin/unbound/daemon/worker.c

1620

worker->stats.num_queries++;

usr.sbin/unbound/daemon/worker.c

1621

pre_edns_ip_ratelimit = !worker->env.cfg->do_answer_cookie

usr.sbin/unbound/daemon/worker.c

163

+ sldns_buffer_capacity(worker->env.scratch_buffer);

usr.sbin/unbound/daemon/worker.c

1630

if(!check_ip_ratelimit(worker, &repinfo->client_addr,

usr.sbin/unbound/daemon/worker.c

1632

worker->stats.num_queries_ip_ratelimited++;

usr.sbin/unbound/daemon/worker.c

164

if(worker->daemon->env->fwds)

usr.sbin/unbound/daemon/worker.c

1643

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

1650

if(worker->env.cfg->log_queries) {

usr.sbin/unbound/daemon/worker.c

166

if(worker->daemon->env->hints)

usr.sbin/unbound/daemon/worker.c

1660

if(worker_err_ratelimit(worker, LDNS_RCODE_REFUSED) == -1) {

usr.sbin/unbound/daemon/worker.c

1665

if(worker->stats.extended) {

usr.sbin/unbound/daemon/worker.c

1666

worker->stats.qtype[qinfo.qtype]++;

usr.sbin/unbound/daemon/worker.c

167

log_info("hints=%u", (unsigned)hints_get_mem(worker->env.hints));

usr.sbin/unbound/daemon/worker.c

1679

if(worker_err_ratelimit(worker, LDNS_RCODE_FORMERR) == -1) {

usr.sbin/unbound/daemon/worker.c

168

if(worker->thread_num == 0)

usr.sbin/unbound/daemon/worker.c

1684

if(worker->stats.extended) {

usr.sbin/unbound/daemon/worker.c

1685

worker->stats.qtype[qinfo.qtype]++;

usr.sbin/unbound/daemon/worker.c

169

me += acl_list_get_mem(worker->daemon->acl);

usr.sbin/unbound/daemon/worker.c

1690

c->buffer, &edns, worker->env.cfg, c, repinfo,

usr.sbin/unbound/daemon/worker.c

1691

*worker->env.now, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

1692

worker->daemon->cookie_secrets)) != 0) {

usr.sbin/unbound/daemon/worker.c

1697

if(worker_err_ratelimit(worker, ret) == -1) {

usr.sbin/unbound/daemon/worker.c

1699

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1707

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1718

if(worker_err_ratelimit(worker, EDNS_RCODE_BADVERS) == -1) {

usr.sbin/unbound/daemon/worker.c

1720

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1726

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1730

worker->daemon->cfg->harden_short_bufsize) {

usr.sbin/unbound/daemon/worker.c

1740

server_stats_downstream_cookie(&worker->stats, &edns);

usr.sbin/unbound/daemon/worker.c

1746

if(!check_ip_ratelimit(worker, &repinfo->client_addr,

usr.sbin/unbound/daemon/worker.c

1749

worker->stats.num_queries_ip_ratelimited++;

usr.sbin/unbound/daemon/worker.c

1750

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1768

if(worker_err_ratelimit(worker, LDNS_EXT_RCODE_BADCOOKIE) == -1) {

usr.sbin/unbound/daemon/worker.c

1770

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1779

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1787

if(worker_err_ratelimit(worker, LDNS_RCODE_REFUSED) == -1) {

usr.sbin/unbound/daemon/worker.c

1789

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1793

worker->scratchpad, LDNS_EDE_OTHER,

usr.sbin/unbound/daemon/worker.c

1801

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1805

if(edns.udp_size > worker->daemon->cfg->max_udp_size &&

usr.sbin/unbound/daemon/worker.c

1812

edns.udp_size = worker->daemon->cfg->max_udp_size;

usr.sbin/unbound/daemon/worker.c

1818

if(worker_err_ratelimit(worker, LDNS_RCODE_SERVFAIL) == -1) {

usr.sbin/unbound/daemon/worker.c

1820

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1826

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1829

if(worker->stats.extended)

usr.sbin/unbound/daemon/worker.c

1830

server_stats_insquery(&worker->stats, c, qinfo.qtype,

usr.sbin/unbound/daemon/worker.c

1840

if(qinfo.qclass == LDNS_RR_CLASS_CH && answer_chaos(worker, &qinfo,

usr.sbin/unbound/daemon/worker.c

1842

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1847

answer_notify(worker, &qinfo, &edns, c->buffer,

usr.sbin/unbound/daemon/worker.c

1849

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1852

if(local_zones_answer(worker->daemon->local_zones, &worker->env, &qinfo,

usr.sbin/unbound/daemon/worker.c

1853

&edns, c->buffer, worker->scratchpad, repinfo, acladdr->taglist,

usr.sbin/unbound/daemon/worker.c

1856

acladdr->tag_datas_size, worker->daemon->cfg->tagname,

usr.sbin/unbound/daemon/worker.c

1857

worker->daemon->cfg->num_tags, acladdr->view)) {

usr.sbin/unbound/daemon/worker.c

1858

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1865

if(worker->env.auth_zones &&

usr.sbin/unbound/daemon/worker.c

1866

rpz_callback_from_worker_request(worker->env.auth_zones,

usr.sbin/unbound/daemon/worker.c

1867

&worker->env, &qinfo, &edns, c->buffer, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

1868

repinfo, acladdr->taglist, acladdr->taglen, &worker->stats,

usr.sbin/unbound/daemon/worker.c

1870

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1877

if(worker->env.auth_zones &&

usr.sbin/unbound/daemon/worker.c

1878

auth_zones_downstream_answer(worker->env.auth_zones,

usr.sbin/unbound/daemon/worker.c

1879

&worker->env, &qinfo, &edns, repinfo, c->buffer,

usr.sbin/unbound/daemon/worker.c

1880

worker->scratchpad)) {

usr.sbin/unbound/daemon/worker.c

1881

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1896

if((ret=deny_refuse_non_local(c, acl, worker, repinfo, acladdr,

usr.sbin/unbound/daemon/worker.c

1897

worker->env.cfg->ede, &check_result)) != -1)

usr.sbin/unbound/daemon/worker.c

1899

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1920

if(worker_err_ratelimit(worker, LDNS_RCODE_REFUSED) == -1) {

usr.sbin/unbound/daemon/worker.c

1922

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1925

if(worker->env.cfg->ede) {

usr.sbin/unbound/daemon/worker.c

1927

worker->scratchpad, LDNS_EDE_NOT_AUTHORITATIVE, "");

usr.sbin/unbound/daemon/worker.c

1932

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1941

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

1949

if((worker->daemon->use_response_ip || worker->daemon->use_rpz) &&

usr.sbin/unbound/daemon/worker.c

1974

if(!edns_bypass_cache_stage(edns.opt_list_in, &worker->env)) {

usr.sbin/unbound/daemon/worker.c

1978

if((e=slabhash_lookup(worker->env.msg_cache, h, lookup_qinfo, 0))) {

usr.sbin/unbound/daemon/worker.c

1981

if(answer_from_cache(worker, &qinfo, cinfo, &need_drop,

usr.sbin/unbound/daemon/worker.c

1991

if((worker->env.cfg->prefetch &&

usr.sbin/unbound/daemon/worker.c

1992

rep->prefetch_ttl <= *worker->env.now) ||

usr.sbin/unbound/daemon/worker.c

1993

(worker->env.cfg->serve_expired &&

usr.sbin/unbound/daemon/worker.c

1994

TTL_IS_EXPIRED(rep->ttl, *worker->env.now) &&

usr.sbin/unbound/daemon/worker.c

1995

!(*worker->env.now < rep->serve_expired_norec_ttl))) {

usr.sbin/unbound/daemon/worker.c

1997

TTL_IS_EXPIRED(rep->ttl, *worker->env.now)

usr.sbin/unbound/daemon/worker.c

1998

? 0 : rep->ttl - *worker->env.now;

usr.sbin/unbound/daemon/worker.c

2001

reply_and_prefetch(worker, lookup_qinfo,

usr.sbin/unbound/daemon/worker.c

2009

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

2014

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

2032

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

204

for(i=0; i<worker->env.mesh->mods.num; i++) {

usr.sbin/unbound/daemon/worker.c

2045

if(answer_norec_from_cache(worker, &qinfo,

usr.sbin/unbound/daemon/worker.c

2049

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

205

fptr_ok(fptr_whitelist_mod_get_mem(worker->env.mesh->

usr.sbin/unbound/daemon/worker.c

2057

server_stats_querymiss(&worker->stats, worker);

usr.sbin/unbound/daemon/worker.c

2068

mesh_new_client(worker->env.mesh, &qinfo, cinfo,

usr.sbin/unbound/daemon/worker.c

207

if(strcmp(worker->env.mesh->mods.mod[i]->name, "validator")==0)

usr.sbin/unbound/daemon/worker.c

2072

regional_free_all(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

2073

worker_mem_report(worker, NULL);

usr.sbin/unbound/daemon/worker.c

208

val += (*worker->env.mesh->mods.mod[i]->get_mem)

usr.sbin/unbound/daemon/worker.c

2084

worker->stats.ans_expired++;

usr.sbin/unbound/daemon/worker.c

2086

server_stats_insrcode(&worker->stats, c->buffer);

usr.sbin/unbound/daemon/worker.c

2087

if(worker->stats.extended) {

usr.sbin/unbound/daemon/worker.c

2088

if(is_secure_answer) worker->stats.ans_secure++;

usr.sbin/unbound/daemon/worker.c

209

(&worker->env, i);

usr.sbin/unbound/daemon/worker.c

2094

if(worker->dtenv.log_client_response_messages && rc !=0) {

usr.sbin/unbound/daemon/worker.c

2097

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

2100

if(worker->env.cfg->log_replies)

usr.sbin/unbound/daemon/worker.c

211

else if(strcmp(worker->env.mesh->mods.mod[i]->name,

usr.sbin/unbound/daemon/worker.c

2112

(worker->env.cfg->log_destaddr?(void*)repinfo->c->socket->addr:NULL),

usr.sbin/unbound/daemon/worker.c

2118

(worker->env.cfg->log_destaddr?(void*)repinfo->c->socket->addr:NULL),

usr.sbin/unbound/daemon/worker.c

213

subnet += (*worker->env.mesh->mods.mod[i]->get_mem)

usr.sbin/unbound/daemon/worker.c

2135

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/worker.c

2139

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/worker.c

214

(&worker->env, i);

usr.sbin/unbound/daemon/worker.c

2146

worker->need_to_exit = 1;

usr.sbin/unbound/daemon/worker.c

2147

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/worker.c

2151

worker->need_to_exit = 1;

usr.sbin/unbound/daemon/worker.c

2152

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/worker.c

2156

worker->need_to_exit = 1;

usr.sbin/unbound/daemon/worker.c

2157

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/worker.c

2167

worker_restart_timer(struct worker* worker)

usr.sbin/unbound/daemon/worker.c

2169

if(worker->env.cfg->stat_interval > 0) {

usr.sbin/unbound/daemon/worker.c

2171

if(worker->daemon->stat_time_specific) {

usr.sbin/unbound/daemon/worker.c

2173

int interval = worker->env.cfg->stat_interval;

usr.sbin/unbound/daemon/worker.c

2174

int offset = worker->daemon->stat_time_offset;

usr.sbin/unbound/daemon/worker.c

2198

tv.tv_sec = worker->env.cfg->stat_interval;

usr.sbin/unbound/daemon/worker.c

220

(unsigned)slabhash_get_mem(worker->env.msg_cache),

usr.sbin/unbound/daemon/worker.c

2202

comm_timer_set(worker->stat_timer, &tv);

usr.sbin/unbound/daemon/worker.c

2208

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/worker.c

2209

server_stats_log(&worker->stats, worker, worker->thread_num);

usr.sbin/unbound/daemon/worker.c

221

(unsigned)slabhash_get_mem(&worker->env.rrset_cache->table),

usr.sbin/unbound/daemon/worker.c

2210

mesh_stats(worker->env.mesh, "mesh has");

usr.sbin/unbound/daemon/worker.c

2211

worker_mem_report(worker, NULL);

usr.sbin/unbound/daemon/worker.c

2213

if (worker->daemon->cfg->shm_enable) {

usr.sbin/unbound/daemon/worker.c

2214

shm_main_run(worker);

usr.sbin/unbound/daemon/worker.c

2216

if(!worker->daemon->cfg->stat_cumulative) {

usr.sbin/unbound/daemon/worker.c

2217

worker_stats_clear(worker);

usr.sbin/unbound/daemon/worker.c

222

(unsigned)infra_get_mem(worker->env.infra_cache),

usr.sbin/unbound/daemon/worker.c

2220

worker_restart_timer(worker);

usr.sbin/unbound/daemon/worker.c

2225

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/worker.c

2228

tv.tv_sec = (time_t)autr_probe_timer(&worker->env);

usr.sbin/unbound/daemon/worker.c

2232

comm_timer_set(worker->env.probe_timer, &tv);

usr.sbin/unbound/daemon/worker.c

2235

struct worker*

usr.sbin/unbound/daemon/worker.c

2239

struct worker* worker = (struct worker*)calloc(1,

usr.sbin/unbound/daemon/worker.c

2240

sizeof(struct worker));

usr.sbin/unbound/daemon/worker.c

2241

if(!worker)

usr.sbin/unbound/daemon/worker.c

2243

worker->daemon = daemon;

usr.sbin/unbound/daemon/worker.c

2244

worker->thread_num = id;

usr.sbin/unbound/daemon/worker.c

2245

if(!(worker->cmd = tube_create())) {

usr.sbin/unbound/daemon/worker.c

2246

free(worker);

usr.sbin/unbound/daemon/worker.c

2250

if(!(worker->rndstate = ub_initstate(daemon->rand))) {

usr.sbin/unbound/daemon/worker.c

2252

tube_delete(worker->cmd);

usr.sbin/unbound/daemon/worker.c

2253

free(worker);

usr.sbin/unbound/daemon/worker.c

2257

return worker;

usr.sbin/unbound/daemon/worker.c

226

(unsigned)slabhash_get_mem(worker->env.msg_cache),

usr.sbin/unbound/daemon/worker.c

2261

worker_init(struct worker* worker, struct config_file *cfg,

usr.sbin/unbound/daemon/worker.c

2265

struct dt_env* dtenv = &worker->dtenv;

usr.sbin/unbound/daemon/worker.c

2269

worker->need_to_exit = 0;

usr.sbin/unbound/daemon/worker.c

227

(unsigned)slabhash_get_mem(&worker->env.rrset_cache->table),

usr.sbin/unbound/daemon/worker.c

2270

worker->base = comm_base_create(do_sigs);

usr.sbin/unbound/daemon/worker.c

2271

if(!worker->base) {

usr.sbin/unbound/daemon/worker.c

2273

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2276

comm_base_set_slow_accept_handlers(worker->base, &worker_stop_accept,

usr.sbin/unbound/daemon/worker.c

2277

&worker_start_accept, worker);

usr.sbin/unbound/daemon/worker.c

228

(unsigned)infra_get_mem(worker->env.infra_cache),

usr.sbin/unbound/daemon/worker.c

2291

worker->comsig = comm_signal_create(worker->base,

usr.sbin/unbound/daemon/worker.c

2292

worker_sighandler, worker);

usr.sbin/unbound/daemon/worker.c

2293

if(!worker->comsig

usr.sbin/unbound/daemon/worker.c

2295

|| !comm_signal_bind(worker->comsig, SIGHUP)

usr.sbin/unbound/daemon/worker.c

2298

|| !comm_signal_bind(worker->comsig, SIGQUIT)

usr.sbin/unbound/daemon/worker.c

2300

|| !comm_signal_bind(worker->comsig, SIGTERM)

usr.sbin/unbound/daemon/worker.c

2302

|| !comm_signal_bind(worker->comsig, SIGBREAK)

usr.sbin/unbound/daemon/worker.c

2304

|| !comm_signal_bind(worker->comsig, SIGINT)) {

usr.sbin/unbound/daemon/worker.c

2306

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2310

if(!daemon_remote_open_accept(worker->daemon->rc,

usr.sbin/unbound/daemon/worker.c

2311

worker->daemon->rc_ports, worker)) {

usr.sbin/unbound/daemon/worker.c

2312

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2316

wsvc_setup_worker(worker);

usr.sbin/unbound/daemon/worker.c

2319

worker->comsig = NULL;

usr.sbin/unbound/daemon/worker.c

2323

log_assert(worker->daemon->dtenv != NULL);

usr.sbin/unbound/daemon/worker.c

2324

memcpy(&worker->dtenv, worker->daemon->dtenv, sizeof(struct dt_env));

usr.sbin/unbound/daemon/worker.c

2325

if(!dt_init(&worker->dtenv, worker->base))

usr.sbin/unbound/daemon/worker.c

2329

worker->front = listen_create(worker->base, ports,

usr.sbin/unbound/daemon/worker.c

2336

worker->daemon->tcl, worker->daemon->listen_dot_sslctx,

usr.sbin/unbound/daemon/worker.c

2337

worker->daemon->listen_doh_sslctx,

usr.sbin/unbound/daemon/worker.c

2338

worker->daemon->listen_quic_sslctx,

usr.sbin/unbound/daemon/worker.c

2339

dtenv, worker->daemon->doq_table, worker->env.rnd,

usr.sbin/unbound/daemon/worker.c

2340

cfg, worker_handle_request, worker);

usr.sbin/unbound/daemon/worker.c

2341

if(!worker->front) {

usr.sbin/unbound/daemon/worker.c

2343

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2346

worker->back = outside_network_create(worker->base,

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->daemon->env->infra_cache, worker->rndstate,

usr.sbin/unbound/daemon/worker.c

2353

&worker_alloc_cleanup, worker,

usr.sbin/unbound/daemon/worker.c

2355

worker->daemon->connect_dot_sslctx, cfg->delay_close,

usr.sbin/unbound/daemon/worker.c

2358

cfg->tcp_auth_query_timeout, worker->daemon->shared_ports);

usr.sbin/unbound/daemon/worker.c

2359

if(!worker->back) {

usr.sbin/unbound/daemon/worker.c

2361

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2364

iterator_set_ip46_support(&worker->daemon->mods, worker->daemon->env,

usr.sbin/unbound/daemon/worker.c

2365

worker->back);

usr.sbin/unbound/daemon/worker.c

2367

if(!tube_setup_bg_listen(worker->cmd, worker->base,

usr.sbin/unbound/daemon/worker.c

2368

&worker_handle_control_cmd, worker)) {

usr.sbin/unbound/daemon/worker.c

2370

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2373

worker->stat_timer = comm_timer_create(worker->base,

usr.sbin/unbound/daemon/worker.c

2374

worker_stat_timer_cb, worker);

usr.sbin/unbound/daemon/worker.c

2375

if(!worker->stat_timer) {

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

2381

worker->scratchpad = regional_create_custom(cfg->msg_buffer_size);

usr.sbin/unbound/daemon/worker.c

2382

if(!worker->scratchpad) {

usr.sbin/unbound/daemon/worker.c

2384

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2388

server_stats_init(&worker->stats, cfg);

usr.sbin/unbound/daemon/worker.c

2389

worker->alloc = worker->daemon->worker_allocs[worker->thread_num];

usr.sbin/unbound/daemon/worker.c

2390

alloc_set_id_cleanup(worker->alloc, &worker_alloc_cleanup, worker);

usr.sbin/unbound/daemon/worker.c

2391

worker->env = *worker->daemon->env;

usr.sbin/unbound/daemon/worker.c

2392

comm_base_timept(worker->base, &worker->env.now, &worker->env.now_tv);

usr.sbin/unbound/daemon/worker.c

2393

worker->env.worker = worker;

usr.sbin/unbound/daemon/worker.c

2394

worker->env.worker_base = worker->base;

usr.sbin/unbound/daemon/worker.c

2395

worker->env.send_query = &worker_send_query;

usr.sbin/unbound/daemon/worker.c

2396

worker->env.alloc = worker->alloc;

usr.sbin/unbound/daemon/worker.c

2397

worker->env.outnet = worker->back;

usr.sbin/unbound/daemon/worker.c

2398

worker->env.rnd = worker->rndstate;

usr.sbin/unbound/daemon/worker.c

2404

worker->env.scratch = regional_create_custom(cfg->msg_buffer_size);

usr.sbin/unbound/daemon/worker.c

2405

if(!worker->env.scratch) {

usr.sbin/unbound/daemon/worker.c

2407

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2410

worker->env.mesh = mesh_create(&worker->daemon->mods, &worker->env);

usr.sbin/unbound/daemon/worker.c

2411

if(!worker->env.mesh) {

usr.sbin/unbound/daemon/worker.c

2413

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2417

worker->env.mesh->use_response_ip = worker->daemon->use_response_ip;

usr.sbin/unbound/daemon/worker.c

2418

worker->env.mesh->use_rpz = worker->daemon->use_rpz;

usr.sbin/unbound/daemon/worker.c

2420

worker->env.detach_subs = &mesh_detach_subs;

usr.sbin/unbound/daemon/worker.c

2421

worker->env.attach_sub = &mesh_attach_sub;

usr.sbin/unbound/daemon/worker.c

2422

worker->env.add_sub = &mesh_add_sub;

usr.sbin/unbound/daemon/worker.c

2423

worker->env.kill_sub = &mesh_state_delete;

usr.sbin/unbound/daemon/worker.c

2424

worker->env.detect_cycle = &mesh_detect_cycle;

usr.sbin/unbound/daemon/worker.c

2425

worker->env.scratch_buffer = sldns_buffer_new(cfg->msg_buffer_size);

usr.sbin/unbound/daemon/worker.c

2426

if(!worker->env.scratch_buffer) {

usr.sbin/unbound/daemon/worker.c

2428

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2432

if(autr_get_num_anchors(worker->env.anchors) > 0

usr.sbin/unbound/daemon/worker.c

2434

&& worker->thread_num == 0

usr.sbin/unbound/daemon/worker.c

2440

worker->env.probe_timer = comm_timer_create(worker->base,

usr.sbin/unbound/daemon/worker.c

2441

worker_probe_timer_cb, worker);

usr.sbin/unbound/daemon/worker.c

2442

if(!worker->env.probe_timer) {

usr.sbin/unbound/daemon/worker.c

2446

comm_timer_set(worker->env.probe_timer, &tv);

usr.sbin/unbound/daemon/worker.c

2450

if(worker->env.auth_zones

usr.sbin/unbound/daemon/worker.c

2452

&& worker->thread_num == 0

usr.sbin/unbound/daemon/worker.c

2455

auth_xfer_pickup_initial(worker->env.auth_zones, &worker->env);

usr.sbin/unbound/daemon/worker.c

2456

auth_zones_pickup_zonemd_verify(worker->env.auth_zones,

usr.sbin/unbound/daemon/worker.c

2457

&worker->env);

usr.sbin/unbound/daemon/worker.c

2460

if(worker->daemon->cfg->dnstap

usr.sbin/unbound/daemon/worker.c

2462

&& worker->thread_num == 0

usr.sbin/unbound/daemon/worker.c

2466

worker->base), worker->daemon->num)) {

usr.sbin/unbound/daemon/worker.c

2468

worker_delete(worker);

usr.sbin/unbound/daemon/worker.c

2473

worker_mem_report(worker, NULL);

usr.sbin/unbound/daemon/worker.c

2475

if(worker->env.cfg->stat_interval > 0) {

usr.sbin/unbound/daemon/worker.c

2477

worker->env.cfg->stat_interval);

usr.sbin/unbound/daemon/worker.c

2478

worker_restart_timer(worker);

usr.sbin/unbound/daemon/worker.c

248

struct worker* worker = e->qstate->env->worker;

usr.sbin/unbound/daemon/worker.c

2485

worker_work(struct worker* worker)

usr.sbin/unbound/daemon/worker.c

2487

comm_base_dispatch(worker->base);

usr.sbin/unbound/daemon/worker.c

2491

worker_delete(struct worker* worker)

usr.sbin/unbound/daemon/worker.c

2493

if(!worker)

usr.sbin/unbound/daemon/worker.c

2495

if(worker->env.mesh && verbosity >= VERB_OPS) {

usr.sbin/unbound/daemon/worker.c

2496

server_stats_log(&worker->stats, worker, worker->thread_num);

usr.sbin/unbound/daemon/worker.c

2497

mesh_stats(worker->env.mesh, "mesh has");

usr.sbin/unbound/daemon/worker.c

2498

worker_mem_report(worker, NULL);

usr.sbin/unbound/daemon/worker.c

2500

outside_network_quit_prepare(worker->back);

usr.sbin/unbound/daemon/worker.c

2501

mesh_delete(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

2502

sldns_buffer_free(worker->env.scratch_buffer);

usr.sbin/unbound/daemon/worker.c

2503

listen_delete(worker->front);

usr.sbin/unbound/daemon/worker.c

2504

outside_network_delete(worker->back);

usr.sbin/unbound/daemon/worker.c

2505

comm_signal_delete(worker->comsig);

usr.sbin/unbound/daemon/worker.c

2506

tube_delete(worker->cmd);

usr.sbin/unbound/daemon/worker.c

2507

comm_timer_delete(worker->stat_timer);

usr.sbin/unbound/daemon/worker.c

2508

comm_timer_delete(worker->env.probe_timer);

usr.sbin/unbound/daemon/worker.c

2509

if(worker->thread_num == 0) {

usr.sbin/unbound/daemon/worker.c

2511

wsvc_desetup_worker(worker);

usr.sbin/unbound/daemon/worker.c

2515

if(worker->daemon->cfg->dnstap

usr.sbin/unbound/daemon/worker.c

2517

&& worker->thread_num == 0

usr.sbin/unbound/daemon/worker.c

2520

dt_io_thread_stop(worker->dtenv.dtio);

usr.sbin/unbound/daemon/worker.c

2522

dt_deinit(&worker->dtenv);

usr.sbin/unbound/daemon/worker.c

2524

comm_base_delete(worker->base);

usr.sbin/unbound/daemon/worker.c

2525

ub_randfree(worker->rndstate);

usr.sbin/unbound/daemon/worker.c

2527

regional_destroy(worker->env.scratch);

usr.sbin/unbound/daemon/worker.c

2528

regional_destroy(worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

2529

free(worker);

usr.sbin/unbound/daemon/worker.c

253

mesh_report_reply(worker->env.mesh, e, reply_info, error);

usr.sbin/unbound/daemon/worker.c

2539

struct worker* worker = q->env->worker;

usr.sbin/unbound/daemon/worker.c

254

worker_mem_report(worker, sq);

usr.sbin/unbound/daemon/worker.c

2545

e->qsent = outnet_serviced_query(worker->back, qinfo, flags, dnssec,

usr.sbin/unbound/daemon/worker.c

2548

worker_handle_service_reply, e, worker->back->udp_buff, q->env,

usr.sbin/unbound/daemon/worker.c

2559

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/worker.c

2560

slabhash_clear(&worker->env.rrset_cache->table);

usr.sbin/unbound/daemon/worker.c

2561

slabhash_clear(worker->env.msg_cache);

usr.sbin/unbound/daemon/worker.c

2564

void worker_stats_clear(struct worker* worker)

usr.sbin/unbound/daemon/worker.c

2566

server_stats_init(&worker->stats, worker->env.cfg);

usr.sbin/unbound/daemon/worker.c

2567

mesh_stats_clear(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

2568

worker->back->unwanted_replies = 0;

usr.sbin/unbound/daemon/worker.c

2569

worker->back->num_tcp_outgoing = 0;

usr.sbin/unbound/daemon/worker.c

2570

worker->back->num_udp_outgoing = 0;

usr.sbin/unbound/daemon/worker.c

2575

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/worker.c

2576

listen_start_accept(worker->front);

usr.sbin/unbound/daemon/worker.c

2577

if(worker->thread_num == 0)

usr.sbin/unbound/daemon/worker.c

2578

daemon_remote_start_accept(worker->daemon->rc);

usr.sbin/unbound/daemon/worker.c

2583

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/worker.c

2584

listen_stop_accept(worker->front);

usr.sbin/unbound/daemon/worker.c

2585

if(worker->thread_num == 0)

usr.sbin/unbound/daemon/worker.c

2586

daemon_remote_stop_accept(worker->daemon->rc);

usr.sbin/unbound/daemon/worker.c

266

mesh_report_reply(worker->env.mesh, e, reply_info,

usr.sbin/unbound/daemon/worker.c

268

worker_mem_report(worker, sq);

usr.sbin/unbound/daemon/worker.c

271

mesh_report_reply(worker->env.mesh, e, reply_info, NETEVENT_NOERROR);

usr.sbin/unbound/daemon/worker.c

272

worker_mem_report(worker, sq);

usr.sbin/unbound/daemon/worker.c

282

worker_err_ratelimit(struct worker* worker, int err)

usr.sbin/unbound/daemon/worker.c

284

if(worker->err_limit_time == *worker->env.now) {

usr.sbin/unbound/daemon/worker.c

286

if(worker->err_limit_count++ > ERROR_RATELIMIT)

usr.sbin/unbound/daemon/worker.c

290

worker->err_limit_time = *worker->env.now;

usr.sbin/unbound/daemon/worker.c

291

worker->err_limit_count = 1;

usr.sbin/unbound/daemon/worker.c

349

worker_check_request(sldns_buffer* pkt, struct worker* worker,

usr.sbin/unbound/daemon/worker.c

360

worker->daemon->cfg->harden_large_queries) {

usr.sbin/unbound/daemon/worker.c

372

out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);

usr.sbin/unbound/daemon/worker.c

379

out->value = worker_err_ratelimit(worker, LDNS_RCODE_NOTIMPL);

usr.sbin/unbound/daemon/worker.c

385

out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);

usr.sbin/unbound/daemon/worker.c

393

out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);

usr.sbin/unbound/daemon/worker.c

399

out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);

usr.sbin/unbound/daemon/worker.c

405

out->value = worker_err_ratelimit(worker, LDNS_RCODE_FORMERR);

usr.sbin/unbound/daemon/worker.c

420

worker_send_reload_ack(struct worker* worker)

usr.sbin/unbound/daemon/worker.c

425

uint8_t c = (uint8_t)worker->thread_num;

usr.sbin/unbound/daemon/worker.c

428

ret = send(worker->daemon->fast_reload_thread->commreload[1],

usr.sbin/unbound/daemon/worker.c

454

worker_stop_and_wait(struct worker* worker)

usr.sbin/unbound/daemon/worker.c

458

worker_send_reload_ack(worker);

usr.sbin/unbound/daemon/worker.c

460

if(!tube_read_msg(worker->cmd, &buf, &len, 0)) {

usr.sbin/unbound/daemon/worker.c

475

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/worker.c

481

if(worker->daemon->fast_reload_drop_mesh) {

usr.sbin/unbound/daemon/worker.c

483

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

485

fast_reload_worker_pickup_changes(worker);

usr.sbin/unbound/daemon/worker.c

486

worker_send_reload_ack(worker);

usr.sbin/unbound/daemon/worker.c

494

struct worker* worker = (struct worker*)arg;

usr.sbin/unbound/daemon/worker.c

499

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/worker.c

511

comm_base_exit(worker->base);

usr.sbin/unbound/daemon/worker.c

515

server_stats_reply(worker, 1);

usr.sbin/unbound/daemon/worker.c

519

server_stats_reply(worker, 0);

usr.sbin/unbound/daemon/worker.c

523

daemon_remote_exec(worker);

usr.sbin/unbound/daemon/worker.c

527

worker_stop_and_wait(worker);

usr.sbin/unbound/daemon/worker.c

531

fast_reload_worker_pickup_changes(worker);

usr.sbin/unbound/daemon/worker.c

532

worker_send_reload_ack(worker);

usr.sbin/unbound/daemon/worker.c

590

answer_norec_from_cache(struct worker* worker, struct query_info* qinfo,

usr.sbin/unbound/daemon/worker.c

605

time_t timenow = *worker->env.now;

usr.sbin/unbound/daemon/worker.c

607

int must_validate = (!has_cd_bit || worker->env.cfg->ignore_cd)

usr.sbin/unbound/daemon/worker.c

608

&& worker->env.need_to_validate;

usr.sbin/unbound/daemon/worker.c

612

dp = dns_cache_find_delegation(&worker->env, qinfo->qname,

usr.sbin/unbound/daemon/worker.c

614

worker->scratchpad, &msg, timenow, 0, NULL, 0);

usr.sbin/unbound/daemon/worker.c

635

if(!inplace_cb_reply_servfail_call(&worker->env, qinfo, NULL,

usr.sbin/unbound/daemon/worker.c

636

msg->rep, LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

637

worker->env.now_tv))

usr.sbin/unbound/daemon/worker.c

640

if(worker->env.cfg->ede &&

usr.sbin/unbound/daemon/worker.c

643

worker->scratchpad, msg->rep->reason_bogus,

usr.sbin/unbound/daemon/worker.c

648

if(worker->stats.extended) {

usr.sbin/unbound/daemon/worker.c

649

worker->stats.ans_bogus++;

usr.sbin/unbound/daemon/worker.c

650

worker->stats.ans_rcode[LDNS_RCODE_SERVFAIL]++;

usr.sbin/unbound/daemon/worker.c

656

if(worker->env.cfg->val_clean_additional)

usr.sbin/unbound/daemon/worker.c

673

if(worker->env.cfg->disable_edns_do && (edns->bits & EDNS_DO))

usr.sbin/unbound/daemon/worker.c

675

if(!inplace_cb_reply_cache_call(&worker->env, qinfo, NULL, msg->rep,

usr.sbin/unbound/daemon/worker.c

676

(int)(flags&LDNS_RCODE_MASK), edns, repinfo, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

677

worker->env.now_tv))

usr.sbin/unbound/daemon/worker.c

682

if(worker->env.cfg->ede && has_cd_bit &&

usr.sbin/unbound/daemon/worker.c

687

worker->scratchpad, msg->rep->reason_bogus,

usr.sbin/unbound/daemon/worker.c

691

repinfo->c->buffer, 0, 1, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

693

if(!inplace_cb_reply_servfail_call(&worker->env, qinfo, NULL, NULL,

usr.sbin/unbound/daemon/worker.c

694

LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

695

worker->env.now_tv))

usr.sbin/unbound/daemon/worker.c

700

if(worker->stats.extended) {

usr.sbin/unbound/daemon/worker.c

701

if(secure) worker->stats.ans_secure++;

usr.sbin/unbound/daemon/worker.c

702

server_stats_insrcode(&worker->stats, repinfo->c->buffer);

usr.sbin/unbound/daemon/worker.c

713

apply_respip_action(struct worker* worker, const struct query_info* qinfo,

usr.sbin/unbound/daemon/worker.c

728

alias_rrset, 0, worker->scratchpad, az, NULL,

usr.sbin/unbound/daemon/worker.c

729

worker->env.views, worker->env.respip_set))

usr.sbin/unbound/daemon/worker.c

747

if(worker->stats.extended && actinfo.rpz_used) {

usr.sbin/unbound/daemon/worker.c

749

worker->stats.rpz_action[RPZ_DISABLED_ACTION]++;

usr.sbin/unbound/daemon/worker.c

751

worker->stats.rpz_action[RPZ_CNAME_OVERRIDE_ACTION]++;

usr.sbin/unbound/daemon/worker.c

753

worker->stats.rpz_action[

usr.sbin/unbound/daemon/worker.c

770

answer_from_cache(struct worker* worker, struct query_info* qinfo,

usr.sbin/unbound/daemon/worker.c

777

time_t timenow = *worker->env.now;

usr.sbin/unbound/daemon/worker.c

782

int must_validate = (!has_cd_bit || worker->env.cfg->ignore_cd)

usr.sbin/unbound/daemon/worker.c

783

&& worker->env.need_to_validate;

usr.sbin/unbound/daemon/worker.c

789

if(worker->env.cfg->serve_expired &&

usr.sbin/unbound/daemon/worker.c

794

(!worker->env.cfg->serve_expired_client_timeout ||

usr.sbin/unbound/daemon/worker.c

797

&& !(worker->env.cachedb_enabled &&

usr.sbin/unbound/daemon/worker.c

798

worker->env.cfg->cachedb_check_when_serve_expired)

usr.sbin/unbound/daemon/worker.c

837

if(worker->env.cfg->disable_edns_do && (edns->bits & EDNS_DO))

usr.sbin/unbound/daemon/worker.c

839

if(!inplace_cb_reply_servfail_call(&worker->env, qinfo, NULL, rep,

usr.sbin/unbound/daemon/worker.c

840

LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

841

worker->env.now_tv))

usr.sbin/unbound/daemon/worker.c

844

if(worker->env.cfg->ede && rep->reason_bogus != LDNS_EDE_NONE) {

usr.sbin/unbound/daemon/worker.c

846

worker->scratchpad, rep->reason_bogus,

usr.sbin/unbound/daemon/worker.c

851

rrset_array_unlock_touch(worker->env.rrset_cache,

usr.sbin/unbound/daemon/worker.c

852

worker->scratchpad, rep->ref, rep->rrset_count);

usr.sbin/unbound/daemon/worker.c

853

if(worker->stats.extended) {

usr.sbin/unbound/daemon/worker.c

854

worker->stats.ans_bogus ++;

usr.sbin/unbound/daemon/worker.c

855

worker->stats.ans_rcode[LDNS_RCODE_SERVFAIL] ++;

usr.sbin/unbound/daemon/worker.c

879

if(worker->env.cfg->disable_edns_do && (edns->bits & EDNS_DO))

usr.sbin/unbound/daemon/worker.c

882

if((worker->daemon->use_response_ip || worker->daemon->use_rpz) &&

usr.sbin/unbound/daemon/worker.c

883

!partial_rep && !apply_respip_action(worker, qinfo, cinfo, rep,

usr.sbin/unbound/daemon/worker.c

885

&encode_rep, worker->env.auth_zones)) {

usr.sbin/unbound/daemon/worker.c

889

must_validate, &encode_rep, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

890

worker->env.auth_zones, worker->env.views,

usr.sbin/unbound/daemon/worker.c

891

worker->env.respip_set)) {

usr.sbin/unbound/daemon/worker.c

906

worker->scratchpad);

usr.sbin/unbound/daemon/worker.c

912

worker->env.cfg->ede_serve_expired && worker->env.cfg->ede) {

usr.sbin/unbound/daemon/worker.c

914

worker->scratchpad, LDNS_EDE_STALE_ANSWER, "");

usr.sbin/unbound/daemon/worker.c

919

worker->env.cfg->ede && has_cd_bit &&

usr.sbin/unbound/daemon/worker.c

922

worker->scratchpad, encode_rep->reason_bogus,

usr.sbin/unbound/daemon/worker.c

925

if(!inplace_cb_reply_cache_call(&worker->env, qinfo, NULL, encode_rep,

usr.sbin/unbound/daemon/worker.c

926

(int)(flags&LDNS_RCODE_MASK), edns, repinfo, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

927

worker->env.now_tv))

usr.sbin/unbound/daemon/worker.c

930

repinfo->c->buffer, timenow, 1, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

933

if(!inplace_cb_reply_servfail_call(&worker->env, qinfo,

usr.sbin/unbound/daemon/worker.c

935

worker->scratchpad, worker->env.now_tv))

usr.sbin/unbound/daemon/worker.c

943

rrset_array_unlock_touch(worker->env.rrset_cache, worker->scratchpad,

usr.sbin/unbound/daemon/worker.c

949

rrset_array_unlock_touch(worker->env.rrset_cache,

usr.sbin/unbound/daemon/worker.c

950

worker->scratchpad, rep->ref, rep->rrset_count);

usr.sbin/unbound/daemon/worker.c

956

reply_and_prefetch(struct worker* worker, struct query_info* qinfo,

usr.sbin/unbound/daemon/worker.c

971

server_stats_prefetch(&worker->stats, worker);

usr.sbin/unbound/daemon/worker.c

976

if(modstack_find(&worker->env.mesh->mods, "subnetcache") != -1

usr.sbin/unbound/daemon/worker.c

977

&& worker->env.unique_mesh) {

usr.sbin/unbound/daemon/worker.c

978

mesh_new_prefetch(worker->env.mesh, qinfo, flags, leeway +

usr.sbin/unbound/daemon/worker.c

988

mesh_new_prefetch(worker->env.mesh, qinfo, flags, leeway +

usr.sbin/unbound/daemon/worker.h

147

struct worker* worker_create(struct daemon* daemon, int id);

usr.sbin/unbound/daemon/worker.h

158

int worker_init(struct worker* worker, struct config_file *cfg,

usr.sbin/unbound/daemon/worker.h

164

void worker_work(struct worker* worker);

usr.sbin/unbound/daemon/worker.h

169

void worker_delete(struct worker* worker);

usr.sbin/unbound/daemon/worker.h

176

void worker_send_cmd(struct worker* worker, enum worker_commands cmd);

usr.sbin/unbound/daemon/worker.h

182

void worker_stats_clear(struct worker* worker);

usr.sbin/unbound/libunbound/libunbound.c

173

ctx->env->worker = NULL;

usr.sbin/unbound/libunbound/libworker.c

175

w->env->worker = (struct worker*)w;

usr.sbin/unbound/libunbound/libworker.c

893

struct libworker* w = (struct libworker*)q->env->worker;

usr.sbin/unbound/libunbound/libworker.c

915

struct libworker* lw = (struct libworker*)e->qstate->env->worker;

usr.sbin/unbound/services/authzone.c

5454

xfr->task_transfer->worker = NULL;

usr.sbin/unbound/services/authzone.c

5644

log_assert(xfr->task_transfer->worker == env->worker);

usr.sbin/unbound/services/authzone.c

5688

if(xfr->task_nextprobe->worker == NULL)

usr.sbin/unbound/services/authzone.c

6177

if(xfr->task_nextprobe->worker == NULL)

usr.sbin/unbound/services/authzone.c

6390

log_assert(xfr->task_transfer->worker == NULL);

usr.sbin/unbound/services/authzone.c

6393

xfr->task_transfer->worker = env->worker;

usr.sbin/unbound/services/authzone.c

6417

xfr->task_probe->worker = NULL;

usr.sbin/unbound/services/authzone.c

6605

if(xfr->task_transfer->worker == NULL) {

usr.sbin/unbound/services/authzone.c

6784

if(xfr->task_transfer->worker == NULL) {

usr.sbin/unbound/services/authzone.c

6792

if(xfr->task_nextprobe->worker == NULL)

usr.sbin/unbound/services/authzone.c

6820

if(xfr->task_nextprobe->worker == NULL)

usr.sbin/unbound/services/authzone.c

6832

if(xfr->task_nextprobe->worker == NULL)

usr.sbin/unbound/services/authzone.c

6922

xfr->task_nextprobe->worker = NULL;

usr.sbin/unbound/services/authzone.c

6965

if(xfr->task_probe->worker == NULL) {

usr.sbin/unbound/services/authzone.c

6973

if(xfr->task_transfer->worker == NULL) {

usr.sbin/unbound/services/authzone.c

6982

xfr->task_probe->worker = env->worker;

usr.sbin/unbound/services/authzone.c

7015

log_assert(xfr->task_nextprobe->worker == NULL ||

usr.sbin/unbound/services/authzone.c

7016

xfr->task_nextprobe->worker == env->worker);

usr.sbin/unbound/services/authzone.c

7068

xfr->task_nextprobe->worker = env->worker;

usr.sbin/unbound/services/authzone.c

7078

if(xfr->task_probe->worker == NULL)

usr.sbin/unbound/services/authzone.c

7108

if(x->task_nextprobe && x->task_nextprobe->worker == NULL) {

usr.sbin/unbound/services/authzone.c

7139

if(x->task_nextprobe && x->task_nextprobe->worker != NULL) {

usr.sbin/unbound/services/authzone.c

7142

if(x->task_probe && x->task_probe->worker != NULL) {

usr.sbin/unbound/services/authzone.c

7145

if(x->task_transfer && x->task_transfer->worker != NULL) {

usr.sbin/unbound/services/authzone.c

7215

lock_protect(&xfr->lock, &xfr->task_nextprobe->worker,

usr.sbin/unbound/services/authzone.c

7216

sizeof(xfr->task_nextprobe->worker));

usr.sbin/unbound/services/authzone.c

7217

lock_protect(&xfr->lock, &xfr->task_probe->worker,

usr.sbin/unbound/services/authzone.c

7218

sizeof(xfr->task_probe->worker));

usr.sbin/unbound/services/authzone.c

7219

lock_protect(&xfr->lock, &xfr->task_transfer->worker,

usr.sbin/unbound/services/authzone.c

7220

sizeof(xfr->task_transfer->worker));

usr.sbin/unbound/services/authzone.c

8833

void xfr_disown_tasks(struct auth_xfer* xfr, struct worker* worker)

usr.sbin/unbound/services/authzone.c

8835

if(xfr->task_nextprobe->worker == worker) {

usr.sbin/unbound/services/authzone.c

8838

if(xfr->task_probe->worker == worker) {

usr.sbin/unbound/services/authzone.c

8841

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

2361

if(ms->env->worker)

usr.sbin/unbound/services/rpz.c

2362

ms->env->worker->stats.rpz_action[action]++;

usr.sbin/unbound/services/rpz.c

2423

if(ms->env->worker)

usr.sbin/unbound/services/rpz.c

2424

ms->env->worker->stats.rpz_action[action]++;

usr.sbin/unbound/services/rpz.c

2584

if(ms->env->worker)

usr.sbin/unbound/services/rpz.c

2585

ms->env->worker->stats.rpz_action[r->action_override]++;

usr.sbin/unbound/testcode/fake_event.c

1734

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

492

struct worker* worker;

usr.sbin/unbound/util/shm_side/shm_main.c

240

shm_general_info(struct worker* worker)

usr.sbin/unbound/util/shm_side/shm_main.c

245

shm_stat = worker->daemon->shm_info->ptr_ctl;

usr.sbin/unbound/util/shm_side/shm_main.c

246

shm_stat->time.now_sec = (long long)worker->env.now_tv->tv_sec;

usr.sbin/unbound/util/shm_side/shm_main.c

247

shm_stat->time.now_usec = (long long)worker->env.now_tv->tv_usec;

usr.sbin/unbound/util/shm_side/shm_main.c

250

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

251

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

253

shm_stat->mem.msg = (long long)slabhash_get_mem(worker->env.msg_cache);

usr.sbin/unbound/util/shm_side/shm_main.c

254

shm_stat->mem.rrset = (long long)slabhash_get_mem(&worker->env.rrset_cache->table);

usr.sbin/unbound/util/shm_side/shm_main.c

257

if(worker->daemon->dnscenv) {

usr.sbin/unbound/util/shm_side/shm_main.c

259

worker->daemon->dnscenv->shared_secrets_cache);

usr.sbin/unbound/util/shm_side/shm_main.c

261

worker->daemon->dnscenv->nonces_cache);

usr.sbin/unbound/util/shm_side/shm_main.c

264

shm_stat->mem.val = (long long)mod_get_mem(&worker->env, "validator");

usr.sbin/unbound/util/shm_side/shm_main.c

265

shm_stat->mem.iter = (long long)mod_get_mem(&worker->env, "iterator");

usr.sbin/unbound/util/shm_side/shm_main.c

266

shm_stat->mem.respip = (long long)mod_get_mem(&worker->env, "respip");

usr.sbin/unbound/util/shm_side/shm_main.c

273

shm_stat->mem.subnet = (long long)mod_get_mem(&worker->env,

usr.sbin/unbound/util/shm_side/shm_main.c

281

shm_stat->mem.ipsecmod = (long long)mod_get_mem(&worker->env,

usr.sbin/unbound/util/shm_side/shm_main.c

285

shm_stat->mem.dynlib = (long long)mod_get_mem(&worker->env, "dynlib");

usr.sbin/unbound/util/shm_side/shm_main.c

346

void shm_main_run(struct worker *worker)

usr.sbin/unbound/util/shm_side/shm_main.c

353

struct shm_main_info* shm_info = worker->daemon->shm_info;

usr.sbin/unbound/util/shm_side/shm_main.c

357

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

360

offset = worker->thread_num + 1;

usr.sbin/unbound/util/shm_side/shm_main.c

365

server_stats_compile(worker, stat_info, 0);

usr.sbin/unbound/util/shm_side/shm_main.c

370

if(shm_thread_is_first(shm_info, worker->thread_num, worker->daemon)) {

usr.sbin/unbound/util/shm_side/shm_main.c

376

shm_info->thread_volley[worker->thread_num] = 1;

usr.sbin/unbound/util/shm_side/shm_main.c

377

if(worker->thread_num == 0) {

usr.sbin/unbound/util/shm_side/shm_main.c

379

shm_general_info(worker);

usr.sbin/unbound/util/shm_side/shm_main.c

387

(stat_info->mesh_time_median/(double)worker->daemon->num);

usr.sbin/unbound/util/shm_side/shm_main.c

389

if(shm_thread_is_last(worker->daemon)) {

usr.sbin/unbound/util/shm_side/shm_main.c

395

((size_t)worker->daemon->num) * sizeof(int));

usr.sbin/unbound/util/shm_side/shm_main.c

399

(void)worker;

usr.sbin/unbound/util/shm_side/shm_main.h

45

struct worker;

usr.sbin/unbound/util/shm_side/shm_main.h

81

void shm_main_run(struct worker *worker);

usr.sbin/unbound/validator/autotrust.c

1211

env->worker?*(int*)env->worker:0, llvalue);