diff options
author | Seth Mos <seth.mos@xs4all.nl> | 2009-05-28 09:42:42 +0200 |
---|---|---|
committer | Seth Mos <seth.mos@xs4all.nl> | 2009-05-28 09:45:54 +0200 |
commit | e1c6b3d67490c079b785ba2330a3366a2f4ecc89 (patch) | |
tree | d5eb4f73e458c63cb6896aa9edf24e935c626bcc /etc/inc/vslb.inc | |
parent | 1bc43e42e9a9e62c2bdcaeceef5754ea57c346d6 (diff) | |
download | pfsense-e1c6b3d67490c079b785ba2330a3366a2f4ecc89.zip pfsense-e1c6b3d67490c079b785ba2330a3366a2f4ecc89.tar.gz |
Backport apinger from 2.0 to 1.2
This removes the gateway support from the slbd load balancer. It will now create a apinger configuration instead.
Change syslog configuration so apinger logs to the slbd.log
Correct status page so that it shows the gateway status.
*** The current thresholds might need fine tuning or later adjustments
*** The dashboard package needs to have it's widget aligned with these changes.
Diffstat (limited to 'etc/inc/vslb.inc')
-rw-r--r-- | etc/inc/vslb.inc | 218 |
1 files changed, 158 insertions, 60 deletions
diff --git a/etc/inc/vslb.inc b/etc/inc/vslb.inc index ad050fd..f1f6882 100644 --- a/etc/inc/vslb.inc +++ b/etc/inc/vslb.inc @@ -43,7 +43,6 @@ function slbd_configure() { $fd = fopen("{$g['varetc_path']}/slbd.conf", "w"); - /* Virtual server pools */ if(is_array($a_vs)) { foreach ($a_vs as $vsent) { @@ -94,75 +93,174 @@ function slbd_configure() { } /* Gateway Pools */ + $a_settings['latencylow'] = "10"; + $a_settings['latencyhigh'] = "20"; + $a_settings['losslow'] = "100"; + $a_settings['losshigh'] = "500"; + + /* kill apinger process */ + if(is_process_running("apinger")) + mwexec("/usr/bin/killall apinger", true); + + $fda = fopen("{$g['varetc_path']}/apinger.conf", "w"); + $apingerconfig = <<<EOD +# pfSense apinger configuration file. Automatically Generated! +user "nobody" +group "nobody" +pid_file "{$g['varrun_path']}/apinger.pid" +status { + ## File where the status information whould be written to + file "/tmp/apinger.status" + ## Interval between file updates + ## when 0 or not set, file is written only when SIGUSR1 is received + interval 10s +} +rrd interval 60s; +alarm default { + command on "/usr/bin/touch /tmp/filter_dirty" + command off "/usr/bin/touch /tmp/filter_dirty" + combine 10s +} +alarm down "down" { + time 10s +} +alarm delay "delay" { + delay_low {$a_settings['latencylow']}ms + delay_high {$a_settings['latencyhigh']}ms +} +alarm loss "loss" { + percent_low {$a_settings['losslow']} + percent_high {$a_settings['losshigh']} +} +target default { + interval 1s + avg_delay_samples 10 + avg_loss_samples 50 + avg_loss_delay_samples 20 + alarms "down","delay","loss" +} + +EOD; + + /* loop all pools to create configuration */ if(is_array($a_pool)) { + /* create a list of unique IP addresses */ + $a_addresses = array(); foreach ($a_pool as $vspool) { if ($vspool['type'] != "gateway") continue; - if ($vspool['desc'] == "") - $slbdconf .= "{$vspool['name']}:\\\n"; - else - $slbdconf .= "{$vspool['name']}|{$vspool['desc']}:\\\n"; - - /* pool name */ - $slbdconf .= "\t:poolname={$vspool['name']}:\\\n"; - /* remove pool status files so we don't end up with a mismatch */ - if(file_exists("{$g['tmp_path']}/{$vspool['name']}.pool")) - unlink("{$g['tmp_path']}/{$vspool['name']}.pool"); - /* virtual IP */ - $slbdconf .= "\t:vip=127.0.0.1:\\\n"; - $slbdconf .= "\t:vip-port=666:\\\n"; - /* fallback IP */ - $slbdconf .= "\t:sitedown=127.0.0.1:\\\n"; - /* fallback port */ - $slbdconf .= "\t:sitedown-port=666:\\\n"; - - $svrcnt = 0; - $svrtxt = ""; - if($vspool['servers']) - foreach ($vspool['servers'] as $lbsvr) { - $lbsvr_split=split("\|", $lbsvr); - $svrtxt .= "\t:{$svrcnt}={$lbsvr_split[1]}:\\\n"; - $svrcnt++; - - /* Add static routes to the monitor IPs */ - $int = convert_friendly_interface_to_real_interface_name($lbsvr_split[0]); - $gateway = get_interface_gateway($int); - $int_ip = find_interface_ip($int); - if($int_ip == "0.0.0.0") { - /* DHCP Corner case. If DHCP is down, we delete the route then - * there is a chance the monitor ip gateway will go out the link - * that is up. - */ - mwexec("/sbin/route delete -host {$lbsvr_split[1]} 2>&1", true); - mwexec("/sbin/route add -host {$lbsvr_split[1]} 127.0.0.1 2>&1", true); - } else { - mwexec("/sbin/route delete -host {$lbsvr_split[1]} 2>&1", true); - mwexec("/sbin/route add -host {$lbsvr_split[1]} {$gateway} 2>&1", true); + if(is_array($vspool['servers'])) { + foreach ($vspool['servers'] as $lbsvr) { + $lbsvr_split=split("\|", $lbsvr); + $a_addresses[] = "$lbsvr_split[1]"; } } - $slbdconf .= "\t:service-port=666:\\\n"; - $slbdconf .= "\t:method=round-robin:\\\n"; - $slbdconf .= "\t:services={$svrcnt}:\\\n"; - $slbdconf .= $svrtxt; - - $slbdconf .= "\t:ping:\n"; - - $should_start=1; } + $a_addresses = array_unique($a_addresses); + + /* add static routes for each gateway with their monitor IP */ + if(!empty($a_addresses)) { + foreach($a_addresses as $address) { + $apingerconfig .= "target \"{$address}\" {\n"; + $apingerconfig .= " description \"{$address}\"\n"; + $apingerconfig .= " rrd file \"{$g['vardb_path']}/rrd/{$address}-quality.rrd\"\n"; + $apingerconfig .= "}\n"; + $apingerconfig .= "\n"; + } + fwrite($fda, $apingerconfig); + fclose($fda); + } + + foreach ($a_pool as $vspool) { + if ($vspool['type'] != "gateway") { + continue; + } + + if(is_array($vspool['servers'])) { + foreach ($vspool['servers'] as $lbsvr) { + $lbsvr_split=split("\|", $lbsvr); + + /* Add static routes to the monitor IPs */ + $int = convert_friendly_interface_to_real_interface_name($lbsvr_split[0]); + $gateway = get_interface_gateway($int); + $int_ip = find_interface_ip($int); + if($int_ip == "0.0.0.0") { + /* DHCP Corner case. If DHCP is down, we delete the route then + * there is a chance the monitor ip gateway will go out the link + * that is up. + */ + mwexec("/sbin/route delete -host {$lbsvr_split[1]} 2>&1", true); + mwexec("/sbin/route add -host {$lbsvr_split[1]} 127.0.0.1 2>&1", true); + } else { + mwexec("/sbin/route delete -host {$lbsvr_split[1]} 2>&1", true); + mwexec("/sbin/route add -host {$lbsvr_split[1]} {$gateway} 2>&1", true); + } + } + } + } + } + + if($should_start == 1) { + fwrite($fd, $slbdconf); + fclose($fd); + mwexec("/usr/bin/killall -9 slbd", true); + sleep(2); + /* startup slbd pointing it's config at /var/etc/slbd.conf with a polling interval of 5 seconds */ + mwexec("/usr/local/sbin/slbd -c{$g['varetc_path']}/slbd.conf -r5000"); + } else { + mwexec("/usr/bin/killall -9 slbd", true); + fclose($fd); + } + + if(!is_process_running("apinger") && (!empty($a_addresses))) { + 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"); } - if($should_start == 1) { - fwrite($fd, $slbdconf); - fclose($fd); - mwexec("/usr/bin/killall -9 slbd", true); - sleep(2); - /* startup slbd pointing it's config at /var/etc/slbd.conf with a polling interval of 5 seconds */ - mwexec("/usr/local/sbin/slbd -c{$g['varetc_path']}/slbd.conf -r5000"); - } else { - mwexec("/usr/bin/killall -9 slbd", true); - fclose($fd); +} + +/* return the status of the apinger targets as a array */ +function return_apinger_status() { + global $config; + global $g; + + $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; + 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); } -?>
\ No newline at end of file +?> |