Lines Matching defs:worker
55 #include "daemon/worker.h"
224 void shm_main_run(struct worker *worker)
233 verbose(VERB_DETAIL, "SHM run - worker [%d] - daemon [%p] - timenow(%u) - timeboot(%u)",
234 worker->thread_num, worker->daemon, (unsigned)worker->env.now_tv->tv_sec, (unsigned)worker->daemon->time_boot.tv_sec);
237 offset = worker->thread_num + 1;
238 stat_total = worker->daemon->shm_info->ptr_arr;
239 stat_info = worker->daemon->shm_info->ptr_arr + offset;
242 server_stats_compile(worker, stat_info, 0);
245 if (worker->thread_num == 0) {
252 shm_stat = worker->daemon->shm_info->ptr_ctl;
253 shm_stat->time.now_sec = (long long)worker->env.now_tv->tv_sec;
254 shm_stat->time.now_usec = (long long)worker->env.now_tv->tv_usec;
257 stat_timeval_subtract(&shm_stat->time.up_sec, &shm_stat->time.up_usec, worker->env.now_tv, &worker->daemon->time_boot);
258 stat_timeval_subtract(&shm_stat->time.elapsed_sec, &shm_stat->time.elapsed_usec, worker->env.now_tv, &worker->daemon->time_last_stat);
260 shm_stat->mem.msg = (long long)slabhash_get_mem(worker->env.msg_cache);
261 shm_stat->mem.rrset = (long long)slabhash_get_mem(&worker->env.rrset_cache->table);
264 if(worker->daemon->dnscenv) {
266 worker->daemon->dnscenv->shared_secrets_cache);
268 worker->daemon->dnscenv->nonces_cache);
271 shm_stat->mem.val = (long long)mod_get_mem(&worker->env,
273 shm_stat->mem.iter = (long long)mod_get_mem(&worker->env,
275 shm_stat->mem.respip = (long long)mod_get_mem(&worker->env,
283 shm_stat->mem.subnet = (long long)mod_get_mem(&worker->env,
291 shm_stat->mem.ipsecmod = (long long)mod_get_mem(&worker->env,
295 shm_stat->mem.dynlib = (long long)mod_get_mem(&worker->env,
303 stat_total->mesh_time_median /= (double)worker->daemon->num;
306 (void)worker;