sbin/unwind/libunbound/iterator/iterator.c

1320

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

sbin/unwind/libunbound/iterator/iterator.c

2102

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

sbin/unwind/libunbound/iterator/iterator.c

2127

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

sbin/unwind/libunbound/iterator/iterator.c

2313

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

sbin/unwind/libunbound/iterator/iterator.c

2762

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

sbin/unwind/libunbound/iterator/iterator.c

2801

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

sbin/unwind/libunbound/libunbound/libworker.c

251

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

sbin/unwind/libunbound/libunbound/libworker.c

252

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

sbin/unwind/libunbound/libunbound/libworker.c

653

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

sbin/unwind/libunbound/libunbound/libworker.c

734

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

sbin/unwind/libunbound/libunbound/libworker.c

872

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

sbin/unwind/libunbound/libunbound/libworker.c

918

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

sbin/unwind/libunbound/libunbound/libworker.c

928

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

sbin/unwind/libunbound/libunbound/libworker.c

932

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

3636

env->mesh->num_query_authzone_down++;

sbin/unwind/libunbound/services/authzone.c

3649

env->mesh->num_query_authzone_down++;

sbin/unwind/libunbound/services/authzone.c

5399

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

sbin/unwind/libunbound/services/authzone.c

5518

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

sbin/unwind/libunbound/services/authzone.c

6721

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

sbin/unwind/libunbound/services/authzone.c

8482

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

sbin/unwind/libunbound/services/authzone.c

8496

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

sbin/unwind/libunbound/services/authzone.c

8563

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

sbin/unwind/libunbound/services/authzone.c

8673

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

sbin/unwind/libunbound/services/listen_dnsport.c

2169

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

sbin/unwind/libunbound/services/listen_dnsport.c

2381

struct mesh_area* mesh, struct mesh_state* m)

sbin/unwind/libunbound/services/listen_dnsport.c

2384

log_assert(req && mesh && m);

sbin/unwind/libunbound/services/listen_dnsport.c

2388

item->mesh = mesh;

sbin/unwind/libunbound/services/listen_dnsport.c

3619

mesh_state_remove_reply(stream->mesh, stream->mesh_state,

sbin/unwind/libunbound/services/listen_dnsport.c

3958

mesh_state_remove_reply(stream->mesh, stream->mesh_state,

sbin/unwind/libunbound/services/listen_dnsport.c

4044

struct mesh_area* mesh, struct mesh_state* m)

sbin/unwind/libunbound/services/listen_dnsport.c

4047

stream->mesh = mesh;

sbin/unwind/libunbound/services/listen_dnsport.c

4050

(void)stream; (void)mesh; (void)m;

sbin/unwind/libunbound/services/listen_dnsport.h

359

struct mesh_area* mesh;

sbin/unwind/libunbound/services/listen_dnsport.h

432

struct mesh_area* mesh, struct mesh_state* m);

sbin/unwind/libunbound/services/listen_dnsport.h

699

struct mesh_area* mesh;

sbin/unwind/libunbound/services/listen_dnsport.h

808

struct mesh_area* mesh, struct mesh_state* m);

sbin/unwind/libunbound/services/mesh.c

1057

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

sbin/unwind/libunbound/services/mesh.c

1079

struct mesh_area* mesh;

sbin/unwind/libunbound/services/mesh.c

1083

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

sbin/unwind/libunbound/services/mesh.c

1106

infra_wait_limit_dec(mesh->env->infra_cache,

sbin/unwind/libunbound/services/mesh.c

1107

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

sbin/unwind/libunbound/services/mesh.c

1109

log_assert(mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

1110

mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

1117

log_assert(mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

1118

mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

1123

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

sbin/unwind/libunbound/services/mesh.c

1124

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

sbin/unwind/libunbound/services/mesh.c

1125

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

sbin/unwind/libunbound/services/mesh.c

1135

struct mesh_area* mesh;

sbin/unwind/libunbound/services/mesh.c

1141

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

sbin/unwind/libunbound/services/mesh.c

1144

mesh->num_forever_states --;

sbin/unwind/libunbound/services/mesh.c

1145

mesh_list_remove(mstate, &mesh->forever_first,

sbin/unwind/libunbound/services/mesh.c

1146

&mesh->forever_last);

sbin/unwind/libunbound/services/mesh.c

1148

mesh_list_remove(mstate, &mesh->jostle_first,

sbin/unwind/libunbound/services/mesh.c

1149

&mesh->jostle_last);

sbin/unwind/libunbound/services/mesh.c

1153

log_assert(mesh->num_detached_states > 0);

sbin/unwind/libunbound/services/mesh.c

1154

mesh->num_detached_states--;

sbin/unwind/libunbound/services/mesh.c

1157

log_assert(mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

1158

mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

1165

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

sbin/unwind/libunbound/services/mesh.c

1166

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

sbin/unwind/libunbound/services/mesh.c

1201

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

sbin/unwind/libunbound/services/mesh.c

1218

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

1219

log_assert(mesh->num_detached_states +

sbin/unwind/libunbound/services/mesh.c

1220

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

sbin/unwind/libunbound/services/mesh.c

1231

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

sbin/unwind/libunbound/services/mesh.c

1232

*sub = mesh_area_find(mesh, cinfo, qinfo, qflags, prime, valrec);

sbin/unwind/libunbound/services/mesh.c

1249

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

sbin/unwind/libunbound/services/mesh.c

1252

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

1259

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

sbin/unwind/libunbound/services/mesh.c

1276

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

sbin/unwind/libunbound/services/mesh.c

1289

log_assert(mesh->num_detached_states > 0);

sbin/unwind/libunbound/services/mesh.c

1290

mesh->num_detached_states--;

sbin/unwind/libunbound/services/mesh.c

1403

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

sbin/unwind/libunbound/services/mesh.c

1404

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

sbin/unwind/libunbound/services/mesh.c

1486

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

sbin/unwind/libunbound/services/mesh.c

1599

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

sbin/unwind/libunbound/services/mesh.c

1600

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

sbin/unwind/libunbound/services/mesh.c

1605

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

sbin/unwind/libunbound/services/mesh.c

1606

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

sbin/unwind/libunbound/services/mesh.c

1607

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

sbin/unwind/libunbound/services/mesh.c

1611

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

sbin/unwind/libunbound/services/mesh.c

1612

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

sbin/unwind/libunbound/services/mesh.c

1614

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

sbin/unwind/libunbound/services/mesh.c

1728

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

sbin/unwind/libunbound/services/mesh.c

1800

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

sbin/unwind/libunbound/services/mesh.c

1801

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

sbin/unwind/libunbound/services/mesh.c

1802

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

sbin/unwind/libunbound/services/mesh.c

1840

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

sbin/unwind/libunbound/services/mesh.c

1841

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

sbin/unwind/libunbound/services/mesh.c

1866

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

sbin/unwind/libunbound/services/mesh.c

1868

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

sbin/unwind/libunbound/services/mesh.c

1870

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

sbin/unwind/libunbound/services/mesh.c

1876

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

sbin/unwind/libunbound/services/mesh.c

1885

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

sbin/unwind/libunbound/services/mesh.c

1886

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

sbin/unwind/libunbound/services/mesh.c

1890

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

sbin/unwind/libunbound/services/mesh.c

1899

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

sbin/unwind/libunbound/services/mesh.c

1900

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

sbin/unwind/libunbound/services/mesh.c

1905

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

sbin/unwind/libunbound/services/mesh.c

1910

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

sbin/unwind/libunbound/services/mesh.c

1916

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

sbin/unwind/libunbound/services/mesh.c

1919

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

sbin/unwind/libunbound/services/mesh.c

1920

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

sbin/unwind/libunbound/services/mesh.c

1927

struct mesh_state* mesh_area_find(struct mesh_area* mesh,

sbin/unwind/libunbound/services/mesh.c

1945

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

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

2121

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

sbin/unwind/libunbound/services/mesh.c

2128

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

sbin/unwind/libunbound/services/mesh.c

2136

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

sbin/unwind/libunbound/services/mesh.c

214

mesh->histogram = timehist_setup();

sbin/unwind/libunbound/services/mesh.c

2141

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

sbin/unwind/libunbound/services/mesh.c

2145

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

sbin/unwind/libunbound/services/mesh.c

2148

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

sbin/unwind/libunbound/services/mesh.c

2149

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

sbin/unwind/libunbound/services/mesh.c

215

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

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

2170

mesh_walk_supers(mesh, mstate);

sbin/unwind/libunbound/services/mesh.c

2185

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

sbin/unwind/libunbound/services/mesh.c

2193

mesh_walk_supers(mesh, mstate);

sbin/unwind/libunbound/services/mesh.c

221

mesh->mods = *stack;

sbin/unwind/libunbound/services/mesh.c

2217

mesh_new_prefetch(mesh, qinfo, qflags, 0,

sbin/unwind/libunbound/services/mesh.c

222

mesh->env = env;

sbin/unwind/libunbound/services/mesh.c

223

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

sbin/unwind/libunbound/services/mesh.c

2234

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

sbin/unwind/libunbound/services/mesh.c

224

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

sbin/unwind/libunbound/services/mesh.c

2242

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

sbin/unwind/libunbound/services/mesh.c

2243

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

sbin/unwind/libunbound/services/mesh.c

225

mesh->num_reply_addrs = 0;

sbin/unwind/libunbound/services/mesh.c

2251

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

sbin/unwind/libunbound/services/mesh.c

2253

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

sbin/unwind/libunbound/services/mesh.c

2258

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

sbin/unwind/libunbound/services/mesh.c

226

mesh->num_reply_states = 0;

sbin/unwind/libunbound/services/mesh.c

2260

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

sbin/unwind/libunbound/services/mesh.c

2261

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

sbin/unwind/libunbound/services/mesh.c

2265

mesh_stats(mesh, "mesh_run: end");

sbin/unwind/libunbound/services/mesh.c

2266

mesh_log_list(mesh);

sbin/unwind/libunbound/services/mesh.c

227

mesh->num_detached_states = 0;

sbin/unwind/libunbound/services/mesh.c

2271

mesh_log_list(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

2276

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

sbin/unwind/libunbound/services/mesh.c

228

mesh->num_forever_states = 0;

sbin/unwind/libunbound/services/mesh.c

229

mesh->stats_jostled = 0;

sbin/unwind/libunbound/services/mesh.c

2292

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

sbin/unwind/libunbound/services/mesh.c

2297

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

sbin/unwind/libunbound/services/mesh.c

2298

(unsigned)mesh->num_reply_states,

sbin/unwind/libunbound/services/mesh.c

2299

(unsigned)mesh->num_detached_states,

sbin/unwind/libunbound/services/mesh.c

230

mesh->stats_dropped = 0;

sbin/unwind/libunbound/services/mesh.c

2300

(unsigned)mesh->num_reply_addrs,

sbin/unwind/libunbound/services/mesh.c

2301

(unsigned)mesh->replies_sent,

sbin/unwind/libunbound/services/mesh.c

2302

(unsigned)mesh->stats_dropped,

sbin/unwind/libunbound/services/mesh.c

2303

(unsigned)mesh->stats_jostled);

sbin/unwind/libunbound/services/mesh.c

2304

if(mesh->replies_sent > 0) {

sbin/unwind/libunbound/services/mesh.c

2306

timeval_divide(&avg, &mesh->replies_sum_wait,

sbin/unwind/libunbound/services/mesh.c

2307

mesh->replies_sent);

sbin/unwind/libunbound/services/mesh.c

231

mesh->ans_expired = 0;

sbin/unwind/libunbound/services/mesh.c

2312

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

sbin/unwind/libunbound/services/mesh.c

2317

mesh_stats_clear(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

2319

if(!mesh)

sbin/unwind/libunbound/services/mesh.c

232

mesh->ans_cachedb = 0;

sbin/unwind/libunbound/services/mesh.c

2321

mesh->num_query_authzone_up = 0;

sbin/unwind/libunbound/services/mesh.c

2322

mesh->num_query_authzone_down = 0;

sbin/unwind/libunbound/services/mesh.c

2323

mesh->replies_sent = 0;

sbin/unwind/libunbound/services/mesh.c

2324

mesh->replies_sum_wait.tv_sec = 0;

sbin/unwind/libunbound/services/mesh.c

2325

mesh->replies_sum_wait.tv_usec = 0;

sbin/unwind/libunbound/services/mesh.c

2326

mesh->stats_jostled = 0;

sbin/unwind/libunbound/services/mesh.c

2327

mesh->stats_dropped = 0;

sbin/unwind/libunbound/services/mesh.c

2328

timehist_clear(mesh->histogram);

sbin/unwind/libunbound/services/mesh.c

2329

mesh->ans_secure = 0;

sbin/unwind/libunbound/services/mesh.c

233

mesh->num_queries_discard_timeout = 0;

sbin/unwind/libunbound/services/mesh.c

2330

mesh->ans_bogus = 0;

sbin/unwind/libunbound/services/mesh.c

2331

mesh->val_ops = 0;

sbin/unwind/libunbound/services/mesh.c

2332

mesh->ans_expired = 0;

sbin/unwind/libunbound/services/mesh.c

2333

mesh->ans_cachedb = 0;

sbin/unwind/libunbound/services/mesh.c

2334

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

sbin/unwind/libunbound/services/mesh.c

2335

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

sbin/unwind/libunbound/services/mesh.c

2336

mesh->ans_nodata = 0;

sbin/unwind/libunbound/services/mesh.c

2337

mesh->num_queries_discard_timeout = 0;

sbin/unwind/libunbound/services/mesh.c

2338

mesh->num_queries_replyaddr_limit = 0;

sbin/unwind/libunbound/services/mesh.c

2339

mesh->num_queries_wait_limit = 0;

sbin/unwind/libunbound/services/mesh.c

234

mesh->num_queries_replyaddr_limit = 0;

sbin/unwind/libunbound/services/mesh.c

2340

mesh->num_dns_error_reports = 0;

sbin/unwind/libunbound/services/mesh.c

2344

mesh_get_mem(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

2347

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

sbin/unwind/libunbound/services/mesh.c

2348

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

sbin/unwind/libunbound/services/mesh.c

2349

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

sbin/unwind/libunbound/services/mesh.c

235

mesh->num_queries_wait_limit = 0;

sbin/unwind/libunbound/services/mesh.c

2350

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

sbin/unwind/libunbound/services/mesh.c

236

mesh->num_dns_error_reports = 0;

sbin/unwind/libunbound/services/mesh.c

2361

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

sbin/unwind/libunbound/services/mesh.c

2363

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

sbin/unwind/libunbound/services/mesh.c

237

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

sbin/unwind/libunbound/services/mesh.c

238

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

sbin/unwind/libunbound/services/mesh.c

2390

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

sbin/unwind/libunbound/services/mesh.c

240

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

sbin/unwind/libunbound/services/mesh.c

2405

log_assert(mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

2406

mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

2407

infra_wait_limit_dec(mesh->env->infra_cache,

sbin/unwind/libunbound/services/mesh.c

2408

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

sbin/unwind/libunbound/services/mesh.c

241

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

sbin/unwind/libunbound/services/mesh.c

2428

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

2432

log_assert(mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

2433

mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

244

return mesh;

sbin/unwind/libunbound/services/mesh.c

2472

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

sbin/unwind/libunbound/services/mesh.c

2520

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

sbin/unwind/libunbound/services/mesh.c

2594

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

sbin/unwind/libunbound/services/mesh.c

2595

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

sbin/unwind/libunbound/services/mesh.c

2596

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

sbin/unwind/libunbound/services/mesh.c

261

mesh_delete(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

263

if(!mesh)

sbin/unwind/libunbound/services/mesh.c

2638

mesh->ans_expired += i;

sbin/unwind/libunbound/services/mesh.c

2642

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

sbin/unwind/libunbound/services/mesh.c

2644

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

sbin/unwind/libunbound/services/mesh.c

2646

qstate->env->mesh->rpz_action[

sbin/unwind/libunbound/services/mesh.c

2655

log_assert(mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

2656

mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

2658

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

266

while(mesh->all.count)

sbin/unwind/libunbound/services/mesh.c

2668

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

sbin/unwind/libunbound/services/mesh.c

2669

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

sbin/unwind/libunbound/services/mesh.c

267

mesh_delete_helper(mesh->all.root);

sbin/unwind/libunbound/services/mesh.c

2674

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

sbin/unwind/libunbound/services/mesh.c

268

timehist_delete(mesh->histogram);

sbin/unwind/libunbound/services/mesh.c

2687

int mesh_jostle_exceeded(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

2689

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

sbin/unwind/libunbound/services/mesh.c

269

sldns_buffer_free(mesh->qbuf_bak);

sbin/unwind/libunbound/services/mesh.c

2694

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

sbin/unwind/libunbound/services/mesh.c

2698

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

sbin/unwind/libunbound/services/mesh.c

270

free(mesh);

sbin/unwind/libunbound/services/mesh.c

2703

log_assert(mesh->num_reply_addrs > 0);

sbin/unwind/libunbound/services/mesh.c

2704

mesh->num_reply_addrs--;

sbin/unwind/libunbound/services/mesh.c

2707

log_assert(mesh->num_reply_states > 0);

sbin/unwind/libunbound/services/mesh.c

2708

mesh->num_reply_states--;

sbin/unwind/libunbound/services/mesh.c

2712

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

274

mesh_delete_all(struct mesh_area* mesh)

sbin/unwind/libunbound/services/mesh.c

277

while(mesh->all.count)

sbin/unwind/libunbound/services/mesh.c

278

mesh_delete_helper(mesh->all.root);

sbin/unwind/libunbound/services/mesh.c

279

mesh->stats_dropped += mesh->num_reply_addrs;

sbin/unwind/libunbound/services/mesh.c

281

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

sbin/unwind/libunbound/services/mesh.c

282

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

sbin/unwind/libunbound/services/mesh.c

283

mesh->num_reply_addrs = 0;

sbin/unwind/libunbound/services/mesh.c

284

mesh->num_reply_states = 0;

sbin/unwind/libunbound/services/mesh.c

285

mesh->num_detached_states = 0;

sbin/unwind/libunbound/services/mesh.c

286

mesh->num_forever_states = 0;

sbin/unwind/libunbound/services/mesh.c

287

mesh->forever_first = NULL;

sbin/unwind/libunbound/services/mesh.c

288

mesh->forever_last = NULL;

sbin/unwind/libunbound/services/mesh.c

289

mesh->jostle_first = NULL;

sbin/unwind/libunbound/services/mesh.c

290

mesh->jostle_last = NULL;

sbin/unwind/libunbound/services/mesh.c

293

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

sbin/unwind/libunbound/services/mesh.c

295

struct mesh_state* m = mesh->jostle_first;

sbin/unwind/libunbound/services/mesh.c

297

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

sbin/unwind/libunbound/services/mesh.c

304

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

sbin/unwind/libunbound/services/mesh.c

307

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

sbin/unwind/libunbound/services/mesh.c

314

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

sbin/unwind/libunbound/services/mesh.c

320

mesh_walk_supers(mesh, m);

sbin/unwind/libunbound/services/mesh.c

322

mesh->stats_jostled ++;

sbin/unwind/libunbound/services/mesh.c

326

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

sbin/unwind/libunbound/services/mesh.c

427

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

sbin/unwind/libunbound/services/mesh.c

433

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

sbin/unwind/libunbound/services/mesh.c

437

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

sbin/unwind/libunbound/services/mesh.c

438

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

sbin/unwind/libunbound/services/mesh.c

444

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

sbin/unwind/libunbound/services/mesh.c

445

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

sbin/unwind/libunbound/services/mesh.c

448

mesh->num_queries_wait_limit++;

sbin/unwind/libunbound/services/mesh.c

450

mesh->env->scratch, LDNS_EDE_OTHER,

sbin/unwind/libunbound/services/mesh.c

452

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

sbin/unwind/libunbound/services/mesh.c

453

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

sbin/unwind/libunbound/services/mesh.c

457

regional_free_all(mesh->env->scratch);

sbin/unwind/libunbound/services/mesh.c

462

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

sbin/unwind/libunbound/services/mesh.c

465

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

sbin/unwind/libunbound/services/mesh.c

473

mesh->stats_dropped++;

sbin/unwind/libunbound/services/mesh.c

480

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

sbin/unwind/libunbound/services/mesh.c

488

mesh->num_queries_replyaddr_limit++;

sbin/unwind/libunbound/services/mesh.c

497

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

sbin/unwind/libunbound/services/mesh.c

501

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

sbin/unwind/libunbound/services/mesh.c

502

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

sbin/unwind/libunbound/services/mesh.c

510

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

520

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

sbin/unwind/libunbound/services/mesh.c

521

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

sbin/unwind/libunbound/services/mesh.c

536

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

sbin/unwind/libunbound/services/mesh.c

552

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

sbin/unwind/libunbound/services/mesh.c

558

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

sbin/unwind/libunbound/services/mesh.c

560

doq_stream_add_meshstate(rep->doq_stream, mesh, s);

sbin/unwind/libunbound/services/mesh.c

568

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

sbin/unwind/libunbound/services/mesh.c

569

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

sbin/unwind/libunbound/services/mesh.c

570

(mesh->env->cachedb_enabled &&

sbin/unwind/libunbound/services/mesh.c

571

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

sbin/unwind/libunbound/services/mesh.c

578

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

sbin/unwind/libunbound/services/mesh.c

579

mesh->env->cfg);

sbin/unwind/libunbound/services/mesh.c

582

log_assert(mesh->num_detached_states > 0);

sbin/unwind/libunbound/services/mesh.c

583

mesh->num_detached_states--;

sbin/unwind/libunbound/services/mesh.c

586

mesh->num_reply_states ++;

sbin/unwind/libunbound/services/mesh.c

588

mesh->num_reply_addrs++;

sbin/unwind/libunbound/services/mesh.c

591

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

sbin/unwind/libunbound/services/mesh.c

592

mesh->num_forever_states ++;

sbin/unwind/libunbound/services/mesh.c

593

mesh_list_insert(s, &mesh->forever_first,

sbin/unwind/libunbound/services/mesh.c

594

&mesh->forever_last);

sbin/unwind/libunbound/services/mesh.c

597

mesh_list_insert(s, &mesh->jostle_first,

sbin/unwind/libunbound/services/mesh.c

598

&mesh->jostle_last);

sbin/unwind/libunbound/services/mesh.c

603

mesh_run(mesh, s, module_event_new, NULL);

sbin/unwind/libunbound/services/mesh.c

607

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

sbin/unwind/libunbound/services/mesh.c

608

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

sbin/unwind/libunbound/services/mesh.c

623

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

sbin/unwind/libunbound/services/mesh.c

628

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

sbin/unwind/libunbound/services/mesh.c

629

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

sbin/unwind/libunbound/services/mesh.c

630

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

sbin/unwind/libunbound/services/mesh.c

636

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

sbin/unwind/libunbound/services/mesh.c

645

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

sbin/unwind/libunbound/services/mesh.c

651

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

668

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

sbin/unwind/libunbound/services/mesh.c

691

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

sbin/unwind/libunbound/services/mesh.c

692

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

sbin/unwind/libunbound/services/mesh.c

693

(mesh->env->cachedb_enabled &&

sbin/unwind/libunbound/services/mesh.c

694

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

sbin/unwind/libunbound/services/mesh.c

704

log_assert(mesh->num_detached_states > 0);

sbin/unwind/libunbound/services/mesh.c

705

mesh->num_detached_states--;

sbin/unwind/libunbound/services/mesh.c

708

mesh->num_reply_states ++;

sbin/unwind/libunbound/services/mesh.c

710

mesh->num_reply_addrs++;

sbin/unwind/libunbound/services/mesh.c

712

mesh_run(mesh, s, module_event_new, NULL);

sbin/unwind/libunbound/services/mesh.c

721

static void mesh_schedule_prefetch(struct mesh_area* mesh,

sbin/unwind/libunbound/services/mesh.c

729

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

sbin/unwind/libunbound/services/mesh.c

744

if(!mesh_make_new_space(mesh, NULL)) {

sbin/unwind/libunbound/services/mesh.c

746

mesh->stats_dropped ++;

sbin/unwind/libunbound/services/mesh.c

750

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

sbin/unwind/libunbound/services/mesh.c

760

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

sbin/unwind/libunbound/services/mesh.c

763

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

770

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

sbin/unwind/libunbound/services/mesh.c

771

mesh->num_forever_states ++;

sbin/unwind/libunbound/services/mesh.c

772

mesh_list_insert(s, &mesh->forever_first,

sbin/unwind/libunbound/services/mesh.c

773

&mesh->forever_last);

sbin/unwind/libunbound/services/mesh.c

776

mesh_list_insert(s, &mesh->jostle_first,

sbin/unwind/libunbound/services/mesh.c

777

&mesh->jostle_last);

sbin/unwind/libunbound/services/mesh.c

789

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

sbin/unwind/libunbound/services/mesh.c

794

mesh_run(mesh, s, module_event_new, NULL);

sbin/unwind/libunbound/services/mesh.c

802

static void mesh_schedule_prefetch_subnet(struct mesh_area* mesh,

sbin/unwind/libunbound/services/mesh.c

815

if(!mesh_make_new_space(mesh, NULL)) {

sbin/unwind/libunbound/services/mesh.c

817

mesh->stats_dropped ++;

sbin/unwind/libunbound/services/mesh.c

821

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

sbin/unwind/libunbound/services/mesh.c

828

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

sbin/unwind/libunbound/services/mesh.c

847

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

sbin/unwind/libunbound/services/mesh.c

850

mesh->num_detached_states++;

sbin/unwind/libunbound/services/mesh.c

857

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

sbin/unwind/libunbound/services/mesh.c

858

mesh->num_forever_states ++;

sbin/unwind/libunbound/services/mesh.c

859

mesh_list_insert(s, &mesh->forever_first,

sbin/unwind/libunbound/services/mesh.c

860

&mesh->forever_last);

sbin/unwind/libunbound/services/mesh.c

863

mesh_list_insert(s, &mesh->jostle_first,

sbin/unwind/libunbound/services/mesh.c

864

&mesh->jostle_last);

sbin/unwind/libunbound/services/mesh.c

876

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

sbin/unwind/libunbound/services/mesh.c

881

mesh_run(mesh, s, module_event_new, NULL);

sbin/unwind/libunbound/services/mesh.c

885

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

sbin/unwind/libunbound/services/mesh.c

893

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

sbin/unwind/libunbound/services/mesh.c

897

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

sbin/unwind/libunbound/services/mesh.c

901

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

sbin/unwind/libunbound/services/mesh.c

911

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

sbin/unwind/libunbound/services/mesh.h

305

void mesh_delete(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

325

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

sbin/unwind/libunbound/services/mesh.h

347

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

sbin/unwind/libunbound/services/mesh.h

365

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

sbin/unwind/libunbound/services/mesh.h

379

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

sbin/unwind/libunbound/services/mesh.h

482

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

sbin/unwind/libunbound/services/mesh.h

528

void mesh_delete_all(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

542

struct mesh_state* mesh_area_find(struct mesh_area* mesh,

sbin/unwind/libunbound/services/mesh.h

596

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

sbin/unwind/libunbound/services/mesh.h

604

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

sbin/unwind/libunbound/services/mesh.h

610

void mesh_stats_clear(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

616

void mesh_log_list(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

623

size_t mesh_get_mem(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

660

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

sbin/unwind/libunbound/services/mesh.h

689

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

sbin/unwind/libunbound/services/mesh.h

720

int mesh_jostle_exceeded(struct mesh_area* mesh);

sbin/unwind/libunbound/services/mesh.h

738

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

sbin/unwind/libunbound/services/modstack.c

340

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

sbin/unwind/libunbound/services/modstack.c

342

fptr_ok(fptr_whitelist_mod_get_mem(env->mesh->

sbin/unwind/libunbound/services/modstack.c

344

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

sbin/unwind/libunbound/util/module.h

498

struct mesh_area* mesh;

sbin/unwind/libunbound/util/netevent.c

3168

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

sbin/unwind/libunbound/util/netevent.c

5114

struct mesh_area* mesh, struct mesh_state* m)

sbin/unwind/libunbound/util/netevent.c

5116

h2_stream->mesh = mesh;

sbin/unwind/libunbound/util/netevent.h

1033

struct mesh_area* mesh, struct mesh_state* m);

sbin/unwind/libunbound/util/netevent.h

997

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

1705

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

sbin/unwind/libunbound/validator/val_sigcrypt.c

1706

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

sbin/unwind/libunbound/validator/validator.c

879

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

sbin/unwind/libunbound/validator/validator.c

918

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

sbin/unwind/libunbound/validator/validator.c

920

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

sbin/unwind/libunbound/validator/validator.c

922

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

sys/dev/pci/if_mwxreg.h

1419

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

2302

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/remote.c

2734

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/remote.c

3040

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

usr.sbin/unbound/daemon/remote.c

3044

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

usr.sbin/unbound/daemon/remote.c

3096

struct mesh_area* mesh;

usr.sbin/unbound/daemon/remote.c

3107

mesh = worker->env.mesh;

usr.sbin/unbound/daemon/remote.c

3108

if(!mesh) return;

usr.sbin/unbound/daemon/remote.c

3109

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

usr.sbin/unbound/daemon/remote.c

3114

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

usr.sbin/unbound/daemon/remote.c

3272

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

usr.sbin/unbound/daemon/remote.c

3322

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

usr.sbin/unbound/daemon/remote.c

7533

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

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

7537

mesh->max_reply_states = cfg->num_queries_per_thread;

usr.sbin/unbound/daemon/remote.c

7538

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

usr.sbin/unbound/daemon/remote.c

7540

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

usr.sbin/unbound/daemon/remote.c

7541

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

usr.sbin/unbound/daemon/remote.c

7579

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

usr.sbin/unbound/daemon/remote.c

7589

mesh_remove_callback(mesh, &qinfo, qflags,

usr.sbin/unbound/daemon/remote.c

7645

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

usr.sbin/unbound/daemon/remote.c

7752

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

usr.sbin/unbound/daemon/remote.c

8000

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_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

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

364

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

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

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

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

213

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

usr.sbin/unbound/daemon/worker.c

2210

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

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

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

2495

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

usr.sbin/unbound/daemon/worker.c

2497

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

usr.sbin/unbound/daemon/worker.c

2501

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

2567

mesh_stats_clear(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

266

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

usr.sbin/unbound/daemon/worker.c

271

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

usr.sbin/unbound/daemon/worker.c

483

mesh_delete_all(worker->env.mesh);

usr.sbin/unbound/daemon/worker.c

976

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

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/iterator/iterator.c

1320

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

usr.sbin/unbound/iterator/iterator.c

2102

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

usr.sbin/unbound/iterator/iterator.c

2127

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

usr.sbin/unbound/iterator/iterator.c

2313

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

usr.sbin/unbound/iterator/iterator.c

2762

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

usr.sbin/unbound/iterator/iterator.c

2801

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

usr.sbin/unbound/libunbound/libworker.c

251

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

usr.sbin/unbound/libunbound/libworker.c

252

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

usr.sbin/unbound/libunbound/libworker.c

653

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

usr.sbin/unbound/libunbound/libworker.c

734

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

usr.sbin/unbound/libunbound/libworker.c

872

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

usr.sbin/unbound/libunbound/libworker.c

918

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

usr.sbin/unbound/libunbound/libworker.c

928

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

usr.sbin/unbound/libunbound/libworker.c

932

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

3636

env->mesh->num_query_authzone_down++;

usr.sbin/unbound/services/authzone.c

3649

env->mesh->num_query_authzone_down++;

usr.sbin/unbound/services/authzone.c

5399

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

usr.sbin/unbound/services/authzone.c

5518

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

usr.sbin/unbound/services/authzone.c

6721

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

usr.sbin/unbound/services/authzone.c

8482

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

usr.sbin/unbound/services/authzone.c

8496

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

usr.sbin/unbound/services/authzone.c

8563

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

usr.sbin/unbound/services/authzone.c

8673

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

usr.sbin/unbound/services/listen_dnsport.c

2169

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

usr.sbin/unbound/services/listen_dnsport.c

2381

struct mesh_area* mesh, struct mesh_state* m)

usr.sbin/unbound/services/listen_dnsport.c

2384

log_assert(req && mesh && m);

usr.sbin/unbound/services/listen_dnsport.c

2388

item->mesh = mesh;

usr.sbin/unbound/services/listen_dnsport.c

3619

mesh_state_remove_reply(stream->mesh, stream->mesh_state,

usr.sbin/unbound/services/listen_dnsport.c

3958

mesh_state_remove_reply(stream->mesh, stream->mesh_state,

usr.sbin/unbound/services/listen_dnsport.c

4044

struct mesh_area* mesh, struct mesh_state* m)

usr.sbin/unbound/services/listen_dnsport.c

4047

stream->mesh = mesh;

usr.sbin/unbound/services/listen_dnsport.c

4050

(void)stream; (void)mesh; (void)m;

usr.sbin/unbound/services/listen_dnsport.h

359

struct mesh_area* mesh;

usr.sbin/unbound/services/listen_dnsport.h

432

struct mesh_area* mesh, struct mesh_state* m);

usr.sbin/unbound/services/listen_dnsport.h

699

struct mesh_area* mesh;

usr.sbin/unbound/services/listen_dnsport.h

808

struct mesh_area* mesh, struct mesh_state* m);

usr.sbin/unbound/services/mesh.c

1057

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

usr.sbin/unbound/services/mesh.c

1079

struct mesh_area* mesh;

usr.sbin/unbound/services/mesh.c

1083

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

usr.sbin/unbound/services/mesh.c

1106

infra_wait_limit_dec(mesh->env->infra_cache,

usr.sbin/unbound/services/mesh.c

1107

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

usr.sbin/unbound/services/mesh.c

1109

log_assert(mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

1110

mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

1117

log_assert(mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

1118

mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

1123

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

usr.sbin/unbound/services/mesh.c

1124

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

usr.sbin/unbound/services/mesh.c

1125

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

usr.sbin/unbound/services/mesh.c

1135

struct mesh_area* mesh;

usr.sbin/unbound/services/mesh.c

1141

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

usr.sbin/unbound/services/mesh.c

1144

mesh->num_forever_states --;

usr.sbin/unbound/services/mesh.c

1145

mesh_list_remove(mstate, &mesh->forever_first,

usr.sbin/unbound/services/mesh.c

1146

&mesh->forever_last);

usr.sbin/unbound/services/mesh.c

1148

mesh_list_remove(mstate, &mesh->jostle_first,

usr.sbin/unbound/services/mesh.c

1149

&mesh->jostle_last);

usr.sbin/unbound/services/mesh.c

1153

log_assert(mesh->num_detached_states > 0);

usr.sbin/unbound/services/mesh.c

1154

mesh->num_detached_states--;

usr.sbin/unbound/services/mesh.c

1157

log_assert(mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

1158

mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

1165

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

usr.sbin/unbound/services/mesh.c

1166

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

usr.sbin/unbound/services/mesh.c

1201

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

usr.sbin/unbound/services/mesh.c

1218

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

1219

log_assert(mesh->num_detached_states +

usr.sbin/unbound/services/mesh.c

1220

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

usr.sbin/unbound/services/mesh.c

1231

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

usr.sbin/unbound/services/mesh.c

1232

*sub = mesh_area_find(mesh, cinfo, qinfo, qflags, prime, valrec);

usr.sbin/unbound/services/mesh.c

1249

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

usr.sbin/unbound/services/mesh.c

1252

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

1259

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

usr.sbin/unbound/services/mesh.c

1276

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

usr.sbin/unbound/services/mesh.c

1289

log_assert(mesh->num_detached_states > 0);

usr.sbin/unbound/services/mesh.c

1290

mesh->num_detached_states--;

usr.sbin/unbound/services/mesh.c

1403

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

usr.sbin/unbound/services/mesh.c

1404

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

usr.sbin/unbound/services/mesh.c

1486

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

usr.sbin/unbound/services/mesh.c

1599

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

usr.sbin/unbound/services/mesh.c

1600

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

usr.sbin/unbound/services/mesh.c

1605

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

usr.sbin/unbound/services/mesh.c

1606

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

usr.sbin/unbound/services/mesh.c

1607

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

usr.sbin/unbound/services/mesh.c

1611

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

usr.sbin/unbound/services/mesh.c

1612

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

usr.sbin/unbound/services/mesh.c

1614

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

usr.sbin/unbound/services/mesh.c

1728

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

usr.sbin/unbound/services/mesh.c

1800

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

usr.sbin/unbound/services/mesh.c

1801

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

usr.sbin/unbound/services/mesh.c

1802

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

usr.sbin/unbound/services/mesh.c

1840

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

usr.sbin/unbound/services/mesh.c

1841

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

usr.sbin/unbound/services/mesh.c

1866

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

usr.sbin/unbound/services/mesh.c

1868

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

usr.sbin/unbound/services/mesh.c

1870

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

usr.sbin/unbound/services/mesh.c

1876

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

usr.sbin/unbound/services/mesh.c

1885

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

usr.sbin/unbound/services/mesh.c

1886

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

usr.sbin/unbound/services/mesh.c

1890

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

usr.sbin/unbound/services/mesh.c

1899

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

usr.sbin/unbound/services/mesh.c

1900

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

usr.sbin/unbound/services/mesh.c

1905

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

usr.sbin/unbound/services/mesh.c

1910

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

usr.sbin/unbound/services/mesh.c

1916

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

usr.sbin/unbound/services/mesh.c

1919

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

usr.sbin/unbound/services/mesh.c

1920

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

usr.sbin/unbound/services/mesh.c

1927

struct mesh_state* mesh_area_find(struct mesh_area* mesh,

usr.sbin/unbound/services/mesh.c

1945

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

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

2121

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

usr.sbin/unbound/services/mesh.c

2128

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

usr.sbin/unbound/services/mesh.c

2136

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

usr.sbin/unbound/services/mesh.c

214

mesh->histogram = timehist_setup();

usr.sbin/unbound/services/mesh.c

2141

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

usr.sbin/unbound/services/mesh.c

2145

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

usr.sbin/unbound/services/mesh.c

2148

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

usr.sbin/unbound/services/mesh.c

2149

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

usr.sbin/unbound/services/mesh.c

215

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

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

2170

mesh_walk_supers(mesh, mstate);

usr.sbin/unbound/services/mesh.c

2185

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

usr.sbin/unbound/services/mesh.c

2193

mesh_walk_supers(mesh, mstate);

usr.sbin/unbound/services/mesh.c

221

mesh->mods = *stack;

usr.sbin/unbound/services/mesh.c

2217

mesh_new_prefetch(mesh, qinfo, qflags, 0,

usr.sbin/unbound/services/mesh.c

222

mesh->env = env;

usr.sbin/unbound/services/mesh.c

223

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

usr.sbin/unbound/services/mesh.c

2234

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

usr.sbin/unbound/services/mesh.c

224

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

usr.sbin/unbound/services/mesh.c

2242

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

usr.sbin/unbound/services/mesh.c

2243

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

usr.sbin/unbound/services/mesh.c

225

mesh->num_reply_addrs = 0;

usr.sbin/unbound/services/mesh.c

2251

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

usr.sbin/unbound/services/mesh.c

2253

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

usr.sbin/unbound/services/mesh.c

2258

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

usr.sbin/unbound/services/mesh.c

226

mesh->num_reply_states = 0;

usr.sbin/unbound/services/mesh.c

2260

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

usr.sbin/unbound/services/mesh.c

2261

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

usr.sbin/unbound/services/mesh.c

2265

mesh_stats(mesh, "mesh_run: end");

usr.sbin/unbound/services/mesh.c

2266

mesh_log_list(mesh);

usr.sbin/unbound/services/mesh.c

227

mesh->num_detached_states = 0;

usr.sbin/unbound/services/mesh.c

2271

mesh_log_list(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

2276

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

usr.sbin/unbound/services/mesh.c

228

mesh->num_forever_states = 0;

usr.sbin/unbound/services/mesh.c

229

mesh->stats_jostled = 0;

usr.sbin/unbound/services/mesh.c

2292

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

usr.sbin/unbound/services/mesh.c

2297

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

usr.sbin/unbound/services/mesh.c

2298

(unsigned)mesh->num_reply_states,

usr.sbin/unbound/services/mesh.c

2299

(unsigned)mesh->num_detached_states,

usr.sbin/unbound/services/mesh.c

230

mesh->stats_dropped = 0;

usr.sbin/unbound/services/mesh.c

2300

(unsigned)mesh->num_reply_addrs,

usr.sbin/unbound/services/mesh.c

2301

(unsigned)mesh->replies_sent,

usr.sbin/unbound/services/mesh.c

2302

(unsigned)mesh->stats_dropped,

usr.sbin/unbound/services/mesh.c

2303

(unsigned)mesh->stats_jostled);

usr.sbin/unbound/services/mesh.c

2304

if(mesh->replies_sent > 0) {

usr.sbin/unbound/services/mesh.c

2306

timeval_divide(&avg, &mesh->replies_sum_wait,

usr.sbin/unbound/services/mesh.c

2307

mesh->replies_sent);

usr.sbin/unbound/services/mesh.c

231

mesh->ans_expired = 0;

usr.sbin/unbound/services/mesh.c

2312

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

usr.sbin/unbound/services/mesh.c

2317

mesh_stats_clear(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

2319

if(!mesh)

usr.sbin/unbound/services/mesh.c

232

mesh->ans_cachedb = 0;

usr.sbin/unbound/services/mesh.c

2321

mesh->num_query_authzone_up = 0;

usr.sbin/unbound/services/mesh.c

2322

mesh->num_query_authzone_down = 0;

usr.sbin/unbound/services/mesh.c

2323

mesh->replies_sent = 0;

usr.sbin/unbound/services/mesh.c

2324

mesh->replies_sum_wait.tv_sec = 0;

usr.sbin/unbound/services/mesh.c

2325

mesh->replies_sum_wait.tv_usec = 0;

usr.sbin/unbound/services/mesh.c

2326

mesh->stats_jostled = 0;

usr.sbin/unbound/services/mesh.c

2327

mesh->stats_dropped = 0;

usr.sbin/unbound/services/mesh.c

2328

timehist_clear(mesh->histogram);

usr.sbin/unbound/services/mesh.c

2329

mesh->ans_secure = 0;

usr.sbin/unbound/services/mesh.c

233

mesh->num_queries_discard_timeout = 0;

usr.sbin/unbound/services/mesh.c

2330

mesh->ans_bogus = 0;

usr.sbin/unbound/services/mesh.c

2331

mesh->val_ops = 0;

usr.sbin/unbound/services/mesh.c

2332

mesh->ans_expired = 0;

usr.sbin/unbound/services/mesh.c

2333

mesh->ans_cachedb = 0;

usr.sbin/unbound/services/mesh.c

2334

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

usr.sbin/unbound/services/mesh.c

2335

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

usr.sbin/unbound/services/mesh.c

2336

mesh->ans_nodata = 0;

usr.sbin/unbound/services/mesh.c

2337

mesh->num_queries_discard_timeout = 0;

usr.sbin/unbound/services/mesh.c

2338

mesh->num_queries_replyaddr_limit = 0;

usr.sbin/unbound/services/mesh.c

2339

mesh->num_queries_wait_limit = 0;

usr.sbin/unbound/services/mesh.c

234

mesh->num_queries_replyaddr_limit = 0;

usr.sbin/unbound/services/mesh.c

2340

mesh->num_dns_error_reports = 0;

usr.sbin/unbound/services/mesh.c

2344

mesh_get_mem(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

2347

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

usr.sbin/unbound/services/mesh.c

2348

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

usr.sbin/unbound/services/mesh.c

2349

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

usr.sbin/unbound/services/mesh.c

235

mesh->num_queries_wait_limit = 0;

usr.sbin/unbound/services/mesh.c

2350

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

usr.sbin/unbound/services/mesh.c

236

mesh->num_dns_error_reports = 0;

usr.sbin/unbound/services/mesh.c

2361

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

usr.sbin/unbound/services/mesh.c

2363

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

usr.sbin/unbound/services/mesh.c

237

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

usr.sbin/unbound/services/mesh.c

238

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

usr.sbin/unbound/services/mesh.c

2390

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

usr.sbin/unbound/services/mesh.c

240

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

usr.sbin/unbound/services/mesh.c

2405

log_assert(mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

2406

mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

2407

infra_wait_limit_dec(mesh->env->infra_cache,

usr.sbin/unbound/services/mesh.c

2408

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

usr.sbin/unbound/services/mesh.c

241

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

usr.sbin/unbound/services/mesh.c

2428

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

2432

log_assert(mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

2433

mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

244

return mesh;

usr.sbin/unbound/services/mesh.c

2472

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

usr.sbin/unbound/services/mesh.c

2520

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

usr.sbin/unbound/services/mesh.c

2594

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

usr.sbin/unbound/services/mesh.c

2595

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

usr.sbin/unbound/services/mesh.c

2596

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

usr.sbin/unbound/services/mesh.c

261

mesh_delete(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

263

if(!mesh)

usr.sbin/unbound/services/mesh.c

2638

mesh->ans_expired += i;

usr.sbin/unbound/services/mesh.c

2642

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

usr.sbin/unbound/services/mesh.c

2644

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

usr.sbin/unbound/services/mesh.c

2646

qstate->env->mesh->rpz_action[

usr.sbin/unbound/services/mesh.c

2655

log_assert(mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

2656

mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

2658

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

266

while(mesh->all.count)

usr.sbin/unbound/services/mesh.c

2668

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

usr.sbin/unbound/services/mesh.c

2669

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

usr.sbin/unbound/services/mesh.c

267

mesh_delete_helper(mesh->all.root);

usr.sbin/unbound/services/mesh.c

2674

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

usr.sbin/unbound/services/mesh.c

268

timehist_delete(mesh->histogram);

usr.sbin/unbound/services/mesh.c

2687

int mesh_jostle_exceeded(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

2689

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

usr.sbin/unbound/services/mesh.c

269

sldns_buffer_free(mesh->qbuf_bak);

usr.sbin/unbound/services/mesh.c

2694

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

usr.sbin/unbound/services/mesh.c

2698

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

usr.sbin/unbound/services/mesh.c

270

free(mesh);

usr.sbin/unbound/services/mesh.c

2703

log_assert(mesh->num_reply_addrs > 0);

usr.sbin/unbound/services/mesh.c

2704

mesh->num_reply_addrs--;

usr.sbin/unbound/services/mesh.c

2707

log_assert(mesh->num_reply_states > 0);

usr.sbin/unbound/services/mesh.c

2708

mesh->num_reply_states--;

usr.sbin/unbound/services/mesh.c

2712

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

274

mesh_delete_all(struct mesh_area* mesh)

usr.sbin/unbound/services/mesh.c

277

while(mesh->all.count)

usr.sbin/unbound/services/mesh.c

278

mesh_delete_helper(mesh->all.root);

usr.sbin/unbound/services/mesh.c

279

mesh->stats_dropped += mesh->num_reply_addrs;

usr.sbin/unbound/services/mesh.c

281

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

usr.sbin/unbound/services/mesh.c

282

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

usr.sbin/unbound/services/mesh.c

283

mesh->num_reply_addrs = 0;

usr.sbin/unbound/services/mesh.c

284

mesh->num_reply_states = 0;

usr.sbin/unbound/services/mesh.c

285

mesh->num_detached_states = 0;

usr.sbin/unbound/services/mesh.c

286

mesh->num_forever_states = 0;

usr.sbin/unbound/services/mesh.c

287

mesh->forever_first = NULL;

usr.sbin/unbound/services/mesh.c

288

mesh->forever_last = NULL;

usr.sbin/unbound/services/mesh.c

289

mesh->jostle_first = NULL;

usr.sbin/unbound/services/mesh.c

290

mesh->jostle_last = NULL;

usr.sbin/unbound/services/mesh.c

293

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

usr.sbin/unbound/services/mesh.c

295

struct mesh_state* m = mesh->jostle_first;

usr.sbin/unbound/services/mesh.c

297

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

usr.sbin/unbound/services/mesh.c

304

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

usr.sbin/unbound/services/mesh.c

307

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

usr.sbin/unbound/services/mesh.c

314

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

usr.sbin/unbound/services/mesh.c

320

mesh_walk_supers(mesh, m);

usr.sbin/unbound/services/mesh.c

322

mesh->stats_jostled ++;

usr.sbin/unbound/services/mesh.c

326

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

usr.sbin/unbound/services/mesh.c

427

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

usr.sbin/unbound/services/mesh.c

433

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

usr.sbin/unbound/services/mesh.c

437

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

usr.sbin/unbound/services/mesh.c

438

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

usr.sbin/unbound/services/mesh.c

444

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

usr.sbin/unbound/services/mesh.c

445

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

usr.sbin/unbound/services/mesh.c

448

mesh->num_queries_wait_limit++;

usr.sbin/unbound/services/mesh.c

450

mesh->env->scratch, LDNS_EDE_OTHER,

usr.sbin/unbound/services/mesh.c

452

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

usr.sbin/unbound/services/mesh.c

453

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

usr.sbin/unbound/services/mesh.c

457

regional_free_all(mesh->env->scratch);

usr.sbin/unbound/services/mesh.c

462

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

usr.sbin/unbound/services/mesh.c

465

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

usr.sbin/unbound/services/mesh.c

473

mesh->stats_dropped++;

usr.sbin/unbound/services/mesh.c

480

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

usr.sbin/unbound/services/mesh.c

488

mesh->num_queries_replyaddr_limit++;

usr.sbin/unbound/services/mesh.c

497

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

usr.sbin/unbound/services/mesh.c

501

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

usr.sbin/unbound/services/mesh.c

502

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

usr.sbin/unbound/services/mesh.c

510

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

520

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

usr.sbin/unbound/services/mesh.c

521

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

usr.sbin/unbound/services/mesh.c

536

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

usr.sbin/unbound/services/mesh.c

552

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

usr.sbin/unbound/services/mesh.c

558

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

usr.sbin/unbound/services/mesh.c

560

doq_stream_add_meshstate(rep->doq_stream, mesh, s);

usr.sbin/unbound/services/mesh.c

568

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

usr.sbin/unbound/services/mesh.c

569

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

usr.sbin/unbound/services/mesh.c

570

(mesh->env->cachedb_enabled &&

usr.sbin/unbound/services/mesh.c

571

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

usr.sbin/unbound/services/mesh.c

578

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

usr.sbin/unbound/services/mesh.c

579

mesh->env->cfg);

usr.sbin/unbound/services/mesh.c

582

log_assert(mesh->num_detached_states > 0);

usr.sbin/unbound/services/mesh.c

583

mesh->num_detached_states--;

usr.sbin/unbound/services/mesh.c

586

mesh->num_reply_states ++;

usr.sbin/unbound/services/mesh.c

588

mesh->num_reply_addrs++;

usr.sbin/unbound/services/mesh.c

591

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

usr.sbin/unbound/services/mesh.c

592

mesh->num_forever_states ++;

usr.sbin/unbound/services/mesh.c

593

mesh_list_insert(s, &mesh->forever_first,

usr.sbin/unbound/services/mesh.c

594

&mesh->forever_last);

usr.sbin/unbound/services/mesh.c

597

mesh_list_insert(s, &mesh->jostle_first,

usr.sbin/unbound/services/mesh.c

598

&mesh->jostle_last);

usr.sbin/unbound/services/mesh.c

603

mesh_run(mesh, s, module_event_new, NULL);

usr.sbin/unbound/services/mesh.c

607

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

usr.sbin/unbound/services/mesh.c

608

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

usr.sbin/unbound/services/mesh.c

623

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

usr.sbin/unbound/services/mesh.c

628

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

usr.sbin/unbound/services/mesh.c

629

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

usr.sbin/unbound/services/mesh.c

630

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

usr.sbin/unbound/services/mesh.c

636

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

usr.sbin/unbound/services/mesh.c

645

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

usr.sbin/unbound/services/mesh.c

651

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

668

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

usr.sbin/unbound/services/mesh.c

691

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

usr.sbin/unbound/services/mesh.c

692

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

usr.sbin/unbound/services/mesh.c

693

(mesh->env->cachedb_enabled &&

usr.sbin/unbound/services/mesh.c

694

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

usr.sbin/unbound/services/mesh.c

704

log_assert(mesh->num_detached_states > 0);

usr.sbin/unbound/services/mesh.c

705

mesh->num_detached_states--;

usr.sbin/unbound/services/mesh.c

708

mesh->num_reply_states ++;

usr.sbin/unbound/services/mesh.c

710

mesh->num_reply_addrs++;

usr.sbin/unbound/services/mesh.c

712

mesh_run(mesh, s, module_event_new, NULL);

usr.sbin/unbound/services/mesh.c

721

static void mesh_schedule_prefetch(struct mesh_area* mesh,

usr.sbin/unbound/services/mesh.c

729

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

usr.sbin/unbound/services/mesh.c

744

if(!mesh_make_new_space(mesh, NULL)) {

usr.sbin/unbound/services/mesh.c

746

mesh->stats_dropped ++;

usr.sbin/unbound/services/mesh.c

750

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

usr.sbin/unbound/services/mesh.c

760

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

usr.sbin/unbound/services/mesh.c

763

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

770

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

usr.sbin/unbound/services/mesh.c

771

mesh->num_forever_states ++;

usr.sbin/unbound/services/mesh.c

772

mesh_list_insert(s, &mesh->forever_first,

usr.sbin/unbound/services/mesh.c

773

&mesh->forever_last);

usr.sbin/unbound/services/mesh.c

776

mesh_list_insert(s, &mesh->jostle_first,

usr.sbin/unbound/services/mesh.c

777

&mesh->jostle_last);

usr.sbin/unbound/services/mesh.c

789

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

usr.sbin/unbound/services/mesh.c

794

mesh_run(mesh, s, module_event_new, NULL);

usr.sbin/unbound/services/mesh.c

802

static void mesh_schedule_prefetch_subnet(struct mesh_area* mesh,

usr.sbin/unbound/services/mesh.c

815

if(!mesh_make_new_space(mesh, NULL)) {

usr.sbin/unbound/services/mesh.c

817

mesh->stats_dropped ++;

usr.sbin/unbound/services/mesh.c

821

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

usr.sbin/unbound/services/mesh.c

828

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

usr.sbin/unbound/services/mesh.c

847

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

usr.sbin/unbound/services/mesh.c

850

mesh->num_detached_states++;

usr.sbin/unbound/services/mesh.c

857

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

usr.sbin/unbound/services/mesh.c

858

mesh->num_forever_states ++;

usr.sbin/unbound/services/mesh.c

859

mesh_list_insert(s, &mesh->forever_first,

usr.sbin/unbound/services/mesh.c

860

&mesh->forever_last);

usr.sbin/unbound/services/mesh.c

863

mesh_list_insert(s, &mesh->jostle_first,

usr.sbin/unbound/services/mesh.c

864

&mesh->jostle_last);

usr.sbin/unbound/services/mesh.c

876

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

usr.sbin/unbound/services/mesh.c

881

mesh_run(mesh, s, module_event_new, NULL);

usr.sbin/unbound/services/mesh.c

885

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

usr.sbin/unbound/services/mesh.c

893

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

usr.sbin/unbound/services/mesh.c

897

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

usr.sbin/unbound/services/mesh.c

901

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

usr.sbin/unbound/services/mesh.c

911

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

usr.sbin/unbound/services/mesh.h

305

void mesh_delete(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

325

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

usr.sbin/unbound/services/mesh.h

347

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

usr.sbin/unbound/services/mesh.h

365

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

usr.sbin/unbound/services/mesh.h

379

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

usr.sbin/unbound/services/mesh.h

482

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

usr.sbin/unbound/services/mesh.h

528

void mesh_delete_all(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

542

struct mesh_state* mesh_area_find(struct mesh_area* mesh,

usr.sbin/unbound/services/mesh.h

596

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

usr.sbin/unbound/services/mesh.h

604

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

usr.sbin/unbound/services/mesh.h

610

void mesh_stats_clear(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

616

void mesh_log_list(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

623

size_t mesh_get_mem(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

660

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

usr.sbin/unbound/services/mesh.h

689

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

usr.sbin/unbound/services/mesh.h

720

int mesh_jostle_exceeded(struct mesh_area* mesh);

usr.sbin/unbound/services/mesh.h

738

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

usr.sbin/unbound/services/modstack.c

340

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

usr.sbin/unbound/services/modstack.c

342

fptr_ok(fptr_whitelist_mod_get_mem(env->mesh->

usr.sbin/unbound/services/modstack.c

344

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

usr.sbin/unbound/testcode/fake_event.c

1999

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

usr.sbin/unbound/testcode/fake_event.c

2031

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

usr.sbin/unbound/testcode/fake_event.c

2040

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

usr.sbin/unbound/testcode/unitzonemd.c

300

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

usr.sbin/unbound/testcode/unitzonemd.c

301

if(!env.mesh)

usr.sbin/unbound/testcode/unitzonemd.c

336

mesh_delete(env.mesh);

usr.sbin/unbound/util/module.h

498

struct mesh_area* mesh;

usr.sbin/unbound/util/netevent.c

3168

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

usr.sbin/unbound/util/netevent.c

5114

struct mesh_area* mesh, struct mesh_state* m)

usr.sbin/unbound/util/netevent.c

5116

h2_stream->mesh = mesh;

usr.sbin/unbound/util/netevent.h

1033

struct mesh_area* mesh, struct mesh_state* m);

usr.sbin/unbound/util/netevent.h

997

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

1705

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

usr.sbin/unbound/validator/val_sigcrypt.c

1706

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

usr.sbin/unbound/validator/validator.c

879

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

usr.sbin/unbound/validator/validator.c

918

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

usr.sbin/unbound/validator/validator.c

920

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

usr.sbin/unbound/validator/validator.c

922

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