var/deb-package/cluster_raw_old/opt/cluster/lib/www/ganglia/ganglia.php

   1 <?php
   2 /* $Id: ganglia.php 809 2007-07-12 06:34:23Z bernardli $ */
   3 #
   4 # Parses ganglia XML tree.
   5 #
   6 # The arrays defined in the first part of this file to hold XML info.
   7 #
   8 # sacerdoti: These are now context-sensitive, and hold only as much
   9 # information as we need to make the page.
  10 #
  11
  12 $error="";
  13
  14 # Gives time in seconds to retrieve and parse XML tree. With subtree-
  15 # capable gmetad, should be very fast in all but the largest cluster configurations.
  16 $parsetime = 0;
  17
  18 # 2key = "Source Name" / "NAME | AUTHORITY | HOSTS_UP ..." = Value.
  19 $grid = array();
  20
  21 # 1Key = "NAME | LOCALTIME | HOSTS_UP | HOSTS_DOWN" = Value.
  22 $cluster = array();
  23
  24 # 2Key = "Cluster Name / Host Name" ... Value = Array of Host Attributes
  25 $hosts_up = array();
  26 # 2Key = "Cluster Name / Host Name" ... Value = Array of Host Attributes
  27 $hosts_down = array();
  28
  29 # Context dependant structure.
  30 $metrics = array();
  31
  32 # 1Key = "Component" (gmetad | gmond) = Version string
  33 $version = array();
  34
  35 # The web frontend version, from conf.php.
  36 #$version["webfrontend"] = "$majorversion.$minorversion.$microversion";
  37 $version["webfrontend"] = "$ganglia_version";
  38
  39 # Get rrdtool version
  40 $rrdtool_version = array();
  41 exec(RRDTOOL, $rrdtool_version);
  42 $rrdtool_version = explode(" ", $rrdtool_version[0]);
  43 $rrdtool_version = $rrdtool_version[1];
  44 $version["rrdtool"] = "$rrdtool_version";
  45
  46 # The name of our local grid.
  47 $self = " ";
  48
  49
  50 # Returns true if the host is alive. Works for both old and new gmond sources.
  51 function host_alive($host, $cluster)
  52 {
  53    $TTL = 60;
  54
  55    if ($host['TN'] and $host['TMAX']) {
  56       if ($host['TN'] > $host['TMAX'] * 4)
  57          return FALSE;
  58          $host_up = FALSE;
  59    }
  60    else {      # The old method.
  61       if (abs($cluster["LOCALTIME"] - $host['REPORTED']) > (4*$TTL))
  62          return FALSE;
  63    }
  64    return TRUE;
  65 }
  66
  67
  68 # Called with <GANGLIA_XML> attributes.
  69 function preamble($ganglia)
  70 {
  71    global $version;
  72
  73    $component = $ganglia['SOURCE'];
  74    $version[$component] = $ganglia['VERSION'];
  75 }
  76
  77
  78 function start_meta ($parser, $tagname, $attrs)
  79 {
  80    global $metrics, $grid, $self;
  81    static $sourcename, $metricname;
  82
  83    switch ($tagname)
  84       {
  85          case "GANGLIA_XML":
  86             preamble($attrs);
  87             break;
  88
  89          case "GRID":
  90          case "CLUSTER":
  91             # Our grid will be first.
  92             if (!$sourcename) $self = $attrs['NAME'];
  93
  94             $sourcename = $attrs['NAME'];
  95             $grid[$sourcename] = $attrs;
  96
  97             # Identify a grid from a cluster.
  98             $grid[$sourcename][$tagname] = 1;
  99             break;
 100
 101          case "METRICS":
 102             $metricname = $attrs['NAME'];
 103             $metrics[$sourcename][$metricname] = $attrs;
 104             break;
 105
 106          case "HOSTS":
 107             $grid[$sourcename]['HOSTS_UP'] = $attrs['UP'];
 108             $grid[$sourcename]['HOSTS_DOWN'] = $attrs['DOWN'];
 109             break;
 110
 111          default:
 112             break;
 113       }
 114 }
 115
 116
 117 function start_cluster ($parser, $tagname, $attrs)
 118 {
 119    global $metrics, $cluster, $self, $grid, $hosts_up, $hosts_down;
 120    static $hostname;
 121
 122    switch ($tagname)
 123       {
 124          case "GANGLIA_XML":
 125             preamble($attrs);
 126             break;
 127          case "GRID":
 128             $self = $attrs['NAME'];
 129             $grid = $attrs;
 130             break;
 131
 132          case "CLUSTER":
 133             $cluster = $attrs;
 134             break;
 135
 136          case "HOST":
 137             $hostname = $attrs['NAME'];
 138
 139             if (host_alive($attrs, $cluster))
 140                {
 141                   isset($cluster['HOSTS_UP']) or $cluster['HOSTS_UP'] = 0;
 142                   $cluster['HOSTS_UP']++;
 143                   $hosts_up[$hostname] = $attrs;
 144                }
 145             else
 146                {
 147                   isset($cluster['HOSTS_DOWN']) or $cluster['HOSTS_DOWN'] = 0;
 148                   $cluster['HOSTS_DOWN']++;
 149                   $hosts_down[$hostname] = $attrs;
 150                }
 151             break;
 152
 153          case "METRIC":
 154             $metricname = $attrs['NAME'];
 155             $metrics[$hostname][$metricname] = $attrs;
 156             break;
 157
 158          default:
 159             break;
 160       }
 161 }
 162
 163
 164 function start_cluster_summary ($parser, $tagname, $attrs)
 165 {
 166    global $metrics, $cluster, $self, $grid;
 167
 168    switch ($tagname)
 169       {
 170          case "GANGLIA_XML":
 171             preamble($attrs);
 172             break;
 173          case "GRID":
 174             $self = $attrs['NAME'];
 175             $grid = $attrs;
 176          case "CLUSTER":
 177             $cluster = $attrs;
 178             break;
 179
 180          case "HOSTS":
 181             $cluster['HOSTS_UP'] = $attrs['UP'];
 182             $cluster['HOSTS_DOWN'] = $attrs['DOWN'];
 183             break;
 184
 185          case "METRICS":
 186             $metrics[$attrs['NAME']] = $attrs;
 187             break;
 188
 189          default:
 190             break;
 191       }
 192 }
 193
 194
 195 function start_host ($parser, $tagname, $attrs)
 196 {
 197    global $metrics, $cluster, $hosts_up, $hosts_down, $self, $grid;
 198
 199    switch ($tagname)
 200       {
 201          case "GANGLIA_XML":
 202             preamble($attrs);
 203             break;
 204          case "GRID":
 205             $self = $attrs['NAME'];
 206             $grid = $attrs;
 207             break;
 208          case "CLUSTER":
 209             $cluster = $attrs;
 210             break;
 211
 212          case "HOST":
 213             if (host_alive($attrs, $cluster))
 214                $hosts_up = $attrs;
 215             else
 216                $hosts_down = $attrs;
 217             break;
 218
 219          case "METRIC":
 220             $metrics[$attrs['NAME']] = $attrs;
 221             break;
 222
 223          default:
 224             break;
 225       }
 226 }
 227
 228
 229 function end_all ($parser, $tagname)
 230 {
 231
 232 }
 233
 234
 235 function Gmetad ()
 236 {
 237    global $error, $parsetime, $clustername, $hostname, $context;
 238    # From conf.php:
 239    global $ganglia_ip, $ganglia_port;
 240
 241    # Parameters are optionalshow
 242    # Defaults...
 243    $ip = $ganglia_ip;
 244    $port = $ganglia_port;
 245    $timeout = 3.0;
 246    $errstr = "";
 247    $errno  = "";
 248
 249    switch( func_num_args() )
 250       {
 251          case 2:
 252             $port = func_get_arg(1);
 253          case 1:
 254             $ip = func_get_arg(0);
 255       }
 256
 257    $parser = xml_parser_create();
 258    switch ($context)
 259       {
 260          case "meta":
 261          case "control":
 262          case "tree":
 263          default:
 264             xml_set_element_handler($parser, "start_meta", "end_all");
 265             $request = "/?filter=summary";
 266             break;
 267          case "physical":
 268          case "cluster":
 269             xml_set_element_handler($parser, "start_cluster", "end_all");
 270             $request = "/$clustername";
 271              break;
 272          case "cluster-summary":
 273             xml_set_element_handler($parser, "start_cluster_summary", "end_all");
 274             $request = "/$clustername?filter=summary";
 275             break;
 276          case "node":
 277          case "host":
 278             xml_set_element_handler($parser, "start_host", "end_all");
 279             $request = "/$clustername/$hostname";
 280             break;
 281       }
 282
 283   $fp = fsockopen( $ip, $port, $errno, $errstr, $timeout);
 284    if (!$fp)
 285       {
 286          $error = "fsockopen error: $errstr";
 287          return FALSE;
 288       }
 289
 290    if ($port == 8649)
 291       {
 292          # We are connecting to a gmond. Non-interactive.
 293          xml_set_element_handler($parser, "start_cluster", "end_all");
 294       }
 295    else
 296       {
 297          $request .= "\n";
 298          $rc = fputs($fp, $request);
 299          if (!$rc)
 300             {
 301                $error = "Could not sent request to gmetad: $errstr";
 302                return FALSE;
 303             }
 304       }
 305
 306    $start = gettimeofday();
 307
 308    while(!feof($fp))
 309       {
 310          $data = fread($fp, 16384);
 311          if (!xml_parse($parser, $data, feof($fp)))
 312             {
 313                $error = sprintf("XML error: %s at %d",
 314                   xml_error_string(xml_get_error_code($parser)),
 315                   xml_get_current_line_number($parser));
 316                fclose($fp);
 317                return FALSE;
 318             }
 319       }
 320    fclose($fp);
 321
 322    $end = gettimeofday();
 323    $parsetime = ($end['sec'] + $end['usec']/1e6) - ($start['sec'] + $start['usec']/1e6);
 324
 325    return TRUE;
 326 }
 327
 328 ?>