sbin/unwind/libunbound/iterator/iterator.c

1294

if(mesh_jostle_exceeded(qstate->env->mesh))

sbin/unwind/libunbound/iterator/iterator.c

2076

if(mesh_jostle_exceeded(qstate->env->mesh)) {

sbin/unwind/libunbound/iterator/iterator.c

2101

if(mesh_jostle_exceeded(qstate->env->mesh)) {

sbin/unwind/libunbound/iterator/iterator.c

2287

if(mesh_jostle_exceeded(qstate->env->mesh)) {

sbin/unwind/libunbound/iterator/iterator.c

2738

qstate->env->mesh->num_query_authzone_up++;

sbin/unwind/libunbound/iterator/iterator.c

2777

&& !mesh_jostle_exceeded(qstate->env->mesh)) {

sbin/unwind/libunbound/libunbound/libworker.c

242

w->env->mesh = mesh_create(&ctx->mods, w->env);

sbin/unwind/libunbound/libunbound/libworker.c

243

if(!w->env->mesh) {

sbin/unwind/libunbound/libunbound/libworker.c

644

if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,

sbin/unwind/libunbound/libunbound/libworker.c

725

if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,

sbin/unwind/libunbound/libunbound/libworker.c

863

if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,

sbin/unwind/libunbound/libunbound/libworker.c

909

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

sbin/unwind/libunbound/libunbound/libworker.c

919

mesh_report_reply(lw->env->mesh, e, reply_info,

sbin/unwind/libunbound/libunbound/libworker.c

923

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

sbin/unwind/libunbound/libunbound/libworker.c

96

mesh_delete(w->env->mesh);

sbin/unwind/libunbound/services/authzone.c

3611

env->mesh->num_query_authzone_down++;

sbin/unwind/libunbound/services/authzone.c

3624

env->mesh->num_query_authzone_down++;

sbin/unwind/libunbound/services/authzone.c

5347

auth_zone_verify_zonemd(z, env, &env->mesh->mods, NULL, 0, 0);

sbin/unwind/libunbound/services/authzone.c

5466

if(!mesh_new_callback(env->mesh, &qinfo, qflags, &edns, buf, 0,

sbin/unwind/libunbound/services/authzone.c

6661

if(!mesh_new_callback(env->mesh, &qinfo, qflags, &edns, buf, 0,

sbin/unwind/libunbound/services/authzone.c

8402

&env->mesh->mods, ds, &is_insecure, &ds_bogus,

sbin/unwind/libunbound/services/authzone.c

8416

auth_zone_verify_zonemd_with_key(z, env, &env->mesh->mods, dnskey,

sbin/unwind/libunbound/services/authzone.c

8483

if(!mesh_new_callback(env->mesh, &qinfo, qflags, &edns, buf, 0,

sbin/unwind/libunbound/services/authzone.c

8593

auth_zone_verify_zonemd(z, env, &env->mesh->mods, NULL, 0, 1);

sbin/unwind/libunbound/services/listen_dnsport.c

2170

mesh_state_remove_reply(open->mesh, open->mesh_state, req->cp);

sbin/unwind/libunbound/services/listen_dnsport.c

2394

struct mesh_area* mesh, struct mesh_state* m)

sbin/unwind/libunbound/services/listen_dnsport.c

2397

log_assert(req && mesh && m);

sbin/unwind/libunbound/services/listen_dnsport.c

2401

item->mesh = mesh;

sbin/unwind/libunbound/services/listen_dnsport.h

357

struct mesh_area* mesh;

sbin/unwind/libunbound/services/listen_dnsport.h

430

struct mesh_area* mesh, struct mesh_state* m);

sbin/unwind/libunbound/services/mesh.c

1028

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

sbin/unwind/libunbound/services/mesh.c

1050

struct mesh_area* mesh;

sbin/unwind/libunbound/services/mesh.c

1054

mesh = mstate->s.env->mesh;

sbin/unwind/libunbound/services/mesh.c

1069

infra_wait_limit_dec(mesh->env->infra_cache,

sbin/unwind/libunbound/services/mesh.c

1070

&rep->query_reply, mesh->env->cfg);

sbin/unwind/libunbound/services/mesh.c

1074

log_assert(mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

1075

mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

1082

log_assert(mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

1083

mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

1088

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

sbin/unwind/libunbound/services/mesh.c

1089

fptr_ok(fptr_whitelist_mod_clear(mesh->mods.mod[i]->clear));

sbin/unwind/libunbound/services/mesh.c

1090

(*mesh->mods.mod[i]->clear)(&mstate->s, i);

sbin/unwind/libunbound/services/mesh.c

1100

struct mesh_area* mesh;

sbin/unwind/libunbound/services/mesh.c

1106

mesh = mstate->s.env->mesh;

sbin/unwind/libunbound/services/mesh.c

1109

mesh->num_forever_states --;

sbin/unwind/libunbound/services/mesh.c

1110

mesh_list_remove(mstate, &mesh->forever_first,

sbin/unwind/libunbound/services/mesh.c

1111

&mesh->forever_last);

sbin/unwind/libunbound/services/mesh.c

1113

mesh_list_remove(mstate, &mesh->jostle_first,

sbin/unwind/libunbound/services/mesh.c

1114

&mesh->jostle_last);

sbin/unwind/libunbound/services/mesh.c

1118

log_assert(mesh->num_detached_states > 0);

sbin/unwind/libunbound/services/mesh.c

1119

mesh->num_detached_states--;

sbin/unwind/libunbound/services/mesh.c

1122

log_assert(mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

1123

mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

1130

(void)rbtree_delete(&mesh->run, mstate);

sbin/unwind/libunbound/services/mesh.c

1131

(void)rbtree_delete(&mesh->all, mstate);

sbin/unwind/libunbound/services/mesh.c

1167

struct mesh_area* mesh = qstate->env->mesh;

sbin/unwind/libunbound/services/mesh.c

1184

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

1185

log_assert(mesh->num_detached_states +

sbin/unwind/libunbound/services/mesh.c

1186

mesh->num_reply_states <= mesh->all.count);

sbin/unwind/libunbound/services/mesh.c

1197

struct mesh_area* mesh = qstate->env->mesh;

sbin/unwind/libunbound/services/mesh.c

1198

*sub = mesh_area_find(mesh, NULL, qinfo, qflags,

sbin/unwind/libunbound/services/mesh.c

1220

rbtree_insert(&mesh->all, &(*sub)->node);

sbin/unwind/libunbound/services/mesh.c

1223

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

1230

rbtree_insert(&mesh->run, &(*sub)->run_node);

sbin/unwind/libunbound/services/mesh.c

1241

struct mesh_area* mesh = qstate->env->mesh;

sbin/unwind/libunbound/services/mesh.c

1253

log_assert(mesh->num_detached_states > 0);

sbin/unwind/libunbound/services/mesh.c

1254

mesh->num_detached_states--;

sbin/unwind/libunbound/services/mesh.c

1367

log_assert(m->s.env->mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

1368

m->s.env->mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

1450

m->s.env->mesh->ans_bogus++;

sbin/unwind/libunbound/services/mesh.c

1559

log_assert(m->s.env->mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

1560

m->s.env->mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

1565

m->s.env->mesh->replies_sent++;

sbin/unwind/libunbound/services/mesh.c

1566

timeval_add(&m->s.env->mesh->replies_sum_wait, &duration);

sbin/unwind/libunbound/services/mesh.c

1567

timehist_insert(m->s.env->mesh->histogram, &duration);

sbin/unwind/libunbound/services/mesh.c

1571

if(secure) m->s.env->mesh->ans_secure++;

sbin/unwind/libunbound/services/mesh.c

1572

m->s.env->mesh->ans_rcode[ rc ] ++;

sbin/unwind/libunbound/services/mesh.c

1574

m->s.env->mesh->ans_nodata++;

sbin/unwind/libunbound/services/mesh.c

1688

qstate->env->mesh->num_dns_error_reports++;

sbin/unwind/libunbound/services/mesh.c

1750

mstate->s.env->mesh->num_queries_discard_timeout++;

sbin/unwind/libunbound/services/mesh.c

1809

mstate->s.env->mesh->rpz_action[RPZ_DISABLED_ACTION] += i;

sbin/unwind/libunbound/services/mesh.c

1811

mstate->s.env->mesh->rpz_action[RPZ_CNAME_OVERRIDE_ACTION] += i;

sbin/unwind/libunbound/services/mesh.c

1813

mstate->s.env->mesh->rpz_action[respip_action_to_rpz_action(

sbin/unwind/libunbound/services/mesh.c

1819

mstate->s.env->mesh->ans_cachedb += i;

sbin/unwind/libunbound/services/mesh.c

1828

log_assert(mstate->s.env->mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

1829

mstate->s.env->mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

1833

mstate->s.env->mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

1842

log_assert(mstate->s.env->mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

1843

mstate->s.env->mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

1848

mstate->s.env->mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

1853

void mesh_walk_supers(struct mesh_area* mesh, struct mesh_state* mstate)

sbin/unwind/libunbound/services/mesh.c

1859

(void)rbtree_insert(&mesh->run, &ref->s->run_node);

sbin/unwind/libunbound/services/mesh.c

1862

mesh->mods.mod[ref->s->s.curmod]->inform_super));

sbin/unwind/libunbound/services/mesh.c

1863

(*mesh->mods.mod[ref->s->s.curmod]->inform_super)(&mstate->s,

sbin/unwind/libunbound/services/mesh.c

1870

struct mesh_state* mesh_area_find(struct mesh_area* mesh,

sbin/unwind/libunbound/services/mesh.c

1888

result = (struct mesh_state*)rbtree_search(&mesh->all, &key);

sbin/unwind/libunbound/services/mesh.c

2058

mesh_continue(struct mesh_area* mesh, struct mesh_state* mstate,

sbin/unwind/libunbound/services/mesh.c

2065

mesh->mods.mod[mstate->s.curmod]->name);

sbin/unwind/libunbound/services/mesh.c

2073

if(mesh->mods.num == mstate->s.curmod) {

sbin/unwind/libunbound/services/mesh.c

2078

return mesh_continue(mesh, mstate, module_error, ev);

sbin/unwind/libunbound/services/mesh.c

2082

for(; mstate->s.curmod < mesh->mods.num;

sbin/unwind/libunbound/services/mesh.c

2085

mesh->mods.mod[mstate->s.curmod]->clear));

sbin/unwind/libunbound/services/mesh.c

2086

(*mesh->mods.mod[mstate->s.curmod]->clear)

sbin/unwind/libunbound/services/mesh.c

209

struct mesh_area* mesh = calloc(1, sizeof(struct mesh_area));

sbin/unwind/libunbound/services/mesh.c

210

if(!mesh) {

sbin/unwind/libunbound/services/mesh.c

2107

mesh_walk_supers(mesh, mstate);

sbin/unwind/libunbound/services/mesh.c

2122

modstack_find(&mesh->mods, "subnetcache") != -1 &&

sbin/unwind/libunbound/services/mesh.c

2130

mesh_walk_supers(mesh, mstate);

sbin/unwind/libunbound/services/mesh.c

214

mesh->histogram = timehist_setup();

sbin/unwind/libunbound/services/mesh.c

215

mesh->qbuf_bak = sldns_buffer_new(env->cfg->msg_buffer_size);

sbin/unwind/libunbound/services/mesh.c

2154

mesh_new_prefetch(mesh, qinfo, qflags, 0,

sbin/unwind/libunbound/services/mesh.c

216

if(!mesh->histogram || !mesh->qbuf_bak) {

sbin/unwind/libunbound/services/mesh.c

217

free(mesh);

sbin/unwind/libunbound/services/mesh.c

2171

void mesh_run(struct mesh_area* mesh, struct mesh_state* mstate,

sbin/unwind/libunbound/services/mesh.c

2179

mesh->mods.mod[mstate->s.curmod]->operate));

sbin/unwind/libunbound/services/mesh.c

2180

(*mesh->mods.mod[mstate->s.curmod]->operate)

sbin/unwind/libunbound/services/mesh.c

2188

mesh->mods.mod[mstate->s.curmod]->name, strextstate(s));

sbin/unwind/libunbound/services/mesh.c

2190

if(mesh_continue(mesh, mstate, s, &ev))

sbin/unwind/libunbound/services/mesh.c

2195

if(mesh->run.count > 0) {

sbin/unwind/libunbound/services/mesh.c

2197

mstate = (struct mesh_state*)mesh->run.root->key;

sbin/unwind/libunbound/services/mesh.c

2198

(void)rbtree_delete(&mesh->run, mstate);

sbin/unwind/libunbound/services/mesh.c

2202

mesh_stats(mesh, "mesh_run: end");

sbin/unwind/libunbound/services/mesh.c

2203

mesh_log_list(mesh);

sbin/unwind/libunbound/services/mesh.c

2208

mesh_log_list(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

221

mesh->mods = *stack;

sbin/unwind/libunbound/services/mesh.c

2213

RBTREE_FOR(m, struct mesh_state*, &mesh->all) {

sbin/unwind/libunbound/services/mesh.c

222

mesh->env = env;

sbin/unwind/libunbound/services/mesh.c

2229

mesh_stats(struct mesh_area* mesh, const char* str)

sbin/unwind/libunbound/services/mesh.c

223

rbtree_init(&mesh->run, &mesh_state_compare);

sbin/unwind/libunbound/services/mesh.c

2234

str, (unsigned)mesh->all.count,

sbin/unwind/libunbound/services/mesh.c

2235

(unsigned)mesh->num_reply_states,

sbin/unwind/libunbound/services/mesh.c

2236

(unsigned)mesh->num_detached_states,

sbin/unwind/libunbound/services/mesh.c

2237

(unsigned)mesh->num_reply_addrs,

sbin/unwind/libunbound/services/mesh.c

2238

(unsigned)mesh->replies_sent,

sbin/unwind/libunbound/services/mesh.c

2239

(unsigned)mesh->stats_dropped,

sbin/unwind/libunbound/services/mesh.c

224

rbtree_init(&mesh->all, &mesh_state_compare);

sbin/unwind/libunbound/services/mesh.c

2240

(unsigned)mesh->stats_jostled);

sbin/unwind/libunbound/services/mesh.c

2241

if(mesh->replies_sent > 0) {

sbin/unwind/libunbound/services/mesh.c

2243

timeval_divide(&avg, &mesh->replies_sum_wait,

sbin/unwind/libunbound/services/mesh.c

2244

mesh->replies_sent);

sbin/unwind/libunbound/services/mesh.c

2249

timehist_log(mesh->histogram, "recursions");

sbin/unwind/libunbound/services/mesh.c

225

mesh->num_reply_addrs = 0;

sbin/unwind/libunbound/services/mesh.c

2254

mesh_stats_clear(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

2256

if(!mesh)

sbin/unwind/libunbound/services/mesh.c

2258

mesh->num_query_authzone_up = 0;

sbin/unwind/libunbound/services/mesh.c

2259

mesh->num_query_authzone_down = 0;

sbin/unwind/libunbound/services/mesh.c

226

mesh->num_reply_states = 0;

sbin/unwind/libunbound/services/mesh.c

2260

mesh->replies_sent = 0;

sbin/unwind/libunbound/services/mesh.c

2261

mesh->replies_sum_wait.tv_sec = 0;

sbin/unwind/libunbound/services/mesh.c

2262

mesh->replies_sum_wait.tv_usec = 0;

sbin/unwind/libunbound/services/mesh.c

2263

mesh->stats_jostled = 0;

sbin/unwind/libunbound/services/mesh.c

2264

mesh->stats_dropped = 0;

sbin/unwind/libunbound/services/mesh.c

2265

timehist_clear(mesh->histogram);

sbin/unwind/libunbound/services/mesh.c

2266

mesh->ans_secure = 0;

sbin/unwind/libunbound/services/mesh.c

2267

mesh->ans_bogus = 0;

sbin/unwind/libunbound/services/mesh.c

2268

mesh->val_ops = 0;

sbin/unwind/libunbound/services/mesh.c

2269

mesh->ans_expired = 0;

sbin/unwind/libunbound/services/mesh.c

227

mesh->num_detached_states = 0;

sbin/unwind/libunbound/services/mesh.c

2270

mesh->ans_cachedb = 0;

sbin/unwind/libunbound/services/mesh.c

2271

memset(&mesh->ans_rcode[0], 0, sizeof(size_t)*UB_STATS_RCODE_NUM);

sbin/unwind/libunbound/services/mesh.c

2272

memset(&mesh->rpz_action[0], 0, sizeof(size_t)*UB_STATS_RPZ_ACTION_NUM);

sbin/unwind/libunbound/services/mesh.c

2273

mesh->ans_nodata = 0;

sbin/unwind/libunbound/services/mesh.c

2274

mesh->num_queries_discard_timeout = 0;

sbin/unwind/libunbound/services/mesh.c

2275

mesh->num_queries_wait_limit = 0;

sbin/unwind/libunbound/services/mesh.c

2276

mesh->num_dns_error_reports = 0;

sbin/unwind/libunbound/services/mesh.c

228

mesh->num_forever_states = 0;

sbin/unwind/libunbound/services/mesh.c

2280

mesh_get_mem(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

2283

size_t s = sizeof(*mesh) + sizeof(struct timehist) +

sbin/unwind/libunbound/services/mesh.c

2284

sizeof(struct th_buck)*mesh->histogram->num +

sbin/unwind/libunbound/services/mesh.c

2285

sizeof(sldns_buffer) + sldns_buffer_capacity(mesh->qbuf_bak);

sbin/unwind/libunbound/services/mesh.c

2286

RBTREE_FOR(m, struct mesh_state*, &mesh->all) {

sbin/unwind/libunbound/services/mesh.c

229

mesh->stats_jostled = 0;

sbin/unwind/libunbound/services/mesh.c

2297

struct mesh_area* mesh = qstate->env->mesh;

sbin/unwind/libunbound/services/mesh.c

2299

dep_m = mesh_area_find(mesh, NULL, qinfo, flags, prime, valrec);

sbin/unwind/libunbound/services/mesh.c

230

mesh->stats_dropped = 0;

sbin/unwind/libunbound/services/mesh.c

231

mesh->ans_expired = 0;

sbin/unwind/libunbound/services/mesh.c

232

mesh->ans_cachedb = 0;

sbin/unwind/libunbound/services/mesh.c

2326

void mesh_state_remove_reply(struct mesh_area* mesh, struct mesh_state* m,

sbin/unwind/libunbound/services/mesh.c

233

mesh->num_queries_discard_timeout = 0;

sbin/unwind/libunbound/services/mesh.c

234

mesh->num_queries_wait_limit = 0;

sbin/unwind/libunbound/services/mesh.c

2340

log_assert(mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

2341

mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

2342

infra_wait_limit_dec(mesh->env->infra_cache,

sbin/unwind/libunbound/services/mesh.c

2343

&n->query_reply, mesh->env->cfg);

sbin/unwind/libunbound/services/mesh.c

235

mesh->num_dns_error_reports = 0;

sbin/unwind/libunbound/services/mesh.c

2355

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

2359

log_assert(mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

236

mesh->max_reply_states = env->cfg->num_queries_per_thread;

sbin/unwind/libunbound/services/mesh.c

2360

mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

237

mesh->max_forever_states = (mesh->max_reply_states+1)/2;

sbin/unwind/libunbound/services/mesh.c

239

mesh->jostle_max.tv_sec = (time_t)(env->cfg->jostle_time / 1000);

sbin/unwind/libunbound/services/mesh.c

2398

struct mesh_area* mesh = qstate->env->mesh;

sbin/unwind/libunbound/services/mesh.c

240

mesh->jostle_max.tv_usec = (time_t)((env->cfg->jostle_time % 1000)

sbin/unwind/libunbound/services/mesh.c

243

return mesh;

sbin/unwind/libunbound/services/mesh.c

2446

if((mesh->use_response_ip || mesh->use_rpz) &&

sbin/unwind/libunbound/services/mesh.c

2513

mstate->s.env->mesh->num_queries_discard_timeout++;

sbin/unwind/libunbound/services/mesh.c

2554

mesh->ans_expired += i;

sbin/unwind/libunbound/services/mesh.c

2558

qstate->env->mesh->rpz_action[RPZ_DISABLED_ACTION] += i;

sbin/unwind/libunbound/services/mesh.c

2560

qstate->env->mesh->rpz_action[RPZ_CNAME_OVERRIDE_ACTION] += i;

sbin/unwind/libunbound/services/mesh.c

2562

qstate->env->mesh->rpz_action[

sbin/unwind/libunbound/services/mesh.c

2571

log_assert(mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

2572

mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

2574

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

2584

log_assert(qstate->env->mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

2585

qstate->env->mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

2590

qstate->env->mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

260

mesh_delete(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

2603

int mesh_jostle_exceeded(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

2605

if(mesh->all.count < mesh->max_reply_states)

sbin/unwind/libunbound/services/mesh.c

2610

void mesh_remove_callback(struct mesh_area* mesh, struct query_info* qinfo,

sbin/unwind/libunbound/services/mesh.c

2614

s = mesh_area_find(mesh, NULL, qinfo, qflags&(BIT_RD|BIT_CD), 0, 0);

sbin/unwind/libunbound/services/mesh.c

2619

log_assert(mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

262

if(!mesh)

sbin/unwind/libunbound/services/mesh.c

2620

mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

2623

log_assert(mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

2624

mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

2628

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

265

while(mesh->all.count)

sbin/unwind/libunbound/services/mesh.c

266

mesh_delete_helper(mesh->all.root);

sbin/unwind/libunbound/services/mesh.c

267

timehist_delete(mesh->histogram);

sbin/unwind/libunbound/services/mesh.c

268

sldns_buffer_free(mesh->qbuf_bak);

sbin/unwind/libunbound/services/mesh.c

269

free(mesh);

sbin/unwind/libunbound/services/mesh.c

273

mesh_delete_all(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

276

while(mesh->all.count)

sbin/unwind/libunbound/services/mesh.c

277

mesh_delete_helper(mesh->all.root);

sbin/unwind/libunbound/services/mesh.c

278

mesh->stats_dropped += mesh->num_reply_addrs;

sbin/unwind/libunbound/services/mesh.c

280

rbtree_init(&mesh->run, &mesh_state_compare);

sbin/unwind/libunbound/services/mesh.c

281

rbtree_init(&mesh->all, &mesh_state_compare);

sbin/unwind/libunbound/services/mesh.c

282

mesh->num_reply_addrs = 0;

sbin/unwind/libunbound/services/mesh.c

283

mesh->num_reply_states = 0;

sbin/unwind/libunbound/services/mesh.c

284

mesh->num_detached_states = 0;

sbin/unwind/libunbound/services/mesh.c

285

mesh->num_forever_states = 0;

sbin/unwind/libunbound/services/mesh.c

286

mesh->forever_first = NULL;

sbin/unwind/libunbound/services/mesh.c

287

mesh->forever_last = NULL;

sbin/unwind/libunbound/services/mesh.c

288

mesh->jostle_first = NULL;

sbin/unwind/libunbound/services/mesh.c

289

mesh->jostle_last = NULL;

sbin/unwind/libunbound/services/mesh.c

292

int mesh_make_new_space(struct mesh_area* mesh, sldns_buffer* qbuf)

sbin/unwind/libunbound/services/mesh.c

294

struct mesh_state* m = mesh->jostle_first;

sbin/unwind/libunbound/services/mesh.c

296

if(mesh->num_reply_states < mesh->max_reply_states)

sbin/unwind/libunbound/services/mesh.c

302

timeval_subtract(&age, mesh->env->now_tv,

sbin/unwind/libunbound/services/mesh.c

304

if(timeval_smaller(&mesh->jostle_max, &age)) {

sbin/unwind/libunbound/services/mesh.c

311

if(qbuf) sldns_buffer_copy(mesh->qbuf_bak, qbuf);

sbin/unwind/libunbound/services/mesh.c

317

mesh_walk_supers(mesh, m);

sbin/unwind/libunbound/services/mesh.c

319

mesh->stats_jostled ++;

sbin/unwind/libunbound/services/mesh.c

323

if(qbuf) sldns_buffer_copy(qbuf, mesh->qbuf_bak);

sbin/unwind/libunbound/services/mesh.c

424

void mesh_new_client(struct mesh_area* mesh, struct query_info* qinfo,

sbin/unwind/libunbound/services/mesh.c

430

int unique = unique_mesh_state(edns->opt_list_in, mesh->env);

sbin/unwind/libunbound/services/mesh.c

434

int timeout = mesh->env->cfg->serve_expired?

sbin/unwind/libunbound/services/mesh.c

435

mesh->env->cfg->serve_expired_client_timeout:0;

sbin/unwind/libunbound/services/mesh.c

441

if(!infra_wait_limit_allowed(mesh->env->infra_cache, rep,

sbin/unwind/libunbound/services/mesh.c

442

edns->cookie_valid, mesh->env->cfg)) {

sbin/unwind/libunbound/services/mesh.c

446

mesh->num_queries_wait_limit++;

sbin/unwind/libunbound/services/mesh.c

450

s = mesh_area_find(mesh, cinfo, qinfo, mesh_flags, 0, 0);

sbin/unwind/libunbound/services/mesh.c

453

if(!mesh_make_new_space(mesh, rep->c->buffer)) {

sbin/unwind/libunbound/services/mesh.c

457

mesh->stats_dropped++;

sbin/unwind/libunbound/services/mesh.c

464

if(mesh->num_reply_addrs > mesh->max_reply_states*16) {

sbin/unwind/libunbound/services/mesh.c

468

mesh->stats_dropped++;

sbin/unwind/libunbound/services/mesh.c

477

s = mesh_state_create(mesh->env, qinfo, cinfo,

sbin/unwind/libunbound/services/mesh.c

481

if(!inplace_cb_reply_servfail_call(mesh->env, qinfo, NULL, NULL,

sbin/unwind/libunbound/services/mesh.c

482

LDNS_RCODE_SERVFAIL, edns, rep, mesh->env->scratch, mesh->env->now_tv))

sbin/unwind/libunbound/services/mesh.c

490

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

500

if(!inplace_cb_reply_servfail_call(mesh->env, qinfo, NULL,

sbin/unwind/libunbound/services/mesh.c

501

NULL, LDNS_RCODE_SERVFAIL, edns, rep, mesh->env->scratch, mesh->env->now_tv))

sbin/unwind/libunbound/services/mesh.c

516

rbtree_insert(&mesh->all, &s->node);

sbin/unwind/libunbound/services/mesh.c

532

if(!tcp_req_info_add_meshstate(rep->c->tcp_req_info, mesh, s)) {

sbin/unwind/libunbound/services/mesh.c

538

http2_stream_add_meshstate(rep->c->h2_stream, mesh, s);

sbin/unwind/libunbound/services/mesh.c

546

if(!timeout && mesh->env->cfg->serve_expired &&

sbin/unwind/libunbound/services/mesh.c

547

!mesh->env->cfg->serve_expired_client_timeout &&

sbin/unwind/libunbound/services/mesh.c

548

(mesh->env->cachedb_enabled &&

sbin/unwind/libunbound/services/mesh.c

549

mesh->env->cfg->cachedb_check_when_serve_expired)) {

sbin/unwind/libunbound/services/mesh.c

556

infra_wait_limit_inc(mesh->env->infra_cache, rep, *mesh->env->now,

sbin/unwind/libunbound/services/mesh.c

557

mesh->env->cfg);

sbin/unwind/libunbound/services/mesh.c

560

log_assert(mesh->num_detached_states > 0);

sbin/unwind/libunbound/services/mesh.c

561

mesh->num_detached_states--;

sbin/unwind/libunbound/services/mesh.c

564

mesh->num_reply_states ++;

sbin/unwind/libunbound/services/mesh.c

566

mesh->num_reply_addrs++;

sbin/unwind/libunbound/services/mesh.c

569

if(mesh->num_forever_states < mesh->max_forever_states) {

sbin/unwind/libunbound/services/mesh.c

570

mesh->num_forever_states ++;

sbin/unwind/libunbound/services/mesh.c

571

mesh_list_insert(s, &mesh->forever_first,

sbin/unwind/libunbound/services/mesh.c

572

&mesh->forever_last);

sbin/unwind/libunbound/services/mesh.c

575

mesh_list_insert(s, &mesh->jostle_first,

sbin/unwind/libunbound/services/mesh.c

576

&mesh->jostle_last);

sbin/unwind/libunbound/services/mesh.c

581

mesh_run(mesh, s, module_event_new, NULL);

sbin/unwind/libunbound/services/mesh.c

585

if(!inplace_cb_reply_servfail_call(mesh->env, qinfo, &s->s,

sbin/unwind/libunbound/services/mesh.c

586

NULL, LDNS_RCODE_SERVFAIL, edns, rep, mesh->env->scratch, mesh->env->now_tv))

sbin/unwind/libunbound/services/mesh.c

599

mesh_new_callback(struct mesh_area* mesh, struct query_info* qinfo,

sbin/unwind/libunbound/services/mesh.c

604

int unique = unique_mesh_state(edns->opt_list_in, mesh->env);

sbin/unwind/libunbound/services/mesh.c

605

int timeout = mesh->env->cfg->serve_expired?

sbin/unwind/libunbound/services/mesh.c

606

mesh->env->cfg->serve_expired_client_timeout:0;

sbin/unwind/libunbound/services/mesh.c

612

s = mesh_area_find(mesh, NULL, qinfo, mesh_flags, 0, 0);

sbin/unwind/libunbound/services/mesh.c

621

s = mesh_state_create(mesh->env, qinfo, NULL,

sbin/unwind/libunbound/services/mesh.c

627

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

644

rbtree_insert(&mesh->all, &s->node);

sbin/unwind/libunbound/services/mesh.c

667

if(!timeout && mesh->env->cfg->serve_expired &&

sbin/unwind/libunbound/services/mesh.c

668

!mesh->env->cfg->serve_expired_client_timeout &&

sbin/unwind/libunbound/services/mesh.c

669

(mesh->env->cachedb_enabled &&

sbin/unwind/libunbound/services/mesh.c

670

mesh->env->cfg->cachedb_check_when_serve_expired)) {

sbin/unwind/libunbound/services/mesh.c

680

log_assert(mesh->num_detached_states > 0);

sbin/unwind/libunbound/services/mesh.c

681

mesh->num_detached_states--;

sbin/unwind/libunbound/services/mesh.c

684

mesh->num_reply_states ++;

sbin/unwind/libunbound/services/mesh.c

686

mesh->num_reply_addrs++;

sbin/unwind/libunbound/services/mesh.c

688

mesh_run(mesh, s, module_event_new, NULL);

sbin/unwind/libunbound/services/mesh.c

697

static void mesh_schedule_prefetch(struct mesh_area* mesh,

sbin/unwind/libunbound/services/mesh.c

705

struct mesh_state* s = mesh_area_find(mesh, NULL, qinfo,

sbin/unwind/libunbound/services/mesh.c

720

if(!mesh_make_new_space(mesh, NULL)) {

sbin/unwind/libunbound/services/mesh.c

722

mesh->stats_dropped ++;

sbin/unwind/libunbound/services/mesh.c

726

s = mesh_state_create(mesh->env, qinfo, NULL, mesh_flags, 0, 0);

sbin/unwind/libunbound/services/mesh.c

736

rbtree_insert(&mesh->all, &s->node);

sbin/unwind/libunbound/services/mesh.c

739

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

746

if(mesh->num_forever_states < mesh->max_forever_states) {

sbin/unwind/libunbound/services/mesh.c

747

mesh->num_forever_states ++;

sbin/unwind/libunbound/services/mesh.c

748

mesh_list_insert(s, &mesh->forever_first,

sbin/unwind/libunbound/services/mesh.c

749

&mesh->forever_last);

sbin/unwind/libunbound/services/mesh.c

752

mesh_list_insert(s, &mesh->jostle_first,

sbin/unwind/libunbound/services/mesh.c

753

&mesh->jostle_last);

sbin/unwind/libunbound/services/mesh.c

765

rbtree_insert(&mesh->run, &s->run_node);

sbin/unwind/libunbound/services/mesh.c

770

mesh_run(mesh, s, module_event_new, NULL);

sbin/unwind/libunbound/services/mesh.c

778

static void mesh_schedule_prefetch_subnet(struct mesh_area* mesh,

sbin/unwind/libunbound/services/mesh.c

791

if(!mesh_make_new_space(mesh, NULL)) {

sbin/unwind/libunbound/services/mesh.c

793

mesh->stats_dropped ++;

sbin/unwind/libunbound/services/mesh.c

797

s = mesh_state_create(mesh->env, qinfo, NULL, mesh_flags, 0, 0);

sbin/unwind/libunbound/services/mesh.c

804

opt = edns_opt_list_find(edns_list, mesh->env->cfg->client_subnet_opcode);

sbin/unwind/libunbound/services/mesh.c

823

rbtree_insert(&mesh->all, &s->node);

sbin/unwind/libunbound/services/mesh.c

826

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

833

if(mesh->num_forever_states < mesh->max_forever_states) {

sbin/unwind/libunbound/services/mesh.c

834

mesh->num_forever_states ++;

sbin/unwind/libunbound/services/mesh.c

835

mesh_list_insert(s, &mesh->forever_first,

sbin/unwind/libunbound/services/mesh.c

836

&mesh->forever_last);

sbin/unwind/libunbound/services/mesh.c

839

mesh_list_insert(s, &mesh->jostle_first,

sbin/unwind/libunbound/services/mesh.c

840

&mesh->jostle_last);

sbin/unwind/libunbound/services/mesh.c

852

rbtree_insert(&mesh->run, &s->run_node);

sbin/unwind/libunbound/services/mesh.c

857

mesh_run(mesh, s, module_event_new, NULL);

sbin/unwind/libunbound/services/mesh.c

861

void mesh_new_prefetch(struct mesh_area* mesh, struct query_info* qinfo,

sbin/unwind/libunbound/services/mesh.c

869

mesh_schedule_prefetch_subnet(mesh, qinfo, qflags, leeway, 1,

sbin/unwind/libunbound/services/mesh.c

873

mesh_schedule_prefetch(mesh, qinfo, qflags, leeway, 1,

sbin/unwind/libunbound/services/mesh.c

877

void mesh_report_reply(struct mesh_area* mesh, struct outbound_entry* e,

sbin/unwind/libunbound/services/mesh.c

887

mesh_run(mesh, e->qstate->mesh_info, event, e);

sbin/unwind/libunbound/services/mesh.h

297

void mesh_delete(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

317

void mesh_new_client(struct mesh_area* mesh, struct query_info* qinfo,

sbin/unwind/libunbound/services/mesh.h

339

int mesh_new_callback(struct mesh_area* mesh, struct query_info* qinfo,

sbin/unwind/libunbound/services/mesh.h

357

void mesh_new_prefetch(struct mesh_area* mesh, struct query_info* qinfo,

sbin/unwind/libunbound/services/mesh.h

371

void mesh_report_reply(struct mesh_area* mesh, struct outbound_entry* e,

sbin/unwind/libunbound/services/mesh.h

469

void mesh_walk_supers(struct mesh_area* mesh, struct mesh_state* mstate);

sbin/unwind/libunbound/services/mesh.h

515

void mesh_delete_all(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

529

struct mesh_state* mesh_area_find(struct mesh_area* mesh,

sbin/unwind/libunbound/services/mesh.h

583

void mesh_run(struct mesh_area* mesh, struct mesh_state* mstate,

sbin/unwind/libunbound/services/mesh.h

591

void mesh_stats(struct mesh_area* mesh, const char* str);

sbin/unwind/libunbound/services/mesh.h

597

void mesh_stats_clear(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

603

void mesh_log_list(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

610

size_t mesh_get_mem(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

647

int mesh_make_new_space(struct mesh_area* mesh, struct sldns_buffer* qbuf);

sbin/unwind/libunbound/services/mesh.h

674

void mesh_state_remove_reply(struct mesh_area* mesh, struct mesh_state* m,

sbin/unwind/libunbound/services/mesh.h

705

int mesh_jostle_exceeded(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

723

void mesh_remove_callback(struct mesh_area* mesh, struct query_info* qinfo,

sbin/unwind/libunbound/services/modstack.c

337

int m = modstack_find(&env->mesh->mods, name);

sbin/unwind/libunbound/services/modstack.c

339

fptr_ok(fptr_whitelist_mod_get_mem(env->mesh->

sbin/unwind/libunbound/services/modstack.c

341

return (*env->mesh->mods.mod[m]->get_mem)(env, m);

sbin/unwind/libunbound/util/module.h

493

struct mesh_area* mesh;

sbin/unwind/libunbound/util/netevent.c

3174

mesh_state_remove_reply(h2_stream->mesh, h2_stream->mesh_state,

sbin/unwind/libunbound/util/netevent.c

5105

struct mesh_area* mesh, struct mesh_state* m)

sbin/unwind/libunbound/util/netevent.c

5107

h2_stream->mesh = mesh;

sbin/unwind/libunbound/util/netevent.h

1031

struct mesh_area* mesh, struct mesh_state* m);

sbin/unwind/libunbound/util/netevent.h

995

struct mesh_area* mesh;

sbin/unwind/libunbound/validator/autotrust.c

2422

if(!mesh_new_callback(env->mesh, &qinfo, qflags, &edns, buf, 0,

sbin/unwind/libunbound/validator/val_sigcrypt.c

1683

if(qstate && qstate->env && qstate->env->mesh)

sbin/unwind/libunbound/validator/val_sigcrypt.c

1684

qstate->env->mesh->val_ops++;

sbin/unwind/libunbound/validator/validator.c

840

mesh_run(qstate->env->mesh, qstate->mesh_info, module_event_pass,

sbin/unwind/libunbound/validator/validator.c

879

if(qstate->env->mesh->all.count >= qstate->env->mesh->max_reply_states)

sbin/unwind/libunbound/validator/validator.c

881

else if(qstate->env->mesh->all.count >= qstate->env->mesh->max_reply_states/2)

sbin/unwind/libunbound/validator/validator.c

883

else if(qstate->env->mesh->all.count >= qstate->env->mesh->max_reply_states/4)

sys/dev/pci/if_mwxreg.h

1241

uint8_t mesh;

usr.bin/deroff/deroff.c

1692

M(NONE, 's','h', mesh),

usr.bin/deroff/deroff.c

1693

M(NONE, 'u','h', mesh),

usr.bin/deroff/deroff.c

227

int mesh(pacmac);

usr.sbin/unbound/daemon/remote.c

2262

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/remote.c

2694

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/remote.c

3000

get_mesh_status(struct mesh_area* mesh, struct mesh_state* m,

usr.sbin/unbound/daemon/remote.c

3004

const char *modname = mesh->mods.mod[m->s.curmod]->name;

usr.sbin/unbound/daemon/remote.c

3056

struct mesh_area* mesh;

usr.sbin/unbound/daemon/remote.c

3067

mesh = worker->env.mesh;

usr.sbin/unbound/daemon/remote.c

3068

if(!mesh) return;

usr.sbin/unbound/daemon/remote.c

3069

RBTREE_FOR(m, struct mesh_state*, &mesh->all) {

usr.sbin/unbound/daemon/remote.c

3074

get_mesh_status(mesh, m, statbuf, sizeof(statbuf));

usr.sbin/unbound/daemon/remote.c

3232

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

usr.sbin/unbound/daemon/remote.c

3282

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

usr.sbin/unbound/daemon/remote.c

7291

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

usr.sbin/unbound/daemon/remote.c

7293

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

usr.sbin/unbound/daemon/remote.c

7294

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

usr.sbin/unbound/daemon/remote.c

7295

mesh->max_reply_states = cfg->num_queries_per_thread;

usr.sbin/unbound/daemon/remote.c

7296

mesh->max_forever_states = (mesh->max_reply_states+1)/2;

usr.sbin/unbound/daemon/remote.c

7298

mesh->jostle_max.tv_sec = (time_t)(cfg->jostle_time / 1000);

usr.sbin/unbound/daemon/remote.c

7299

mesh->jostle_max.tv_usec = (time_t)((cfg->jostle_time % 1000)*1000);

usr.sbin/unbound/daemon/remote.c

7337

auth_zone_zonemd_stop_lookup(struct auth_zone* z, struct mesh_area* mesh)

usr.sbin/unbound/daemon/remote.c

7347

mesh_remove_callback(mesh, &qinfo, qflags,

usr.sbin/unbound/daemon/remote.c

7403

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

usr.sbin/unbound/daemon/remote.c

7510

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

usr.sbin/unbound/daemon/remote.c

7679

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

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

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

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

143

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

usr.sbin/unbound/daemon/stats.c

168

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

usr.sbin/unbound/daemon/stats.c

191

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

usr.sbin/unbound/daemon/stats.c

209

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

usr.sbin/unbound/daemon/stats.c

263

s->mesh_num_states = (long long)worker->env.mesh->all.count;

usr.sbin/unbound/daemon/stats.c

264

s->mesh_num_reply_states = (long long)worker->env.mesh->num_reply_states;

usr.sbin/unbound/daemon/stats.c

265

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

usr.sbin/unbound/daemon/stats.c

266

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

usr.sbin/unbound/daemon/stats.c

267

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

usr.sbin/unbound/daemon/stats.c

268

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

usr.sbin/unbound/daemon/stats.c

269

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

usr.sbin/unbound/daemon/stats.c

270

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

usr.sbin/unbound/daemon/stats.c

274

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

usr.sbin/unbound/daemon/stats.c

275

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

usr.sbin/unbound/daemon/stats.c

276

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

usr.sbin/unbound/daemon/stats.c

277

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

usr.sbin/unbound/daemon/stats.c

278

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

usr.sbin/unbound/daemon/stats.c

280

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

usr.sbin/unbound/daemon/stats.c

282

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

usr.sbin/unbound/daemon/stats.c

283

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

usr.sbin/unbound/daemon/stats.c

286

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

usr.sbin/unbound/daemon/stats.c

288

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

usr.sbin/unbound/daemon/stats.c

290

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

usr.sbin/unbound/daemon/stats.c

335

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

usr.sbin/unbound/daemon/stats.c

336

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

usr.sbin/unbound/daemon/stats.c

361

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

usr.sbin/unbound/daemon/stats.c

99

stats->sum_query_list_size += worker->env.mesh->all.count;

usr.sbin/unbound/daemon/worker.c

124

size_t total, front, back, mesh, msg, rrset, infra, ac, superac;

usr.sbin/unbound/daemon/worker.c

137

mesh = mesh_get_mem(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

143

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

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

150

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

usr.sbin/unbound/daemon/worker.c

152

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

usr.sbin/unbound/daemon/worker.c

155

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

usr.sbin/unbound/daemon/worker.c

173

total = front+back+mesh+msg+rrset+infra+iter+val+ac+superac+me;

usr.sbin/unbound/daemon/worker.c

180

(unsigned)mesh, (unsigned)msg, (unsigned)rrset, (unsigned)infra,

usr.sbin/unbound/daemon/worker.c

189

(unsigned)mesh, (unsigned)msg, (unsigned)rrset,

usr.sbin/unbound/daemon/worker.c

2006

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

usr.sbin/unbound/daemon/worker.c

204

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

usr.sbin/unbound/daemon/worker.c

205

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

usr.sbin/unbound/daemon/worker.c

207

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

usr.sbin/unbound/daemon/worker.c

208

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

usr.sbin/unbound/daemon/worker.c

211

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

usr.sbin/unbound/daemon/worker.c

2121

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

usr.sbin/unbound/daemon/worker.c

213

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

usr.sbin/unbound/daemon/worker.c

2332

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

usr.sbin/unbound/daemon/worker.c

2333

if(!worker->env.mesh) {

usr.sbin/unbound/daemon/worker.c

2339

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

usr.sbin/unbound/daemon/worker.c

2340

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

usr.sbin/unbound/daemon/worker.c

2417

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

usr.sbin/unbound/daemon/worker.c

2419

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

usr.sbin/unbound/daemon/worker.c

2423

mesh_delete(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

2490

mesh_stats_clear(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

253

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

usr.sbin/unbound/daemon/worker.c

265

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

usr.sbin/unbound/daemon/worker.c

270

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

usr.sbin/unbound/daemon/worker.c

445

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

938

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

usr.sbin/unbound/daemon/worker.c

940

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

usr.sbin/unbound/daemon/worker.c

950

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

usr.sbin/unbound/iterator/iterator.c

1294

if(mesh_jostle_exceeded(qstate->env->mesh))

usr.sbin/unbound/iterator/iterator.c

2076

if(mesh_jostle_exceeded(qstate->env->mesh)) {

usr.sbin/unbound/iterator/iterator.c

2101

if(mesh_jostle_exceeded(qstate->env->mesh)) {

usr.sbin/unbound/iterator/iterator.c

2287

if(mesh_jostle_exceeded(qstate->env->mesh)) {

usr.sbin/unbound/iterator/iterator.c

2738

qstate->env->mesh->num_query_authzone_up++;

usr.sbin/unbound/iterator/iterator.c

2777

&& !mesh_jostle_exceeded(qstate->env->mesh)) {

usr.sbin/unbound/libunbound/libworker.c

242

w->env->mesh = mesh_create(&ctx->mods, w->env);

usr.sbin/unbound/libunbound/libworker.c

243

if(!w->env->mesh) {

usr.sbin/unbound/libunbound/libworker.c

644

if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,

usr.sbin/unbound/libunbound/libworker.c

725

if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,

usr.sbin/unbound/libunbound/libworker.c

863

if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,

usr.sbin/unbound/libunbound/libworker.c

909

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

usr.sbin/unbound/libunbound/libworker.c

919

mesh_report_reply(lw->env->mesh, e, reply_info,

usr.sbin/unbound/libunbound/libworker.c

923

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

usr.sbin/unbound/libunbound/libworker.c

96

mesh_delete(w->env->mesh);

usr.sbin/unbound/services/authzone.c

3611

env->mesh->num_query_authzone_down++;

usr.sbin/unbound/services/authzone.c

3624

env->mesh->num_query_authzone_down++;

usr.sbin/unbound/services/authzone.c

5347

auth_zone_verify_zonemd(z, env, &env->mesh->mods, NULL, 0, 0);

usr.sbin/unbound/services/authzone.c

5466

if(!mesh_new_callback(env->mesh, &qinfo, qflags, &edns, buf, 0,

usr.sbin/unbound/services/authzone.c

6661

if(!mesh_new_callback(env->mesh, &qinfo, qflags, &edns, buf, 0,

usr.sbin/unbound/services/authzone.c

8402

&env->mesh->mods, ds, &is_insecure, &ds_bogus,

usr.sbin/unbound/services/authzone.c

8416

auth_zone_verify_zonemd_with_key(z, env, &env->mesh->mods, dnskey,

usr.sbin/unbound/services/authzone.c

8483

if(!mesh_new_callback(env->mesh, &qinfo, qflags, &edns, buf, 0,

usr.sbin/unbound/services/authzone.c

8593

auth_zone_verify_zonemd(z, env, &env->mesh->mods, NULL, 0, 1);

usr.sbin/unbound/services/listen_dnsport.c

2170

mesh_state_remove_reply(open->mesh, open->mesh_state, req->cp);

usr.sbin/unbound/services/listen_dnsport.c

2394

struct mesh_area* mesh, struct mesh_state* m)

usr.sbin/unbound/services/listen_dnsport.c

2397

log_assert(req && mesh && m);

usr.sbin/unbound/services/listen_dnsport.c

2401

item->mesh = mesh;

usr.sbin/unbound/services/listen_dnsport.h

357

struct mesh_area* mesh;

usr.sbin/unbound/services/listen_dnsport.h

430

struct mesh_area* mesh, struct mesh_state* m);

usr.sbin/unbound/services/mesh.c

1028

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

usr.sbin/unbound/services/mesh.c

1050

struct mesh_area* mesh;

usr.sbin/unbound/services/mesh.c

1054

mesh = mstate->s.env->mesh;

usr.sbin/unbound/services/mesh.c

1069

infra_wait_limit_dec(mesh->env->infra_cache,

usr.sbin/unbound/services/mesh.c

1070

&rep->query_reply, mesh->env->cfg);

usr.sbin/unbound/services/mesh.c

1074

log_assert(mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

1075

mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

1082

log_assert(mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

1083

mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

1088

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

usr.sbin/unbound/services/mesh.c

1089

fptr_ok(fptr_whitelist_mod_clear(mesh->mods.mod[i]->clear));

usr.sbin/unbound/services/mesh.c

1090

(*mesh->mods.mod[i]->clear)(&mstate->s, i);

usr.sbin/unbound/services/mesh.c

1100

struct mesh_area* mesh;

usr.sbin/unbound/services/mesh.c

1106

mesh = mstate->s.env->mesh;

usr.sbin/unbound/services/mesh.c

1109

mesh->num_forever_states --;

usr.sbin/unbound/services/mesh.c

1110

mesh_list_remove(mstate, &mesh->forever_first,

usr.sbin/unbound/services/mesh.c

1111

&mesh->forever_last);

usr.sbin/unbound/services/mesh.c

1113

mesh_list_remove(mstate, &mesh->jostle_first,

usr.sbin/unbound/services/mesh.c

1114

&mesh->jostle_last);

usr.sbin/unbound/services/mesh.c

1118

log_assert(mesh->num_detached_states > 0);

usr.sbin/unbound/services/mesh.c

1119

mesh->num_detached_states--;

usr.sbin/unbound/services/mesh.c

1122

log_assert(mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

1123

mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

1130

(void)rbtree_delete(&mesh->run, mstate);

usr.sbin/unbound/services/mesh.c

1131

(void)rbtree_delete(&mesh->all, mstate);

usr.sbin/unbound/services/mesh.c

1167

struct mesh_area* mesh = qstate->env->mesh;

usr.sbin/unbound/services/mesh.c

1184

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

1185

log_assert(mesh->num_detached_states +

usr.sbin/unbound/services/mesh.c

1186

mesh->num_reply_states <= mesh->all.count);

usr.sbin/unbound/services/mesh.c

1197

struct mesh_area* mesh = qstate->env->mesh;

usr.sbin/unbound/services/mesh.c

1198

*sub = mesh_area_find(mesh, NULL, qinfo, qflags,

usr.sbin/unbound/services/mesh.c

1220

rbtree_insert(&mesh->all, &(*sub)->node);

usr.sbin/unbound/services/mesh.c

1223

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

1230

rbtree_insert(&mesh->run, &(*sub)->run_node);

usr.sbin/unbound/services/mesh.c

1241

struct mesh_area* mesh = qstate->env->mesh;

usr.sbin/unbound/services/mesh.c

1253

log_assert(mesh->num_detached_states > 0);

usr.sbin/unbound/services/mesh.c

1254

mesh->num_detached_states--;

usr.sbin/unbound/services/mesh.c

1367

log_assert(m->s.env->mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

1368

m->s.env->mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

1450

m->s.env->mesh->ans_bogus++;

usr.sbin/unbound/services/mesh.c

1559

log_assert(m->s.env->mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

1560

m->s.env->mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

1565

m->s.env->mesh->replies_sent++;

usr.sbin/unbound/services/mesh.c

1566

timeval_add(&m->s.env->mesh->replies_sum_wait, &duration);

usr.sbin/unbound/services/mesh.c

1567

timehist_insert(m->s.env->mesh->histogram, &duration);

usr.sbin/unbound/services/mesh.c

1571

if(secure) m->s.env->mesh->ans_secure++;

usr.sbin/unbound/services/mesh.c

1572

m->s.env->mesh->ans_rcode[ rc ] ++;

usr.sbin/unbound/services/mesh.c

1574

m->s.env->mesh->ans_nodata++;

usr.sbin/unbound/services/mesh.c

1688

qstate->env->mesh->num_dns_error_reports++;

usr.sbin/unbound/services/mesh.c

1750

mstate->s.env->mesh->num_queries_discard_timeout++;

usr.sbin/unbound/services/mesh.c

1809

mstate->s.env->mesh->rpz_action[RPZ_DISABLED_ACTION] += i;

usr.sbin/unbound/services/mesh.c

1811

mstate->s.env->mesh->rpz_action[RPZ_CNAME_OVERRIDE_ACTION] += i;

usr.sbin/unbound/services/mesh.c

1813

mstate->s.env->mesh->rpz_action[respip_action_to_rpz_action(

usr.sbin/unbound/services/mesh.c

1819

mstate->s.env->mesh->ans_cachedb += i;

usr.sbin/unbound/services/mesh.c

1828

log_assert(mstate->s.env->mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

1829

mstate->s.env->mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

1833

mstate->s.env->mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

1842

log_assert(mstate->s.env->mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

1843

mstate->s.env->mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

1848

mstate->s.env->mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

1853

void mesh_walk_supers(struct mesh_area* mesh, struct mesh_state* mstate)

usr.sbin/unbound/services/mesh.c

1859

(void)rbtree_insert(&mesh->run, &ref->s->run_node);

usr.sbin/unbound/services/mesh.c

1862

mesh->mods.mod[ref->s->s.curmod]->inform_super));

usr.sbin/unbound/services/mesh.c

1863

(*mesh->mods.mod[ref->s->s.curmod]->inform_super)(&mstate->s,

usr.sbin/unbound/services/mesh.c

1870

struct mesh_state* mesh_area_find(struct mesh_area* mesh,

usr.sbin/unbound/services/mesh.c

1888

result = (struct mesh_state*)rbtree_search(&mesh->all, &key);

usr.sbin/unbound/services/mesh.c

2058

mesh_continue(struct mesh_area* mesh, struct mesh_state* mstate,

usr.sbin/unbound/services/mesh.c

2065

mesh->mods.mod[mstate->s.curmod]->name);

usr.sbin/unbound/services/mesh.c

2073

if(mesh->mods.num == mstate->s.curmod) {

usr.sbin/unbound/services/mesh.c

2078

return mesh_continue(mesh, mstate, module_error, ev);

usr.sbin/unbound/services/mesh.c

2082

for(; mstate->s.curmod < mesh->mods.num;

usr.sbin/unbound/services/mesh.c

2085

mesh->mods.mod[mstate->s.curmod]->clear));

usr.sbin/unbound/services/mesh.c

2086

(*mesh->mods.mod[mstate->s.curmod]->clear)

usr.sbin/unbound/services/mesh.c

209

struct mesh_area* mesh = calloc(1, sizeof(struct mesh_area));

usr.sbin/unbound/services/mesh.c

210

if(!mesh) {

usr.sbin/unbound/services/mesh.c

2107

mesh_walk_supers(mesh, mstate);

usr.sbin/unbound/services/mesh.c

2122

modstack_find(&mesh->mods, "subnetcache") != -1 &&

usr.sbin/unbound/services/mesh.c

2130

mesh_walk_supers(mesh, mstate);

usr.sbin/unbound/services/mesh.c

214

mesh->histogram = timehist_setup();

usr.sbin/unbound/services/mesh.c

215

mesh->qbuf_bak = sldns_buffer_new(env->cfg->msg_buffer_size);

usr.sbin/unbound/services/mesh.c

2154

mesh_new_prefetch(mesh, qinfo, qflags, 0,

usr.sbin/unbound/services/mesh.c

216

if(!mesh->histogram || !mesh->qbuf_bak) {

usr.sbin/unbound/services/mesh.c

217

free(mesh);

usr.sbin/unbound/services/mesh.c

2171

void mesh_run(struct mesh_area* mesh, struct mesh_state* mstate,

usr.sbin/unbound/services/mesh.c

2179

mesh->mods.mod[mstate->s.curmod]->operate));

usr.sbin/unbound/services/mesh.c

2180

(*mesh->mods.mod[mstate->s.curmod]->operate)

usr.sbin/unbound/services/mesh.c

2188

mesh->mods.mod[mstate->s.curmod]->name, strextstate(s));

usr.sbin/unbound/services/mesh.c

2190

if(mesh_continue(mesh, mstate, s, &ev))

usr.sbin/unbound/services/mesh.c

2195

if(mesh->run.count > 0) {

usr.sbin/unbound/services/mesh.c

2197

mstate = (struct mesh_state*)mesh->run.root->key;

usr.sbin/unbound/services/mesh.c

2198

(void)rbtree_delete(&mesh->run, mstate);

usr.sbin/unbound/services/mesh.c

2202

mesh_stats(mesh, "mesh_run: end");

usr.sbin/unbound/services/mesh.c

2203

mesh_log_list(mesh);

usr.sbin/unbound/services/mesh.c

2208

mesh_log_list(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

221

mesh->mods = *stack;

usr.sbin/unbound/services/mesh.c

2213

RBTREE_FOR(m, struct mesh_state*, &mesh->all) {

usr.sbin/unbound/services/mesh.c

222

mesh->env = env;

usr.sbin/unbound/services/mesh.c

2229

mesh_stats(struct mesh_area* mesh, const char* str)

usr.sbin/unbound/services/mesh.c

223

rbtree_init(&mesh->run, &mesh_state_compare);

usr.sbin/unbound/services/mesh.c

2234

str, (unsigned)mesh->all.count,

usr.sbin/unbound/services/mesh.c

2235

(unsigned)mesh->num_reply_states,

usr.sbin/unbound/services/mesh.c

2236

(unsigned)mesh->num_detached_states,

usr.sbin/unbound/services/mesh.c

2237

(unsigned)mesh->num_reply_addrs,

usr.sbin/unbound/services/mesh.c

2238

(unsigned)mesh->replies_sent,

usr.sbin/unbound/services/mesh.c

2239

(unsigned)mesh->stats_dropped,

usr.sbin/unbound/services/mesh.c

224

rbtree_init(&mesh->all, &mesh_state_compare);

usr.sbin/unbound/services/mesh.c

2240

(unsigned)mesh->stats_jostled);

usr.sbin/unbound/services/mesh.c

2241

if(mesh->replies_sent > 0) {

usr.sbin/unbound/services/mesh.c

2243

timeval_divide(&avg, &mesh->replies_sum_wait,

usr.sbin/unbound/services/mesh.c

2244

mesh->replies_sent);

usr.sbin/unbound/services/mesh.c

2249

timehist_log(mesh->histogram, "recursions");

usr.sbin/unbound/services/mesh.c

225

mesh->num_reply_addrs = 0;

usr.sbin/unbound/services/mesh.c

2254

mesh_stats_clear(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

2256

if(!mesh)

usr.sbin/unbound/services/mesh.c

2258

mesh->num_query_authzone_up = 0;

usr.sbin/unbound/services/mesh.c

2259

mesh->num_query_authzone_down = 0;

usr.sbin/unbound/services/mesh.c

226

mesh->num_reply_states = 0;

usr.sbin/unbound/services/mesh.c

2260

mesh->replies_sent = 0;

usr.sbin/unbound/services/mesh.c

2261

mesh->replies_sum_wait.tv_sec = 0;

usr.sbin/unbound/services/mesh.c

2262

mesh->replies_sum_wait.tv_usec = 0;

usr.sbin/unbound/services/mesh.c

2263

mesh->stats_jostled = 0;

usr.sbin/unbound/services/mesh.c

2264

mesh->stats_dropped = 0;

usr.sbin/unbound/services/mesh.c

2265

timehist_clear(mesh->histogram);

usr.sbin/unbound/services/mesh.c

2266

mesh->ans_secure = 0;

usr.sbin/unbound/services/mesh.c

2267

mesh->ans_bogus = 0;

usr.sbin/unbound/services/mesh.c

2268

mesh->val_ops = 0;

usr.sbin/unbound/services/mesh.c

2269

mesh->ans_expired = 0;

usr.sbin/unbound/services/mesh.c

227

mesh->num_detached_states = 0;

usr.sbin/unbound/services/mesh.c

2270

mesh->ans_cachedb = 0;

usr.sbin/unbound/services/mesh.c

2271

memset(&mesh->ans_rcode[0], 0, sizeof(size_t)*UB_STATS_RCODE_NUM);

usr.sbin/unbound/services/mesh.c

2272

memset(&mesh->rpz_action[0], 0, sizeof(size_t)*UB_STATS_RPZ_ACTION_NUM);

usr.sbin/unbound/services/mesh.c

2273

mesh->ans_nodata = 0;

usr.sbin/unbound/services/mesh.c

2274

mesh->num_queries_discard_timeout = 0;

usr.sbin/unbound/services/mesh.c

2275

mesh->num_queries_wait_limit = 0;

usr.sbin/unbound/services/mesh.c

2276

mesh->num_dns_error_reports = 0;

usr.sbin/unbound/services/mesh.c

228

mesh->num_forever_states = 0;

usr.sbin/unbound/services/mesh.c

2280

mesh_get_mem(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

2283

size_t s = sizeof(*mesh) + sizeof(struct timehist) +

usr.sbin/unbound/services/mesh.c

2284

sizeof(struct th_buck)*mesh->histogram->num +

usr.sbin/unbound/services/mesh.c

2285

sizeof(sldns_buffer) + sldns_buffer_capacity(mesh->qbuf_bak);

usr.sbin/unbound/services/mesh.c

2286

RBTREE_FOR(m, struct mesh_state*, &mesh->all) {

usr.sbin/unbound/services/mesh.c

229

mesh->stats_jostled = 0;

usr.sbin/unbound/services/mesh.c

2297

struct mesh_area* mesh = qstate->env->mesh;

usr.sbin/unbound/services/mesh.c

2299

dep_m = mesh_area_find(mesh, NULL, qinfo, flags, prime, valrec);

usr.sbin/unbound/services/mesh.c

230

mesh->stats_dropped = 0;

usr.sbin/unbound/services/mesh.c

231

mesh->ans_expired = 0;

usr.sbin/unbound/services/mesh.c

232

mesh->ans_cachedb = 0;

usr.sbin/unbound/services/mesh.c

2326

void mesh_state_remove_reply(struct mesh_area* mesh, struct mesh_state* m,

usr.sbin/unbound/services/mesh.c

233

mesh->num_queries_discard_timeout = 0;

usr.sbin/unbound/services/mesh.c

234

mesh->num_queries_wait_limit = 0;

usr.sbin/unbound/services/mesh.c

2340

log_assert(mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

2341

mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

2342

infra_wait_limit_dec(mesh->env->infra_cache,

usr.sbin/unbound/services/mesh.c

2343

&n->query_reply, mesh->env->cfg);

usr.sbin/unbound/services/mesh.c

235

mesh->num_dns_error_reports = 0;

usr.sbin/unbound/services/mesh.c

2355

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

2359

log_assert(mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

236

mesh->max_reply_states = env->cfg->num_queries_per_thread;

usr.sbin/unbound/services/mesh.c

2360

mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

237

mesh->max_forever_states = (mesh->max_reply_states+1)/2;

usr.sbin/unbound/services/mesh.c

239

mesh->jostle_max.tv_sec = (time_t)(env->cfg->jostle_time / 1000);

usr.sbin/unbound/services/mesh.c

2398

struct mesh_area* mesh = qstate->env->mesh;

usr.sbin/unbound/services/mesh.c

240

mesh->jostle_max.tv_usec = (time_t)((env->cfg->jostle_time % 1000)

usr.sbin/unbound/services/mesh.c

243

return mesh;

usr.sbin/unbound/services/mesh.c

2446

if((mesh->use_response_ip || mesh->use_rpz) &&

usr.sbin/unbound/services/mesh.c

2513

mstate->s.env->mesh->num_queries_discard_timeout++;

usr.sbin/unbound/services/mesh.c

2554

mesh->ans_expired += i;

usr.sbin/unbound/services/mesh.c

2558

qstate->env->mesh->rpz_action[RPZ_DISABLED_ACTION] += i;

usr.sbin/unbound/services/mesh.c

2560

qstate->env->mesh->rpz_action[RPZ_CNAME_OVERRIDE_ACTION] += i;

usr.sbin/unbound/services/mesh.c

2562

qstate->env->mesh->rpz_action[

usr.sbin/unbound/services/mesh.c

2571

log_assert(mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

2572

mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

2574

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

2584

log_assert(qstate->env->mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

2585

qstate->env->mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

2590

qstate->env->mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

260

mesh_delete(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

2603

int mesh_jostle_exceeded(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

2605

if(mesh->all.count < mesh->max_reply_states)

usr.sbin/unbound/services/mesh.c

2610

void mesh_remove_callback(struct mesh_area* mesh, struct query_info* qinfo,

usr.sbin/unbound/services/mesh.c

2614

s = mesh_area_find(mesh, NULL, qinfo, qflags&(BIT_RD|BIT_CD), 0, 0);

usr.sbin/unbound/services/mesh.c

2619

log_assert(mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

262

if(!mesh)

usr.sbin/unbound/services/mesh.c

2620

mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

2623

log_assert(mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

2624

mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

2628

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

265

while(mesh->all.count)

usr.sbin/unbound/services/mesh.c

266

mesh_delete_helper(mesh->all.root);

usr.sbin/unbound/services/mesh.c

267

timehist_delete(mesh->histogram);

usr.sbin/unbound/services/mesh.c

268

sldns_buffer_free(mesh->qbuf_bak);

usr.sbin/unbound/services/mesh.c

269

free(mesh);

usr.sbin/unbound/services/mesh.c

273

mesh_delete_all(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

276

while(mesh->all.count)

usr.sbin/unbound/services/mesh.c

277

mesh_delete_helper(mesh->all.root);

usr.sbin/unbound/services/mesh.c

278

mesh->stats_dropped += mesh->num_reply_addrs;

usr.sbin/unbound/services/mesh.c

280

rbtree_init(&mesh->run, &mesh_state_compare);

usr.sbin/unbound/services/mesh.c

281

rbtree_init(&mesh->all, &mesh_state_compare);

usr.sbin/unbound/services/mesh.c

282

mesh->num_reply_addrs = 0;

usr.sbin/unbound/services/mesh.c

283

mesh->num_reply_states = 0;

usr.sbin/unbound/services/mesh.c

284

mesh->num_detached_states = 0;

usr.sbin/unbound/services/mesh.c

285

mesh->num_forever_states = 0;

usr.sbin/unbound/services/mesh.c

286

mesh->forever_first = NULL;

usr.sbin/unbound/services/mesh.c

287

mesh->forever_last = NULL;

usr.sbin/unbound/services/mesh.c

288

mesh->jostle_first = NULL;

usr.sbin/unbound/services/mesh.c

289

mesh->jostle_last = NULL;

usr.sbin/unbound/services/mesh.c

292

int mesh_make_new_space(struct mesh_area* mesh, sldns_buffer* qbuf)

usr.sbin/unbound/services/mesh.c

294

struct mesh_state* m = mesh->jostle_first;

usr.sbin/unbound/services/mesh.c

296

if(mesh->num_reply_states < mesh->max_reply_states)

usr.sbin/unbound/services/mesh.c

302

timeval_subtract(&age, mesh->env->now_tv,

usr.sbin/unbound/services/mesh.c

304

if(timeval_smaller(&mesh->jostle_max, &age)) {

usr.sbin/unbound/services/mesh.c

311

if(qbuf) sldns_buffer_copy(mesh->qbuf_bak, qbuf);

usr.sbin/unbound/services/mesh.c

317

mesh_walk_supers(mesh, m);

usr.sbin/unbound/services/mesh.c

319

mesh->stats_jostled ++;

usr.sbin/unbound/services/mesh.c

323

if(qbuf) sldns_buffer_copy(qbuf, mesh->qbuf_bak);

usr.sbin/unbound/services/mesh.c

424

void mesh_new_client(struct mesh_area* mesh, struct query_info* qinfo,

usr.sbin/unbound/services/mesh.c

430

int unique = unique_mesh_state(edns->opt_list_in, mesh->env);

usr.sbin/unbound/services/mesh.c

434

int timeout = mesh->env->cfg->serve_expired?

usr.sbin/unbound/services/mesh.c

435

mesh->env->cfg->serve_expired_client_timeout:0;

usr.sbin/unbound/services/mesh.c

441

if(!infra_wait_limit_allowed(mesh->env->infra_cache, rep,

usr.sbin/unbound/services/mesh.c

442

edns->cookie_valid, mesh->env->cfg)) {

usr.sbin/unbound/services/mesh.c

446

mesh->num_queries_wait_limit++;

usr.sbin/unbound/services/mesh.c

450

s = mesh_area_find(mesh, cinfo, qinfo, mesh_flags, 0, 0);

usr.sbin/unbound/services/mesh.c

453

if(!mesh_make_new_space(mesh, rep->c->buffer)) {

usr.sbin/unbound/services/mesh.c

457

mesh->stats_dropped++;

usr.sbin/unbound/services/mesh.c

464

if(mesh->num_reply_addrs > mesh->max_reply_states*16) {

usr.sbin/unbound/services/mesh.c

468

mesh->stats_dropped++;

usr.sbin/unbound/services/mesh.c

477

s = mesh_state_create(mesh->env, qinfo, cinfo,

usr.sbin/unbound/services/mesh.c

481

if(!inplace_cb_reply_servfail_call(mesh->env, qinfo, NULL, NULL,

usr.sbin/unbound/services/mesh.c

482

LDNS_RCODE_SERVFAIL, edns, rep, mesh->env->scratch, mesh->env->now_tv))

usr.sbin/unbound/services/mesh.c

490

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

500

if(!inplace_cb_reply_servfail_call(mesh->env, qinfo, NULL,

usr.sbin/unbound/services/mesh.c

501

NULL, LDNS_RCODE_SERVFAIL, edns, rep, mesh->env->scratch, mesh->env->now_tv))

usr.sbin/unbound/services/mesh.c

516

rbtree_insert(&mesh->all, &s->node);

usr.sbin/unbound/services/mesh.c

532

if(!tcp_req_info_add_meshstate(rep->c->tcp_req_info, mesh, s)) {

usr.sbin/unbound/services/mesh.c

538

http2_stream_add_meshstate(rep->c->h2_stream, mesh, s);

usr.sbin/unbound/services/mesh.c

546

if(!timeout && mesh->env->cfg->serve_expired &&

usr.sbin/unbound/services/mesh.c

547

!mesh->env->cfg->serve_expired_client_timeout &&

usr.sbin/unbound/services/mesh.c

548

(mesh->env->cachedb_enabled &&

usr.sbin/unbound/services/mesh.c

549

mesh->env->cfg->cachedb_check_when_serve_expired)) {

usr.sbin/unbound/services/mesh.c

556

infra_wait_limit_inc(mesh->env->infra_cache, rep, *mesh->env->now,

usr.sbin/unbound/services/mesh.c

557

mesh->env->cfg);

usr.sbin/unbound/services/mesh.c

560

log_assert(mesh->num_detached_states > 0);

usr.sbin/unbound/services/mesh.c

561

mesh->num_detached_states--;

usr.sbin/unbound/services/mesh.c

564

mesh->num_reply_states ++;

usr.sbin/unbound/services/mesh.c

566

mesh->num_reply_addrs++;

usr.sbin/unbound/services/mesh.c

569

if(mesh->num_forever_states < mesh->max_forever_states) {

usr.sbin/unbound/services/mesh.c

570

mesh->num_forever_states ++;

usr.sbin/unbound/services/mesh.c

571

mesh_list_insert(s, &mesh->forever_first,

usr.sbin/unbound/services/mesh.c

572

&mesh->forever_last);

usr.sbin/unbound/services/mesh.c

575

mesh_list_insert(s, &mesh->jostle_first,

usr.sbin/unbound/services/mesh.c

576

&mesh->jostle_last);

usr.sbin/unbound/services/mesh.c

581

mesh_run(mesh, s, module_event_new, NULL);

usr.sbin/unbound/services/mesh.c

585

if(!inplace_cb_reply_servfail_call(mesh->env, qinfo, &s->s,

usr.sbin/unbound/services/mesh.c

586

NULL, LDNS_RCODE_SERVFAIL, edns, rep, mesh->env->scratch, mesh->env->now_tv))

usr.sbin/unbound/services/mesh.c

599

mesh_new_callback(struct mesh_area* mesh, struct query_info* qinfo,

usr.sbin/unbound/services/mesh.c

604

int unique = unique_mesh_state(edns->opt_list_in, mesh->env);

usr.sbin/unbound/services/mesh.c

605

int timeout = mesh->env->cfg->serve_expired?

usr.sbin/unbound/services/mesh.c

606

mesh->env->cfg->serve_expired_client_timeout:0;

usr.sbin/unbound/services/mesh.c

612

s = mesh_area_find(mesh, NULL, qinfo, mesh_flags, 0, 0);

usr.sbin/unbound/services/mesh.c

621

s = mesh_state_create(mesh->env, qinfo, NULL,

usr.sbin/unbound/services/mesh.c

627

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

644

rbtree_insert(&mesh->all, &s->node);

usr.sbin/unbound/services/mesh.c

667

if(!timeout && mesh->env->cfg->serve_expired &&

usr.sbin/unbound/services/mesh.c

668

!mesh->env->cfg->serve_expired_client_timeout &&

usr.sbin/unbound/services/mesh.c

669

(mesh->env->cachedb_enabled &&

usr.sbin/unbound/services/mesh.c

670

mesh->env->cfg->cachedb_check_when_serve_expired)) {

usr.sbin/unbound/services/mesh.c

680

log_assert(mesh->num_detached_states > 0);

usr.sbin/unbound/services/mesh.c

681

mesh->num_detached_states--;

usr.sbin/unbound/services/mesh.c

684

mesh->num_reply_states ++;

usr.sbin/unbound/services/mesh.c

686

mesh->num_reply_addrs++;

usr.sbin/unbound/services/mesh.c

688

mesh_run(mesh, s, module_event_new, NULL);

usr.sbin/unbound/services/mesh.c

697

static void mesh_schedule_prefetch(struct mesh_area* mesh,

usr.sbin/unbound/services/mesh.c

705

struct mesh_state* s = mesh_area_find(mesh, NULL, qinfo,

usr.sbin/unbound/services/mesh.c

720

if(!mesh_make_new_space(mesh, NULL)) {

usr.sbin/unbound/services/mesh.c

722

mesh->stats_dropped ++;

usr.sbin/unbound/services/mesh.c

726

s = mesh_state_create(mesh->env, qinfo, NULL, mesh_flags, 0, 0);

usr.sbin/unbound/services/mesh.c

736

rbtree_insert(&mesh->all, &s->node);

usr.sbin/unbound/services/mesh.c

739

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

746

if(mesh->num_forever_states < mesh->max_forever_states) {

usr.sbin/unbound/services/mesh.c

747

mesh->num_forever_states ++;

usr.sbin/unbound/services/mesh.c

748

mesh_list_insert(s, &mesh->forever_first,

usr.sbin/unbound/services/mesh.c

749

&mesh->forever_last);

usr.sbin/unbound/services/mesh.c

752

mesh_list_insert(s, &mesh->jostle_first,

usr.sbin/unbound/services/mesh.c

753

&mesh->jostle_last);

usr.sbin/unbound/services/mesh.c

765

rbtree_insert(&mesh->run, &s->run_node);

usr.sbin/unbound/services/mesh.c

770

mesh_run(mesh, s, module_event_new, NULL);

usr.sbin/unbound/services/mesh.c

778

static void mesh_schedule_prefetch_subnet(struct mesh_area* mesh,

usr.sbin/unbound/services/mesh.c

791

if(!mesh_make_new_space(mesh, NULL)) {

usr.sbin/unbound/services/mesh.c

793

mesh->stats_dropped ++;

usr.sbin/unbound/services/mesh.c

797

s = mesh_state_create(mesh->env, qinfo, NULL, mesh_flags, 0, 0);

usr.sbin/unbound/services/mesh.c

804

opt = edns_opt_list_find(edns_list, mesh->env->cfg->client_subnet_opcode);

usr.sbin/unbound/services/mesh.c

823

rbtree_insert(&mesh->all, &s->node);

usr.sbin/unbound/services/mesh.c

826

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

833

if(mesh->num_forever_states < mesh->max_forever_states) {

usr.sbin/unbound/services/mesh.c

834

mesh->num_forever_states ++;

usr.sbin/unbound/services/mesh.c

835

mesh_list_insert(s, &mesh->forever_first,

usr.sbin/unbound/services/mesh.c

836

&mesh->forever_last);

usr.sbin/unbound/services/mesh.c

839

mesh_list_insert(s, &mesh->jostle_first,

usr.sbin/unbound/services/mesh.c

840

&mesh->jostle_last);

usr.sbin/unbound/services/mesh.c

852

rbtree_insert(&mesh->run, &s->run_node);

usr.sbin/unbound/services/mesh.c

857

mesh_run(mesh, s, module_event_new, NULL);

usr.sbin/unbound/services/mesh.c

861

void mesh_new_prefetch(struct mesh_area* mesh, struct query_info* qinfo,

usr.sbin/unbound/services/mesh.c

869

mesh_schedule_prefetch_subnet(mesh, qinfo, qflags, leeway, 1,

usr.sbin/unbound/services/mesh.c

873

mesh_schedule_prefetch(mesh, qinfo, qflags, leeway, 1,

usr.sbin/unbound/services/mesh.c

877

void mesh_report_reply(struct mesh_area* mesh, struct outbound_entry* e,

usr.sbin/unbound/services/mesh.c

887

mesh_run(mesh, e->qstate->mesh_info, event, e);

usr.sbin/unbound/services/mesh.h

297

void mesh_delete(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

317

void mesh_new_client(struct mesh_area* mesh, struct query_info* qinfo,

usr.sbin/unbound/services/mesh.h

339

int mesh_new_callback(struct mesh_area* mesh, struct query_info* qinfo,

usr.sbin/unbound/services/mesh.h

357

void mesh_new_prefetch(struct mesh_area* mesh, struct query_info* qinfo,

usr.sbin/unbound/services/mesh.h

371

void mesh_report_reply(struct mesh_area* mesh, struct outbound_entry* e,

usr.sbin/unbound/services/mesh.h

469

void mesh_walk_supers(struct mesh_area* mesh, struct mesh_state* mstate);

usr.sbin/unbound/services/mesh.h

515

void mesh_delete_all(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

529

struct mesh_state* mesh_area_find(struct mesh_area* mesh,

usr.sbin/unbound/services/mesh.h

583

void mesh_run(struct mesh_area* mesh, struct mesh_state* mstate,

usr.sbin/unbound/services/mesh.h

591

void mesh_stats(struct mesh_area* mesh, const char* str);

usr.sbin/unbound/services/mesh.h

597

void mesh_stats_clear(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

603

void mesh_log_list(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

610

size_t mesh_get_mem(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

647

int mesh_make_new_space(struct mesh_area* mesh, struct sldns_buffer* qbuf);

usr.sbin/unbound/services/mesh.h

674

void mesh_state_remove_reply(struct mesh_area* mesh, struct mesh_state* m,

usr.sbin/unbound/services/mesh.h

705

int mesh_jostle_exceeded(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

723

void mesh_remove_callback(struct mesh_area* mesh, struct query_info* qinfo,

usr.sbin/unbound/services/modstack.c

337

int m = modstack_find(&env->mesh->mods, name);

usr.sbin/unbound/services/modstack.c

339

fptr_ok(fptr_whitelist_mod_get_mem(env->mesh->

usr.sbin/unbound/services/modstack.c

341

return (*env->mesh->mods.mod[m]->get_mem)(env, m);

usr.sbin/unbound/testcode/fake_event.c

1984

struct mesh_area* ATTR_UNUSED(mesh), struct mesh_state* ATTR_UNUSED(m))

usr.sbin/unbound/testcode/fake_event.c

2016

struct mesh_area* ATTR_UNUSED(mesh), struct mesh_state* ATTR_UNUSED(m))

usr.sbin/unbound/testcode/unitzonemd.c

296

env.mesh = mesh_create(&mods, &env);

usr.sbin/unbound/testcode/unitzonemd.c

297

if(!env.mesh)

usr.sbin/unbound/testcode/unitzonemd.c

332

mesh_delete(env.mesh);

usr.sbin/unbound/util/module.h

493

struct mesh_area* mesh;

usr.sbin/unbound/util/netevent.c

3174

mesh_state_remove_reply(h2_stream->mesh, h2_stream->mesh_state,

usr.sbin/unbound/util/netevent.c

5105

struct mesh_area* mesh, struct mesh_state* m)

usr.sbin/unbound/util/netevent.c

5107

h2_stream->mesh = mesh;

usr.sbin/unbound/util/netevent.h

1031

struct mesh_area* mesh, struct mesh_state* m);

usr.sbin/unbound/util/netevent.h

995

struct mesh_area* mesh;

usr.sbin/unbound/validator/autotrust.c

2418

if(!mesh_new_callback(env->mesh, &qinfo, qflags, &edns, buf, 0,

usr.sbin/unbound/validator/val_sigcrypt.c

1683

if(qstate && qstate->env && qstate->env->mesh)

usr.sbin/unbound/validator/val_sigcrypt.c

1684

qstate->env->mesh->val_ops++;

usr.sbin/unbound/validator/validator.c

840

mesh_run(qstate->env->mesh, qstate->mesh_info, module_event_pass,

usr.sbin/unbound/validator/validator.c

879

if(qstate->env->mesh->all.count >= qstate->env->mesh->max_reply_states)

usr.sbin/unbound/validator/validator.c

881

else if(qstate->env->mesh->all.count >= qstate->env->mesh->max_reply_states/2)

usr.sbin/unbound/validator/validator.c

883

else if(qstate->env->mesh->all.count >= qstate->env->mesh->max_reply_states/4)