Lines Matching full:env

48 static struct relayd		*env = NULL;  variable
62 env = ps->ps_env; in pfe()
67 if (env->sc_pf == NULL) { in pfe()
68 if ((env->sc_pf = calloc(1, sizeof(*(env->sc_pf)))) == NULL) in pfe()
70 env->sc_pf->dev = s; in pfe()
72 if (ioctl(env->sc_pf->dev, DIOCGETSTATUS, &status) == -1) in pfe()
96 flush_rulesets(env); in pfe_shutdown()
97 config_purge(env, CONFIG_ALL); in pfe_shutdown()
106 if (!event_initialized(&env->sc_statev)) { in pfe_setup_events()
107 evtimer_set(&env->sc_statev, pfe_statistics, NULL); in pfe_setup_events()
108 bcopy(&env->sc_conf.statinterval, &tv, sizeof(tv)); in pfe_setup_events()
109 evtimer_add(&env->sc_statev, &tv); in pfe_setup_events()
116 event_del(&env->sc_statev); in pfe_disable_events()
132 if ((host = host_find(env, st.id)) == NULL) in pfe_dispatch_hce()
153 proc_compose(env->sc_ps, PROC_RELAY, in pfe_dispatch_hce()
156 if ((table = table_find(env, host->conf.tableid)) in pfe_dispatch_hce()
165 snmp_hosttrap(env, table, host); in pfe_dispatch_hce()
203 config_gettable(env, imsg); in pfe_dispatch_parent()
206 config_gethost(env, imsg); in pfe_dispatch_parent()
209 config_getrdr(env, imsg); in pfe_dispatch_parent()
212 config_getvirt(env, imsg); in pfe_dispatch_parent()
215 config_getrt(env, imsg); in pfe_dispatch_parent()
218 config_getroute(env, imsg); in pfe_dispatch_parent()
221 config_getproto(env, imsg); in pfe_dispatch_parent()
224 config_getrelay(env, imsg); in pfe_dispatch_parent()
227 config_getrelaytable(env, imsg); in pfe_dispatch_parent()
230 config_getcfg(env, imsg); in pfe_dispatch_parent()
231 init_tables(env); in pfe_dispatch_parent()
232 agentx_init(env); in pfe_dispatch_parent()
239 config_getreset(env, imsg); in pfe_dispatch_parent()
266 if (cnl.proc > env->sc_conf.prefork_relay) in pfe_dispatch_relay()
268 if (natlook(env, &cnl) != 0) in pfe_dispatch_relay()
270 proc_compose_imsg(env->sc_ps, PROC_RELAY, cnl.proc, in pfe_dispatch_relay()
276 if (crs.proc > env->sc_conf.prefork_relay) in pfe_dispatch_relay()
278 if ((rlay = relay_find(env, crs.id)) == NULL) in pfe_dispatch_relay()
282 env->sc_conf.statinterval.tv_sec; in pfe_dispatch_relay()
318 TAILQ_FOREACH(t, &env->sc_sessions, se_entry) { in pfe_dispatch_relay()
330 TAILQ_INSERT_TAIL(&env->sc_sessions, s, se_entry); in pfe_dispatch_relay()
335 TAILQ_FOREACH(s, &env->sc_sessions, se_entry) in pfe_dispatch_relay()
339 TAILQ_REMOVE(&env->sc_sessions, s, se_entry); in pfe_dispatch_relay()
362 if (env->sc_rdrs == NULL) in show()
364 TAILQ_FOREACH(rdr, env->sc_rdrs, entry) { in show()
390 if (env->sc_relays == NULL) in show()
392 TAILQ_FOREACH(rlay, env->sc_relays, rl_entry) { in show()
393 rlay->rl_stats[env->sc_conf.prefork_relay].id = EMPTY_ID; in show()
412 if (env->sc_rts == NULL) in show()
414 TAILQ_FOREACH(rt, env->sc_rts, rt_entry) { in show()
440 for (proc = 0; proc < env->sc_conf.prefork_relay; proc++) { in show_sessions()
446 proc_compose_imsg(env->sc_ps, PROC_RELAY, proc, in show_sessions()
458 rdr = rdr_findbyname(env, id->name); in disable_rdr()
460 rdr = rdr_find(env, id->id); in disable_rdr()
484 rdr = rdr_findbyname(env, id->name); in enable_rdr()
486 rdr = rdr_find(env, id->id); in enable_rdr()
520 table = table_findbyname(env, id->name); in disable_table()
522 table = table_find(env, id->id); in disable_table()
526 if (table->conf.rdrid > 0 && rdr_find(env, table->conf.rdrid) == NULL) in disable_table()
535 proc_compose(env->sc_ps, PROC_HCE, IMSG_TABLE_DISABLE, in disable_table()
539 proc_compose(env->sc_ps, PROC_RELAY, IMSG_TABLE_DISABLE, in disable_table()
554 table = table_findbyname(env, id->name); in enable_table()
556 table = table_find(env, id->id); in enable_table()
561 if (table->conf.rdrid > 0 && rdr_find(env, table->conf.rdrid) == NULL) in enable_table()
571 proc_compose(env->sc_ps, PROC_HCE, IMSG_TABLE_ENABLE, in enable_table()
575 proc_compose(env->sc_ps, PROC_RELAY, IMSG_TABLE_ENABLE, in enable_table()
592 host = host_findbyname(env, id->name); in disable_host()
596 host = host_find(env, id->id); in disable_host()
606 if ((table = table_find(env, host->conf.tableid)) == NULL) in disable_host()
619 proc_compose(env->sc_ps, PROC_HCE, IMSG_HOST_DISABLE, in disable_host()
623 proc_compose(env->sc_ps, PROC_RELAY, IMSG_HOST_DISABLE, in disable_host()
634 TAILQ_FOREACH(t, env->sc_tables, entry) in disable_host()
656 host = host_findbyname(env, id->name); in enable_host()
660 host = host_find(env, id->id); in enable_host()
674 proc_compose(env->sc_ps, PROC_HCE, IMSG_HOST_ENABLE, in enable_host()
678 proc_compose(env->sc_ps, PROC_RELAY, IMSG_HOST_ENABLE, in enable_host()
690 TAILQ_FOREACH(t, env->sc_tables, entry) in enable_host()
715 TAILQ_FOREACH(rdr, env->sc_rdrs, entry) { in pfe_sync()
738 sync_table(env, rdr, active); in pfe_sync()
739 control_imsg_forward(env->sc_ps, &imsg); in pfe_sync()
744 flush_table(env, rdr); in pfe_sync()
751 sync_ruleset(env, rdr, 0); in pfe_sync()
752 control_imsg_forward(env->sc_ps, &imsg); in pfe_sync()
761 sync_ruleset(env, rdr, 1); in pfe_sync()
762 control_imsg_forward(env->sc_ps, &imsg); in pfe_sync()
766 TAILQ_FOREACH(rt, env->sc_rts, rt_entry) { in pfe_sync()
771 sync_routes(env, rt); in pfe_sync()
774 TAILQ_FOREACH(table, env->sc_tables, entry) { in pfe_sync()
803 proc_compose(env->sc_ps, PROC_PARENT, IMSG_DEMOTE, in pfe_sync()
820 TAILQ_FOREACH(rdr, env->sc_rdrs, entry) { in pfe_statistics()
821 cnt = check_table(env, rdr, rdr->table); in pfe_statistics()
823 cnt += check_table(env, rdr, rdr->backup); in pfe_statistics()
835 (3600 / env->sc_conf.statinterval.tv_sec)) == 0) { in pfe_statistics()
841 (86400 / env->sc_conf.statinterval.tv_sec)) == 0) { in pfe_statistics()
850 rdr->stats.interval = env->sc_conf.statinterval.tv_sec; in pfe_statistics()
854 evtimer_set(&env->sc_statev, pfe_statistics, NULL); in pfe_statistics()
855 bcopy(&env->sc_conf.statinterval, &tv, sizeof(tv)); in pfe_statistics()
856 evtimer_add(&env->sc_statev, &tv); in pfe_statistics()