Changeset 163 for trunk/web/addons/toga/libtoga.php

Timestamp:

06/23/05 10:17:37 (19 years ago)

Author:

bastiaans

Message:

web/addons/toga/conf.php:

• Set to actual gmetad port (was gmond's)

web/addons/toga/image.php:

• clustername parse fix

web/addons/toga/libtoga.php:

• Made ClusterImage?, DataGatherer?, TorqueXMLHandler really only parse a certain cluster

web/addons/toga/overview.php:

• Use clustername when getting data

File:

• trunk/web/addons/toga/libtoga.php (modified) (8 diffs)

trunk/web/addons/toga/libtoga.php

@@ -399 +399 @@
         var $xmlhandler, $data, $httpvars;
 
-        function DataGatherer() {
+        function DataGatherer( $cluster ) {
 
                 global $DATA_SOURCE;
-                
+        
+                //printf("dg cluster = %s\n", $cluster );
                 $ds_fields = explode( ':', $DATA_SOURCE );
                 $ds_ip = $ds_fields[0];
@@ -411 +412 @@
                 $this->parser = xml_parser_create();
                 $this->httpvars = $httpvars;
-                $this->xmlhandler = new TorqueXMLHandler();
+                $this->xmlhandler = new TorqueXMLHandler( $cluster );
                 xml_set_element_handler( $this->parser, array( &$this->xmlhandler, 'startElement' ), array( &$this->xmlhandler, 'stopElement' ) );
         }
@@ -452 +453 @@
 class TorqueXMLHandler {
 
-        var $clusters, $heartbeat, $nodes, $jobs;
-
-        function TorqueXMLHandler() {
+        var $clusters, $heartbeat, $nodes, $jobs, $clustername, $proc_cluster;
+
+        function TorqueXMLHandler( $clustername ) {
                 $jobs = array();
                 $clusters = array();
-                $nodes = array();
+                $this->nodes = array();
                 $heartbeat = array();
+                $this->clustername = $clustername;
+                //printf(" cluster set to %s \n", $this->clustername );
         }
 
@@ -489 +492 @@
                 $jobid = null;
 
-                // printf( '%s=%s', $attrs[NAME], $attrs[VAL] );
+                //printf( '%s=%s', $attrs[NAME], $attrs[VAL] );
+
+                //printf( "clustername = %s proc_cluster = %s\n", $this->clustername, $this->proc_cluster );
 
                 if( $name == 'CLUSTER' ) {
 
-                        $clustername = $attrs[VAL];
-
-                        if( !isset( $clusters[$clustername] ) )
-                                $clusters[$clustername] = array();
-
-                } else if( $name == 'HOST' ) {
+                        $this->proc_cluster = $attrs[NAME];
+                        //printf( "Found cluster %s\n", $attrs[NAME] );
+                        //print_r( $attrs );
+
+                        //if( !isset( $clusters[$clustername] ) )
+                        //      $clusters[$clustername] = array();
+
+                } else if( $name == 'HOST' and $this->proc_cluster == $this->clustername) {
 
                         $hostname = $attrs[NAME];
                         $location = $attrs[LOCATION];
+                        //printf( "Found node %s\n", $hostname );
 
                         if( !isset( $this->nodes[$hostname] ) )
-                                $this->nodes[$hostname] = new NodeImage( $hostname );
-
-                } else if( $name == 'METRIC' and strstr( $attrs[NAME], 'TOGA' ) ) {
+                                $nodes[$hostname] = new NodeImage( $hostname );
+
+                } else if( $name == 'METRIC' and strstr( $attrs[NAME], 'TOGA' ) and $this->proc_cluster == $this->clustername ) {
 
                         if( strstr( $attrs[NAME], 'TOGA-HEARTBEAT' ) ) {
@@ -576 +584 @@
                                                                 $my_node->addJob( $jobid, 1 );
 
-                                                $this->nodes[$host] = $my_node;
+                                                $nodes[$host] = $my_node;
                                         }
                                 }
@@ -582 +590 @@
                 }
                 $this->jobs = $jobs;
+                //print_r( $nodes );
+                $this->nodes = $nodes;
         }
 
@@ -625 +635 @@
 
         function getNodes() {
+                //print_r( $this->nodes );
                 return $this->nodes;
         }
@@ -794 +805 @@
         function ClusterImage( $clustername ) {
 
-                $this->dataget = new DataGatherer();
+                //printf( "image cluster = %s\n", $clustername );
+                $this->dataget = new DataGatherer( $clustername );
                 $this->clustername = $clustername;
                 $this->filters = array();