Lines Matching refs:worker
49 #include "daemon/worker.h"
93 void server_stats_querymiss(struct ub_server_stats* stats, struct worker* worker)
96 stats->sum_query_list_size += worker->env.mesh->all.count;
97 if((long long)worker->env.mesh->all.count > stats->max_query_list_size)
98 stats->max_query_list_size = (long long)worker->env.mesh->all.count;
101 void server_stats_prefetch(struct ub_server_stats* stats, struct worker* worker)
105 stats->sum_query_list_size += worker->env.mesh->all.count;
106 if((long long)worker->env.mesh->all.count > stats->max_query_list_size)
107 stats->max_query_list_size = (long long)worker->env.mesh->all.count;
110 void server_stats_log(struct ub_server_stats* stats, struct worker* worker,
129 (unsigned)worker->env.mesh->stats_dropped,
130 (unsigned)worker->env.mesh->stats_jostled);
137 set_subnet_stats(struct worker* worker, struct ub_server_stats* svr,
140 int m = modstack_find(&worker->env.mesh->mods, "subnet");
144 sne = (struct subnet_env*)worker->env.modinfo[m];
145 if(reset && !worker->env.cfg->stat_cumulative) {
152 if(reset && !worker->env.cfg->stat_cumulative) {
162 set_neg_cache_stats(struct worker* worker, struct ub_server_stats* svr,
165 int m = modstack_find(&worker->env.mesh->mods, "validator");
170 ve = (struct val_env*)worker->env.modinfo[m];
177 if(reset && !worker->env.cfg->stat_cumulative) {
186 get_rrset_bogus(struct worker* worker, int reset)
188 int m = modstack_find(&worker->env.mesh->mods, "validator");
193 ve = (struct val_env*)worker->env.modinfo[m];
196 if(reset && !worker->env.cfg->stat_cumulative)
204 get_queries_ratelimit(struct worker* worker, int reset)
206 int m = modstack_find(&worker->env.mesh->mods, "iterator");
211 ie = (struct iter_env*)worker->env.modinfo[m];
214 if(reset && !worker->env.cfg->stat_cumulative)
223 get_dnscrypt_cache_miss(struct worker* worker, int reset)
226 struct dnsc_env* de = worker->daemon->dnscenv;
231 if(reset && !worker->env.cfg->stat_cumulative)
239 get_dnscrypt_replay(struct worker* worker, int reset)
242 struct dnsc_env* de = worker->daemon->dnscenv;
246 if(reset && !worker->env.cfg->stat_cumulative)
254 server_stats_compile(struct worker* worker, struct ub_stats_info* s, int reset)
259 s->svr = worker->stats;
260 s->mesh_num_states = (long long)worker->env.mesh->all.count;
261 s->mesh_num_reply_states = (long long)worker->env.mesh->num_reply_states;
262 s->mesh_jostled = (long long)worker->env.mesh->stats_jostled;
263 s->mesh_dropped = (long long)worker->env.mesh->stats_dropped;
264 s->mesh_replies_sent = (long long)worker->env.mesh->replies_sent;
265 s->mesh_replies_sum_wait_sec = (long long)worker->env.mesh->replies_sum_wait.tv_sec;
266 s->mesh_replies_sum_wait_usec = (long long)worker->env.mesh->replies_sum_wait.tv_usec;
267 s->mesh_time_median = timehist_quartile(worker->env.mesh->histogram,
271 s->svr.ans_secure += (long long)worker->env.mesh->ans_secure;
272 s->svr.ans_bogus += (long long)worker->env.mesh->ans_bogus;
273 s->svr.ans_rcode_nodata += (long long)worker->env.mesh->ans_nodata;
274 s->svr.ans_expired += (long long)worker->env.mesh->ans_expired;
276 s->svr.ans_rcode[i] += (long long)worker->env.mesh->ans_rcode[i];
278 s->svr.rpz_action[i] += (long long)worker->env.mesh->rpz_action[i];
279 timehist_export(worker->env.mesh->histogram, s->svr.hist,
282 s->svr.unwanted_replies = (long long)worker->back->unwanted_replies;
283 s->svr.qtcp_outgoing = (long long)worker->back->num_tcp_outgoing;
286 s->svr.rrset_bogus = (long long)get_rrset_bogus(worker, reset);
289 s->svr.queries_ratelimited = (long long)get_queries_ratelimit(worker, reset);
292 s->svr.msg_cache_count = (long long)count_slabhash_entries(worker->env.msg_cache);
293 s->svr.rrset_cache_count = (long long)count_slabhash_entries(&worker->env.rrset_cache->table);
294 s->svr.infra_cache_count = (long long)count_slabhash_entries(worker->env.infra_cache->hosts);
295 if(worker->env.key_cache)
296 s->svr.key_cache_count = (long long)count_slabhash_entries(worker->env.key_cache->slab);
300 if(worker->daemon->dnscenv) {
302 (long long)get_dnscrypt_cache_miss(worker, reset);
304 worker->daemon->dnscenv->shared_secrets_cache);
306 worker->daemon->dnscenv->nonces_cache);
308 (long long)get_dnscrypt_replay(worker, reset);
321 if(worker->env.auth_zones) {
322 if(reset && !worker->env.cfg->stat_cumulative) {
323 lock_rw_wrlock(&worker->env.auth_zones->lock);
325 lock_rw_rdlock(&worker->env.auth_zones->lock);
327 s->svr.num_query_authzone_up = (long long)worker->env.
329 s->svr.num_query_authzone_down = (long long)worker->env.
331 if(reset && !worker->env.cfg->stat_cumulative) {
332 worker->env.auth_zones->num_query_up = 0;
333 worker->env.auth_zones->num_query_down = 0;
335 lock_rw_unlock(&worker->env.auth_zones->lock);
345 set_neg_cache_stats(worker, &s->svr, reset);
348 set_subnet_stats(worker, &s->svr, reset);
356 for(lp = worker->front->cps; lp; lp = lp->next) {
361 if(reset && !worker->env.cfg->stat_cumulative) {
362 worker_stats_clear(worker);
366 void server_stats_obtain(struct worker* worker, struct worker* who,
371 if(worker == who) {
373 server_stats_compile(worker, s, reset);
382 if(!tube_read_msg(worker->cmd, &reply, &len, 0))
391 void server_stats_reply(struct worker* worker, int reset)
394 server_stats_compile(worker, &s, reset);
396 if(!tube_write_msg(worker->daemon->workers[0]->cmd,