Lines Matching refs:worker
222 rc->worker = NULL; in daemon_remote_clear()
381 n->com = comm_point_create_raw(rc->worker->base, fd, 0, in accept_open()
391 struct listen_port* ports, struct worker* worker) in daemon_remote_open_accept() argument
394 rc->worker = worker; in daemon_remote_open_accept()
452 n->c = comm_point_create_raw(rc->worker->base, newfd, 0, in remote_accept_callback()
652 for(i=1; i<rc->worker->daemon->num; i++) { in distribute_cmd()
653 worker_send_cmd(rc->worker->daemon->workers[i], in distribute_cmd()
655 if(!tube_write_msg(rc->worker->daemon->workers[i]->cmd, in distribute_cmd()
665 do_stop(RES* ssl, struct worker* worker) in do_stop() argument
667 worker->need_to_exit = 1; in do_stop()
668 comm_base_exit(worker->base); in do_stop()
674 do_reload(RES* ssl, struct worker* worker, int reuse_cache) in do_reload() argument
676 worker->reuse_cache = reuse_cache; in do_reload()
677 worker->need_to_exit = 0; in do_reload()
678 comm_base_exit(worker->base); in do_reload()
791 print_mem(RES* ssl, struct worker* worker, struct daemon* daemon, in print_mem() argument
810 val = mod_get_mem(&worker->env, "validator"); in print_mem()
811 iter = mod_get_mem(&worker->env, "iterator"); in print_mem()
812 respip = mod_get_mem(&worker->env, "respip"); in print_mem()
814 subnet = mod_get_mem(&worker->env, "subnetcache"); in print_mem()
817 ipsecmod = mod_get_mem(&worker->env, "ipsecmod"); in print_mem()
827 dynlib = mod_get_mem(&worker->env, "dynlib"); in print_mem()
874 print_uptime(RES* ssl, struct worker* worker, int reset) in print_uptime() argument
876 struct timeval now = *worker->env.now_tv; in print_uptime()
878 timeval_subtract(&up, &now, &worker->daemon->time_boot); in print_uptime()
879 timeval_subtract(&dt, &now, &worker->daemon->time_last_stat); in print_uptime()
881 worker->daemon->time_last_stat = now; in print_uptime()
1111 do_stats(RES* ssl, struct worker* worker, int reset) in do_stats() argument
1113 struct daemon* daemon = worker->daemon; in do_stats()
1121 server_stats_obtain(worker, daemon->workers[i], &s, reset); in do_stats()
1132 if(!print_uptime(ssl, worker, reset)) in do_stats()
1135 if(!print_mem(ssl, worker, daemon, &total)) in do_stats()
1250 do_zones_add(struct daemon_remote* rc, RES* ssl, struct worker* worker) in do_zones_add() argument
1265 if(!perform_zone_add(ssl, worker->daemon->local_zones, in do_zones_add()
1308 do_zones_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker) in do_zones_remove() argument
1323 if(!perform_zone_remove(ssl, worker->daemon->local_zones, in do_zones_remove()
1381 do_datas_add(struct daemon_remote* rc, RES* ssl, struct worker* worker) in do_datas_add() argument
1397 if(perform_data_add(ssl, worker->daemon->local_zones, in do_datas_add()
1430 do_datas_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker) in do_datas_remove() argument
1445 if(!perform_data_remove(ssl, worker->daemon->local_zones, in do_datas_remove()
1458 do_view_zone_add(RES* ssl, struct worker* worker, char* arg) in do_view_zone_add() argument
1464 v = views_find_view(worker->daemon->views, in do_view_zone_add()
1491 do_view_zone_remove(RES* ssl, struct worker* worker, char* arg) in do_view_zone_remove() argument
1497 v = views_find_view(worker->daemon->views, in do_view_zone_remove()
1514 do_view_data_add(RES* ssl, struct worker* worker, char* arg) in do_view_data_add() argument
1520 v = views_find_view(worker->daemon->views, in do_view_data_add()
1539 do_view_datas_add(struct daemon_remote* rc, RES* ssl, struct worker* worker, in do_view_datas_add() argument
1546 v = views_find_view(worker->daemon->views, in do_view_datas_add()
1582 do_view_data_remove(RES* ssl, struct worker* worker, char* arg) in do_view_data_remove() argument
1588 v = views_find_view(worker->daemon->views, in do_view_data_remove()
1605 do_view_datas_remove(struct daemon_remote* rc, RES* ssl, struct worker* worker, in do_view_datas_remove() argument
1612 v = views_find_view(worker->daemon->views, in do_view_datas_remove()
1649 do_lookup(RES* ssl, struct worker* worker, char* arg) in do_lookup() argument
1656 (void)print_deleg_lookup(ssl, worker, nm, nmlen, nmlabs); in do_lookup()
1662 do_cache_remove(struct worker* worker, uint8_t* nm, size_t nmlen, in do_cache_remove() argument
1667 rrset_cache_remove(worker->env.rrset_cache, nm, nmlen, t, c, 0); in do_cache_remove()
1669 rrset_cache_remove(worker->env.rrset_cache, nm, nmlen, t, c, in do_cache_remove()
1677 slabhash_remove(worker->env.msg_cache, h, &k); in do_cache_remove()
1681 slabhash_remove(worker->env.msg_cache, h, &k); in do_cache_remove()
1684 if(remcachedb && worker->env.cachedb_enabled) in do_cache_remove()
1685 cachedb_msg_remove_qinfo(&worker->env, &k); in do_cache_remove()
1710 do_flush_type(RES* ssl, struct worker* worker, char* arg) in do_flush_type() argument
1730 do_cache_remove(worker, nm, nmlen, t, LDNS_RR_CLASS_IN, pc); in do_flush_type()
1738 do_flush_stats(RES* ssl, struct worker* worker) in do_flush_stats() argument
1740 worker_stats_clear(worker); in do_flush_stats()
1749 struct worker* worker; member
1795 do_flush_infra(RES* ssl, struct worker* worker, char* arg) in do_flush_infra() argument
1801 slabhash_clear(worker->env.infra_cache->hosts); in do_flush_infra()
1811 inf.worker = worker; in do_flush_infra()
1815 inf.expired = *worker->env.now; in do_flush_infra()
1823 slabhash_traverse(worker->env.infra_cache->hosts, 1, &infra_del_host, in do_flush_infra()
1830 do_flush_requestlist(RES* ssl, struct worker* worker) in do_flush_requestlist() argument
1832 mesh_delete_all(worker->env.mesh); in do_flush_requestlist()
1869 if(inf->remcachedb && inf->worker->env.cachedb_enabled) in zone_del_msg()
1870 cachedb_msg_remove_qinfo(&inf->worker->env, &k->key); in zone_del_msg()
1893 do_flush_zone(RES* ssl, struct worker* worker, char* arg) in do_flush_zone() argument
1906 inf.worker = worker; in do_flush_zone()
1910 inf.expired = *worker->env.now; in do_flush_zone()
1916 slabhash_traverse(&worker->env.rrset_cache->table, 1, in do_flush_zone()
1919 slabhash_traverse(worker->env.msg_cache, 1, &zone_del_msg, &inf); in do_flush_zone()
1922 if(worker->env.key_cache) { in do_flush_zone()
1923 slabhash_traverse(worker->env.key_cache->slab, 1, in do_flush_zone()
1958 if(inf->remcachedb && inf->worker->env.cachedb_enabled) in bogus_del_msg()
1959 cachedb_msg_remove_qinfo(&inf->worker->env, in bogus_del_msg()
1980 do_flush_bogus(RES* ssl, struct worker* worker, char* arg) in do_flush_bogus() argument
1987 inf.worker = worker; in do_flush_bogus()
1988 inf.expired = *worker->env.now; in do_flush_bogus()
1994 slabhash_traverse(&worker->env.rrset_cache->table, 1, in do_flush_bogus()
1997 slabhash_traverse(worker->env.msg_cache, 1, &bogus_del_msg, &inf); in do_flush_bogus()
2000 if(worker->env.key_cache) { in do_flush_bogus()
2001 slabhash_traverse(worker->env.key_cache->slab, 1, in do_flush_bogus()
2040 if(inf->remcachedb && inf->worker->env.cachedb_enabled) in negative_del_msg()
2041 cachedb_msg_remove_qinfo(&inf->worker->env, in negative_del_msg()
2064 do_flush_negative(RES* ssl, struct worker* worker, char* arg) in do_flush_negative() argument
2071 inf.worker = worker; in do_flush_negative()
2072 inf.expired = *worker->env.now; in do_flush_negative()
2078 slabhash_traverse(&worker->env.rrset_cache->table, 1, in do_flush_negative()
2081 slabhash_traverse(worker->env.msg_cache, 1, &negative_del_msg, &inf); in do_flush_negative()
2084 if(worker->env.key_cache) { in do_flush_negative()
2085 slabhash_traverse(worker->env.key_cache->slab, 1, in do_flush_negative()
2096 do_flush_name(RES* ssl, struct worker* w, char* arg) in do_flush_name()
2242 do_forward(RES* ssl, struct worker* worker, char* args) in do_forward() argument
2244 struct iter_forwards* fwd = worker->env.fwds; in do_forward()
2258 mesh_delete_all(worker->env.mesh); in do_forward()
2321 do_forward_add(RES* ssl, struct worker* worker, char* args) in do_forward_add() argument
2323 struct iter_forwards* fwd = worker->env.fwds; in do_forward_add()
2334 if(insecure && worker->env.anchors) { in do_forward_add()
2335 if(!anchors_add_insecure(worker->env.anchors, LDNS_RR_CLASS_IN, in do_forward_add()
2357 do_forward_remove(RES* ssl, struct worker* worker, char* args) in do_forward_remove() argument
2359 struct iter_forwards* fwd = worker->env.fwds; in do_forward_remove()
2367 if(insecure && worker->env.anchors) in do_forward_remove()
2368 anchors_delete_insecure(worker->env.anchors, LDNS_RR_CLASS_IN, in do_forward_remove()
2378 do_stub_add(RES* ssl, struct worker* worker, char* args) in do_stub_add() argument
2380 struct iter_forwards* fwd = worker->env.fwds; in do_stub_add()
2391 lock_rw_wrlock(&worker->env.hints->lock); in do_stub_add()
2392 if(insecure && worker->env.anchors) { in do_stub_add()
2393 if(!anchors_add_insecure(worker->env.anchors, LDNS_RR_CLASS_IN, in do_stub_add()
2396 lock_rw_unlock(&worker->env.hints->lock); in do_stub_add()
2404 if(insecure && worker->env.anchors) in do_stub_add()
2405 anchors_delete_insecure(worker->env.anchors, in do_stub_add()
2408 lock_rw_unlock(&worker->env.hints->lock); in do_stub_add()
2414 if(!hints_add_stub(worker->env.hints, LDNS_RR_CLASS_IN, dp, !prime, in do_stub_add()
2418 if(insecure && worker->env.anchors) in do_stub_add()
2419 anchors_delete_insecure(worker->env.anchors, in do_stub_add()
2422 lock_rw_unlock(&worker->env.hints->lock); in do_stub_add()
2427 lock_rw_unlock(&worker->env.hints->lock); in do_stub_add()
2434 do_stub_remove(RES* ssl, struct worker* worker, char* args) in do_stub_remove() argument
2436 struct iter_forwards* fwd = worker->env.fwds; in do_stub_remove()
2444 lock_rw_wrlock(&worker->env.hints->lock); in do_stub_remove()
2445 if(insecure && worker->env.anchors) in do_stub_remove()
2446 anchors_delete_insecure(worker->env.anchors, LDNS_RR_CLASS_IN, in do_stub_remove()
2449 hints_delete_stub(worker->env.hints, LDNS_RR_CLASS_IN, nm, nolock); in do_stub_remove()
2451 lock_rw_unlock(&worker->env.hints->lock); in do_stub_remove()
2458 do_insecure_add(RES* ssl, struct worker* worker, char* arg) in do_insecure_add() argument
2465 if(worker->env.anchors) { in do_insecure_add()
2466 if(!anchors_add_insecure(worker->env.anchors, in do_insecure_add()
2479 do_insecure_remove(RES* ssl, struct worker* worker, char* arg) in do_insecure_remove() argument
2486 if(worker->env.anchors) in do_insecure_remove()
2487 anchors_delete_insecure(worker->env.anchors, in do_insecure_remove()
2494 do_insecure_list(RES* ssl, struct worker* worker) in do_insecure_list() argument
2498 if(worker->env.anchors) { in do_insecure_list()
2499 RBTREE_FOR(a, struct trust_anchor*, worker->env.anchors->tree) { in do_insecure_list()
2510 do_status(RES* ssl, struct worker* worker) in do_status() argument
2518 if(!ssl_printf(ssl, "threads: %d\n", worker->daemon->num)) in do_status()
2520 if(!ssl_printf(ssl, "modules: %d [", worker->daemon->mods.num)) in do_status()
2522 for(i=0; i<worker->daemon->mods.num; i++) { in do_status()
2523 if(!ssl_printf(ssl, " %s", worker->daemon->mods.mod[i]->name)) in do_status()
2528 uptime = (time_t)time(NULL) - (time_t)worker->daemon->time_boot.tv_sec; in do_status()
2532 (worker->daemon->reuseport?" reuseport":""), in do_status()
2533 (worker->daemon->rc->accept_list?" control":""), in do_status()
2534 (worker->daemon->rc->accept_list && worker->daemon->rc->use_cert?"(ssl)":""), in do_status()
2535 …(worker->daemon->rc->accept_list && worker->daemon->cfg->control_ifs.first && worker->daemon->cfg-… in do_status()
2618 do_dump_requestlist(RES* ssl, struct worker* worker) in do_dump_requestlist() argument
2626 if(!ssl_printf(ssl, "thread #%d\n", worker->thread_num)) in do_dump_requestlist()
2631 mesh = worker->env.mesh; in do_dump_requestlist()
2637 get_mesh_age(m, timebuf, sizeof(timebuf), &worker->env); in do_dump_requestlist()
2712 do_dump_infra(RES* ssl, struct worker* worker) in do_dump_infra() argument
2715 arg.infra = worker->env.infra_cache; in do_dump_infra()
2717 arg.now = *worker->env.now; in do_dump_infra()
2724 do_log_reopen(RES* ssl, struct worker* worker) in do_log_reopen() argument
2726 struct config_file* cfg = worker->env.cfg; in do_log_reopen()
2733 do_auth_zone_reload(RES* ssl, struct worker* worker, char* arg) in do_auth_zone_reload() argument
2738 struct auth_zones* az = worker->env.auth_zones; in do_auth_zone_reload()
2764 if(!auth_zone_read_zonefile(z, worker->env.cfg)) { in do_auth_zone_reload()
2789 xfr->lease_time = *worker->env.now; in do_auth_zone_reload()
2793 auth_zone_verify_zonemd(z, &worker->env, &worker->env.mesh->mods, in do_auth_zone_reload()
2812 do_auth_zone_transfer(RES* ssl, struct worker* worker, char* arg) in do_auth_zone_transfer() argument
2817 struct auth_zones* az = worker->env.auth_zones; in do_auth_zone_transfer()
2820 if(!az || !auth_zones_startprobesequence(az, &worker->env, nm, nmlen, in do_auth_zone_transfer()
2832 do_set_option(RES* ssl, struct worker* worker, char* arg) in do_set_option() argument
2837 if(!config_set_option(worker->env.cfg, arg, arg2)) { in do_set_option()
2843 int m = modstack_find(&worker->env.mesh->mods, "validator"); in do_set_option()
2845 if(m != -1) val_env = (struct val_env*)worker->env.modinfo[m]; in do_set_option()
2847 val_env->date_override = worker->env.cfg->val_date_override; in do_set_option()
2861 do_get_option(RES* ssl, struct worker* worker, char* arg) in do_get_option() argument
2864 r = config_get_option(worker->env.cfg, arg, remote_get_opt_ssl, ssl); in do_get_option()
2873 do_list_forwards(RES* ssl, struct worker* worker) in do_list_forwards() argument
2876 struct iter_forwards* fwds = worker->env.fwds; in do_list_forwards()
2886 if(worker->env.anchors && in do_list_forwards()
2887 (a=anchor_find(worker->env.anchors, z->name, in do_list_forwards()
2905 do_list_stubs(RES* ssl, struct worker* worker) in do_list_stubs() argument
2911 lock_rw_rdlock(&worker->env.hints->lock); in do_list_stubs()
2912 RBTREE_FOR(z, struct iter_hints_stub*, &worker->env.hints->tree) { in do_list_stubs()
2916 if(worker->env.anchors && in do_list_stubs()
2917 (a=anchor_find(worker->env.anchors, z->node.name, in do_list_stubs()
2928 lock_rw_unlock(&worker->env.hints->lock); in do_list_stubs()
2932 lock_rw_unlock(&worker->env.hints->lock); in do_list_stubs()
2989 do_list_local_data(RES* ssl, struct worker* worker, struct local_zones* zones) in do_list_local_data() argument
2994 char* s = (char*)sldns_buffer_begin(worker->env.scratch_buffer); in do_list_local_data()
2995 size_t slen = sldns_buffer_capacity(worker->env.scratch_buffer); in do_list_local_data()
3028 do_view_list_local_zones(RES* ssl, struct worker* worker, char* arg) in do_view_list_local_zones() argument
3030 struct view* v = views_find_view(worker->daemon->views, in do_view_list_local_zones()
3044 do_view_list_local_data(RES* ssl, struct worker* worker, char* arg) in do_view_list_local_data() argument
3046 struct view* v = views_find_view(worker->daemon->views, in do_view_list_local_data()
3053 do_list_local_data(ssl, worker, v->local_zones); in do_view_list_local_data()
3112 do_ratelimit_list(RES* ssl, struct worker* worker, char* arg) in do_ratelimit_list() argument
3116 a.infra = worker->env.infra_cache; in do_ratelimit_list()
3117 a.now = *worker->env.now; in do_ratelimit_list()
3119 a.backoff = worker->env.cfg->ratelimit_backoff; in do_ratelimit_list()
3131 do_ip_ratelimit_list(RES* ssl, struct worker* worker, char* arg) in do_ip_ratelimit_list() argument
3135 a.infra = worker->env.infra_cache; in do_ip_ratelimit_list()
3136 a.now = *worker->env.now; in do_ip_ratelimit_list()
3138 a.backoff = worker->env.cfg->ip_ratelimit_backoff; in do_ip_ratelimit_list()
3150 do_rpz_enable_disable(RES* ssl, struct worker* worker, char* arg, int enable) { in do_rpz_enable_disable() argument
3154 struct auth_zones *az = worker->env.auth_zones; in do_rpz_enable_disable()
3187 do_rpz_enable(RES* ssl, struct worker* worker, char* arg) in do_rpz_enable() argument
3189 do_rpz_enable_disable(ssl, worker, arg, 1); in do_rpz_enable()
3194 do_rpz_disable(RES* ssl, struct worker* worker, char* arg) in do_rpz_disable() argument
3196 do_rpz_enable_disable(ssl, worker, arg, 0); in do_rpz_disable()
3202 cookie_secret_file_dump(RES* ssl, struct worker* worker) { in cookie_secret_file_dump() argument
3203 char const* secret_file = worker->env.cfg->cookie_secret_file; in cookie_secret_file_dump()
3204 struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets; in cookie_secret_file_dump()
3244 do_activate_cookie_secret(RES* ssl, struct worker* worker) { in do_activate_cookie_secret() argument
3245 char const* secret_file = worker->env.cfg->cookie_secret_file; in do_activate_cookie_secret()
3246 struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets; in do_activate_cookie_secret()
3264 if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) { in do_activate_cookie_secret()
3271 if(worker->thread_num == 0) in do_activate_cookie_secret()
3272 (void)cookie_secret_file_dump(ssl, worker); in do_activate_cookie_secret()
3279 do_drop_cookie_secret(RES* ssl, struct worker* worker) { in do_drop_cookie_secret() argument
3280 char const* secret_file = worker->env.cfg->cookie_secret_file; in do_drop_cookie_secret()
3281 struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets; in do_drop_cookie_secret()
3299 if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) { in do_drop_cookie_secret()
3306 if(worker->thread_num == 0) in do_drop_cookie_secret()
3307 (void)cookie_secret_file_dump(ssl, worker); in do_drop_cookie_secret()
3314 do_add_cookie_secret(RES* ssl, struct worker* worker, char* arg) { in do_add_cookie_secret() argument
3316 char const* secret_file = worker->env.cfg->cookie_secret_file; in do_add_cookie_secret()
3317 struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets; in do_add_cookie_secret()
3324 worker->daemon->cookie_secrets = cookie_secrets_create(); in do_add_cookie_secret()
3325 if(!worker->daemon->cookie_secrets) { in do_add_cookie_secret()
3329 cookie_secrets = worker->daemon->cookie_secrets; in do_add_cookie_secret()
3355 if(worker->thread_num == 0 && !cookie_secret_file_dump(ssl, worker)) { in do_add_cookie_secret()
3365 if(worker->thread_num == 0) in do_add_cookie_secret()
3366 (void)cookie_secret_file_dump(ssl, worker); in do_add_cookie_secret()
3374 do_print_cookie_secrets(RES* ssl, struct worker* worker) { in do_print_cookie_secrets() argument
3375 struct cookie_secrets* cookie_secrets = worker->daemon->cookie_secrets; in do_print_cookie_secrets()
3413 struct worker* worker) in execute_cmd() argument
3418 do_stop(ssl, worker); in execute_cmd()
3421 do_reload(ssl, worker, 1); in execute_cmd()
3424 do_reload(ssl, worker, 0); in execute_cmd()
3427 do_stats(ssl, worker, 0); in execute_cmd()
3430 do_stats(ssl, worker, 1); in execute_cmd()
3433 do_status(ssl, worker); in execute_cmd()
3437 if(worker->daemon->num > 1) { in execute_cmd()
3443 (void)dump_cache(ssl, worker); in execute_cmd()
3447 if(worker->daemon->num > 1) { in execute_cmd()
3453 if(load_cache(ssl, worker)) send_ok(ssl); in execute_cmd()
3456 do_list_forwards(ssl, worker); in execute_cmd()
3459 do_list_stubs(ssl, worker); in execute_cmd()
3462 do_insecure_list(ssl, worker); in execute_cmd()
3465 do_list_local_zones(ssl, worker->daemon->local_zones); in execute_cmd()
3468 do_list_local_data(ssl, worker, worker->daemon->local_zones); in execute_cmd()
3471 do_view_list_local_zones(ssl, worker, skipwhite(p+21)); in execute_cmd()
3474 do_view_list_local_data(ssl, worker, skipwhite(p+20)); in execute_cmd()
3477 do_ratelimit_list(ssl, worker, p+14); in execute_cmd()
3480 do_ip_ratelimit_list(ssl, worker, p+17); in execute_cmd()
3483 do_list_auth_zones(ssl, worker->env.auth_zones); in execute_cmd()
3486 do_auth_zone_reload(ssl, worker, skipwhite(p+16)); in execute_cmd()
3489 do_auth_zone_transfer(ssl, worker, skipwhite(p+18)); in execute_cmd()
3494 do_insecure_add(ssl, worker, skipwhite(p+12)); in execute_cmd()
3499 do_insecure_remove(ssl, worker, skipwhite(p+15)); in execute_cmd()
3504 do_flush_stats(ssl, worker); in execute_cmd()
3509 do_flush_requestlist(ssl, worker); in execute_cmd()
3512 do_lookup(ssl, worker, skipwhite(p+6)); in execute_cmd()
3518 do_zones_remove(rc, ssl, worker); in execute_cmd()
3521 do_zones_add(rc, ssl, worker); in execute_cmd()
3524 do_datas_remove(rc, ssl, worker); in execute_cmd()
3527 do_datas_add(rc, ssl, worker); in execute_cmd()
3530 do_view_datas_remove(rc, ssl, worker, skipwhite(p+23)); in execute_cmd()
3533 do_view_datas_add(rc, ssl, worker, skipwhite(p+16)); in execute_cmd()
3536 do_print_cookie_secrets(ssl, worker); in execute_cmd()
3551 do_zone_remove(ssl, worker->daemon->local_zones, skipwhite(p+17)); in execute_cmd()
3553 do_zone_add(ssl, worker->daemon->local_zones, skipwhite(p+10)); in execute_cmd()
3555 do_data_remove(ssl, worker->daemon->local_zones, skipwhite(p+17)); in execute_cmd()
3557 do_data_add(ssl, worker->daemon->local_zones, skipwhite(p+10)); in execute_cmd()
3559 do_forward_add(ssl, worker, skipwhite(p+11)); in execute_cmd()
3561 do_forward_remove(ssl, worker, skipwhite(p+14)); in execute_cmd()
3563 do_forward(ssl, worker, skipwhite(p+7)); in execute_cmd()
3565 do_stub_add(ssl, worker, skipwhite(p+8)); in execute_cmd()
3567 do_stub_remove(ssl, worker, skipwhite(p+11)); in execute_cmd()
3569 do_view_zone_remove(ssl, worker, skipwhite(p+22)); in execute_cmd()
3571 do_view_zone_add(ssl, worker, skipwhite(p+15)); in execute_cmd()
3573 do_view_data_remove(ssl, worker, skipwhite(p+22)); in execute_cmd()
3575 do_view_data_add(ssl, worker, skipwhite(p+15)); in execute_cmd()
3577 do_flush_zone(ssl, worker, skipwhite(p+10)); in execute_cmd()
3579 do_flush_type(ssl, worker, skipwhite(p+10)); in execute_cmd()
3581 do_flush_infra(ssl, worker, skipwhite(p+11)); in execute_cmd()
3583 do_flush_name(ssl, worker, skipwhite(p+5)); in execute_cmd()
3585 do_dump_requestlist(ssl, worker); in execute_cmd()
3587 do_dump_infra(ssl, worker); in execute_cmd()
3589 do_log_reopen(ssl, worker); in execute_cmd()
3591 do_set_option(ssl, worker, skipwhite(p+10)); in execute_cmd()
3593 do_get_option(ssl, worker, skipwhite(p+10)); in execute_cmd()
3595 do_flush_bogus(ssl, worker, skipwhite(p+11)); in execute_cmd()
3597 do_flush_negative(ssl, worker, skipwhite(p+14)); in execute_cmd()
3599 do_rpz_enable(ssl, worker, skipwhite(p+10)); in execute_cmd()
3601 do_rpz_disable(ssl, worker, skipwhite(p+11)); in execute_cmd()
3603 do_add_cookie_secret(ssl, worker, skipwhite(p+17)); in execute_cmd()
3605 do_drop_cookie_secret(ssl, worker); in execute_cmd()
3607 do_activate_cookie_secret(ssl, worker); in execute_cmd()
3614 daemon_remote_exec(struct worker* worker) in daemon_remote_exec() argument
3619 if(!tube_read_msg(worker->cmd, &msg, &len, 0)) { in daemon_remote_exec()
3624 execute_cmd(NULL, NULL, (char*)msg, worker); in daemon_remote_exec()
3688 execute_cmd(rc, res, buf, rc->worker); in handle_req()