{ ... } ## 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'])); mwexec("/sbin/route add -host " . escapeshellarg($gateway['monitor']) . " " . escapeshellarg($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'] = convert_friendly_interface_to_real_interface_name($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['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; } switch($status['status']) { case "None": /* Online add member */ $tiers[$tier][] = $gwname; break; case "delay": if(strstr($group['trigger'] , "latency")) { /* high latency */ log_error("MONITOR: $gwname has high latency, removing from routing group"); } else { $tiers[$tier][] = $gwname; } break; case "loss": if(strstr($group['trigger'], "loss")) { /* packet loss */ log_error("MONITOR: $gwname has packet loss, removing from routing group"); } else { $tiers[$tier][] = $gwname; } break; } } } $tiers_count = count($tiers); if($tiers_count == 0) { /* Oh dear, we have no members! Engage Plan B */ log_error("All gateways are unavailable, proceeding with configured XML settings!"); foreach($group['item'] as $item) { foreach($group['item'] as $item) { $itemsplit = explode("|", $item); $tier = $itemsplit[1]; $gwname = $itemsplit[0]; $tiers[$tier][] = $gwname; } } } /* 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); } ?>