Changeset 7 for trunk/daemon/togad.py


Ignore:
Timestamp:
03/21/05 13:59:28 (18 years ago)
Author:
bastiaans
Message:

daemon/togad.py:

Appearantly XML handling is case sensitive

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/daemon/togad.py

    r6 r7  
    2121        def startElement( self, name, attrs ):
    2222
    23                 if name == 'ganglia_xml':
    24                         self.XMLSource = attrs.get('source',"")
    25                         self.gangliaVersion = attrs.get('version',"")
     23                if name == 'GANGLIA_XML':
     24                        self.XMLSource = attrs.get('SOURCE',"")
     25                        self.gangliaVersion = attrs.get('VERSION',"")
     26                        if DEBUG: print 'Found XML data: source %s version %s' %( self.XMLSource, self.gangliaVersion )
    2627
    27                 elif name == 'grid':
    28                         self.gridName = attrs.get('name',"")
     28                elif name == 'GRID':
     29                        self.gridName = attrs.get('NAME',"")
     30                        if DEBUG: print '`-Grid found: %s' %( self.gridName )
    2931
    30                 elif name == 'cluster':
    31                         self.clusterName = attrs.get('name',"")
     32                elif name == 'CLUSTER':
     33                        self.clusterName = attrs.get('NAME',"")
     34                        if DEBUG: print ' |-Cluster found: %s' %( self.clusterName )
    3235
    33                 elif name == 'host':     
    34                         self.hostName = attrs.get('name',"")
    35                         self.hostIp = attrs.get('ip',"")
    36                         self.hostReported = attrs.get('reported',"")
     36                elif name == 'HOST':     
     37                        self.hostName = attrs.get('NAME',"")
     38                        self.hostIp = attrs.get('IP',"")
     39                        self.hostReported = attrs.get('REPORTED',"")
     40                        if DEBUG: print ' | |-Host found: %s - ip %s reported %s' %( self.hostName, self.hostIp, self.hostReported )
    3741
    38                 elif name == 'metric':
     42                elif name == 'METRIC':
    3943                        myMetric = { }
    40                         myMetric['name'] = attrs.get('name',"")
    41                         myMetric['val'] = attrs.get('val',"")
     44                        myMetric['name'] = attrs.get('NAME',"")
     45                        myMetric['val'] = attrs.get('VAL',"")
    4246
    4347                        self.metrics.append( myMetric )
     
    4650                return
    4751
    48         def endElement( self, name ):
    49                 if name == 'ganglia_xml':
    50                         if DEBUG: print 'Found XML data: source %s version %s' %( self.XMLSource, self.gangliaVersion )
     52        #def endElement( self, name ):
     53                #if name == 'ganglia_xml':
    5154
    52                 if name == 'grid':
    53                         if DEBUG: print '`-Grid found: %s' %( self.gridName )
     55                #if name == 'grid':
    5456
    55                 if name == 'cluster':
    56                         if DEBUG: print ' |-Cluster found: %s' %( self.clusterName )
     57                #if name == 'cluster':
    5758
    58                 if name == 'host':     
    59                         if DEBUG: print ' | |-Host found: %s - ip %s reported %s' %( self.hostName, self.hostIp, self.hostReported )
     59                #if name == 'host':     
    6060
    6161                #if name == 'metric':
     
    7777                                s = socket.socket(af, socktype, proto)
    7878                        except socket.error, msg:
     79                                print socket.error
     80                                print msg
    7981                                s = None
    8082                                continue
    8183                        try:
     84                                print 'connected'
    8285                                s.connect(sa)
     86                                #s.setblocking(1)
    8387                        except socket.error, msg:
    8488                                s.close()
     89                                print socket.error
     90                                print msg
    8591                                s = None
    8692                                continue
     
    9197                        sys.exit(1)
    9298
    93                 return s.makefile()
     99                return s.makefile( 'r' )
     100                #return s
    94101
    95102                #s.send('Hello, world')
     
    108115        myHandler = GangliaXMLHandler()
    109116        myParser.setContentHandler( myHandler )
     117
     118        #for line in myXMLGatherer.getFileDescriptor().readlines():
     119        #       print line
     120
    110121        myParser.parse( myXMLGatherer.getFileDescriptor() )
    111122
Note: See TracChangeset for help on using the changeset viewer.