{ ... } ## The parameters are those described above in the "target default" section ## plus the "description" parameter. ## the
should be IPv4 or IPv6 address (not hostname!) EOD; /* add static routes for each gateway with their monitor IP */ if(is_array($gateways_arr)) { foreach($gateways_arr as $name => $gateway) { if($gateway['monitor'] == "") { $gateway['monitor'] = $gateway['gateway']; } $apingerconfig .= "target \"{$gateway['monitor']}\" {\n"; $apingerconfig .= " description \"{$gateway['name']}\"\n"; $apingerconfig .= " rrd file \"{$g['vardb_path']}/rrd/{$gateway['name']}-quality.rrd\"\n"; $apingerconfig .= "}\n"; $apingerconfig .= "\n"; if($gateway['monitor'] == $gateway['gateway']) { /* if the gateway is the same as the monitor we do not add a * route as this will break the routing table */ continue; } else { mwexec("/sbin/route delete -host " . escapeshellarg($gateway['monitor'])); if(! stristr("127.0.0", $gateway['gateway'])) { mwexec("/sbin/route add -host " . escapeshellarg($gateway['monitor']) . " " . escapeshellarg($gateway['gateway'])); log_error("Removing static route for monitor {$gateway['monitor']} and adding a new route through {$gateway['gateway']}"); } } } } fwrite($fd, $apingerconfig); fclose($fd); if(!is_process_running("apinger")) { if (is_dir("{$g['tmp_path']}")) chmod("{$g['tmp_path']}", 01777); if (is_dir("{$g['vardb_path']}/rrd")) chown("{$g['vardb_path']}/rrd", "nobody"); /* start a new apinger process */ mwexec_bg("/usr/local/sbin/apinger -c {$g['varetc_path']}/apinger.conf"); } return 0; } /* return the status of the apinger targets as a array */ function return_gateways_status() { global $config; global $g; $gateways_arr = return_gateways_array(); $apingerstatus = array(); if(is_readable("{$g['tmp_path']}/apinger.status")) $apingerstatus = file("{$g['tmp_path']}/apinger.status"); $status = array(); foreach($apingerstatus as $line) { $fields = explode(":", $line); switch($fields[0]) { case "Target": $target = trim($fields[1]); $status[$target] = array(); $status[$target]['monitor'] = $target; foreach($gateways_arr as $name => $gateway) { if($gateway['monitor'] == "$target") { $status[$target]['gateway'] = $gateway['gateway']; $status[$target]['interface'] = $gateway['interface']; } } break; case "Description": $status[$target]['name'] = trim($fields[1]); break; case "Last reply received": $status[$target]['lastcheck'] = trim($fields[1]) .":". trim($fields[2]) .":". trim($fields[3]); break; case "Average delay": $status[$target]['delay'] = trim($fields[1]); break; case "Average packet loss": $status[$target]['loss'] = trim($fields[1]); break; case "Active alarms": $status[$target]['status'] = trim($fields[1]); break; } } return($status); } function return_gateways_array() { global $config; $gateways_arr = array(); /* Loop through all interfaces with a gateway and add it to a array */ $iflist = get_configured_interface_with_descr(); foreach($iflist as $ifname => $friendly ) { if(interface_has_gateway($ifname)) { $gateway = array(); $gateway['gateway'] = get_interface_gateway($ifname); /* Loopback dummy for dynamic interfaces without a IP */ if(!is_ipaddr(trim($gateway['gateway']))) { $gateway['gateway'] = "127.0.0.2"; } /* * do not add dynamic gateways if it is also found * in the gateways array. * XXX: NB: Can this ever happen?! * smos@ get_interface_gateway() also succeeds for * static gateways, thus they need to be excluded */ if(is_array($config['gateways']['gateway_item'])) { foreach($config['gateways']['gateway_item'] as $gateway_item) { if($gateway_item['gateway'] == $gateway['gateway']) { continue 2; } } } /* retrieve a proper monitor IP? */ if(is_ipaddr($config['interfaces'][$ifname]['monitorip'])) { $gateway['monitor'] = $config['interfaces'][$ifname]['monitorip']; } else { $gateway['monitor'] = $gateway['gateway']; } $gateway['interface'] = get_real_interface($ifname); $gateway['name'] = "{$ifname}"; $gateway['descr'] = "Interface {$friendly} Gateway"; $gateway['attribute'] = "system"; $gateways_arr[$ifname] = $gateway; } } /* tack on all the hard defined gateways as well */ if(is_array($config['gateways']['gateway_item'])) { $i = 0; foreach($config['gateways']['gateway_item'] as $gateway) { if($gateway['monitor'] == "") { $gateway['monitor'] = $gateway['gateway']; } /* include the gateway index as the attribute */ $gateway['interface'] = convert_friendly_interface_to_real_interface_name($gateway['interface']); $gateway['attribute'] = "$i"; $gateways_arr[$gateway['name']] = $gateway; $i++; } } return($gateways_arr); } /* return a array with all gateway groups with name as key * All gateway groups will be processed before returning the array. */ function return_gateway_groups_array() { global $config, $g; /* fetch the current gateways status */ $gateways_status = return_gateways_status(); $gateways_arr = return_gateways_array(); $gateway_groups_array = array(); if (is_array($config['gateways']['gateway_group'])) { foreach($config['gateways']['gateway_group'] as $group) { /* create array with group gateways members seperated by tier */ $tiers = array(); foreach($group['item'] as $item) { $itemsplit = explode("|", $item); $tier = $itemsplit[1]; $gwname = $itemsplit[0]; /* check if the gateway is available before adding it to the array */ foreach($gateways_status as $status) { if(($status['name'] != $gwname)) { continue; } if (preg_match("/down/i", $status['status'])) { $msg = "MONITOR: $gwname has high latency, removing from routing group"; log_error($msg); notify_via_growl($msg); } elseif (preg_match("/loss/i", $status['status'])) { if (strstr($group['trigger'], "loss")) { /* packet loss */ $msg = "MONITOR: $gwname has packet loss, removing from routing group"; log_error($msg); notify_via_growl($msg); } else { $tiers[$tier][] = $gwname; } } elseif (preg_match("/delay/i", $status['status'])) { if (strstr($group['trigger'] , "latency")) { /* high latency */ $msg = "MONITOR: $gwname has high latency, removing from routing group"; log_error($msg); notify_via_growl($msg); } else { $tiers[$tier][] = $gwname; } } elseif (preg_match("/none/i", $status['status'])) { /* Online add member */ $tiers[$tier][] = $gwname; } } } $tiers_count = count($tiers); if($tiers_count == 0) { /* Oh dear, we have no members! Engage Plan B */ $msg = "All gateways are unavailable, proceeding with configured XML settings!"; log_error($msg); notify_via_growl($msg); foreach($group['item'] as $item) { foreach($group['item'] as $item) { $itemsplit = explode("|", $item); $tier = $itemsplit[1]; $gwname = $itemsplit[0]; $tiers[$tier][] = $gwname; } } } /* sort the tiers array by the tier key */ ksort($tiers); /* we do not really foreach the tiers as we stop after the first tier */ foreach($tiers as $tiernr => $tier) { /* process all gateways in this tier */ $member_count = count($tier); foreach($tier as $tiernr => $member) { /* determine interface gateway */ foreach($gateways_arr as $name => $gateway) { if($gateway['name'] == $member) { $int = $gateway['interface']; if(is_ipaddr($gateway['gateway'])) $gatewayip = $gateway['gateway']; else $gatewayip = lookup_gateway_ip_by_name($gateway['gateway']); break; } } if (($int <> "") && is_ipaddr($gatewayip)) { $gateway_groups_array[$group['name']][$tiernr]['int'] = "$int"; $gateway_groups_array[$group['name']][$tiernr]['gwip'] = "$gatewayip"; } } /* we should have the 1st available tier now, exit stage left */ break; } } } return($gateway_groups_array); } /* Update DHCP WAN Interface ip address in gateway group item */ function dhclient_update_gateway_groups_defaultroute($interface = "wan") { global $config, $g; foreach($config['gateways']['gateway_item'] as & $gw) { if($gw['interface'] == $interface) { $current_gw = get_interface_gateway($interface); if($gw['gateway'] <> $current_gw) { $gw['gateway'] = $current_gw; $changed = true; } } } if($changed && $current_gw) write_config("Updating gateway group gateway for $interface - new gateway is $current_gw"); } function lookup_gateway_ip_by_name($name) { global $config; if(is_array($config['gateways']['gateway_item'])) { foreach($config['gateways']['gateway_item'] as $gateway) { if($gateway['name'] == $name) { $gatewayip = $gateway['gateway']; //$interfacegw = $gateway['interface']; return($gatewayip); } } } else { return(false); } } function lookup_gateway_monitor_ip_by_name($name) { global $config; $gateways_arr = return_gateways_array(); foreach($gateways_arr as $gateway) { if($gateway['name'] == "$name") { $monitorip = $gateway['monitor']; if($monitorip == "") $monitorip = $gateway['gateway']; return($monitorip); } } return(false); } function lookup_gateway_interface_by_name($name) { global $config; $gateways_arr = return_gateways_array(); foreach($gateways_arr as $gateway) { if($gateway['name'] == "$name") { $gatewayip = $gateway['gateway']; $interfacegw = $gateway['interface']; return($interfacegw); } } return(false); } function get_interface_gateway($interface) { global $config, $g; $iflist = get_configured_interface_with_descr(); /* * XXX: BUG: This is silly at first, but we may be called with the interface * descr for no apparent reason!!! * Probably one of those silly strtoupper() legacy stuff! */ foreach ($iflist as $ifent => $ifdesc) { if ($ifent == $interface || $ifdesc == $interface) { $interface = $ifent; break; } } $gw = NULL; $gwcfg = $config['interfaces'][$interface]; if (is_ipaddr($gwcfg['gateway'])) $gw = $gwcfg['gateway']; else if (!empty($gwcfg['gateway'])) $gw = lookup_gateway_ip_by_name($gwcfg['gateway']); // for dynamic interfaces we handle them through the $interface_router file. if (!is_ipaddr($gw)) { $realif = get_real_interface($interface); if (file_exists("{$g['tmp_path']}/{$realif}_router")) { $gw = file_get_contents("{$g['tmp_path']}/{$realif}_router"); $gw = rtrim($gw); } } /* return gateway */ return $gw; } ?>