Changeset 7
- Timestamp:
- 03/21/05 13:59:28 (19 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/daemon/togad.py
r6 r7 21 21 def startElement( self, name, attrs ): 22 22 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 ) 26 27 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 ) 29 31 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 ) 32 35 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 ) 37 41 38 elif name == ' metric':42 elif name == 'METRIC': 39 43 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',"") 42 46 43 47 self.metrics.append( myMetric ) … … 46 50 return 47 51 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': 51 54 52 if name == 'grid': 53 if DEBUG: print '`-Grid found: %s' %( self.gridName ) 55 #if name == 'grid': 54 56 55 if name == 'cluster': 56 if DEBUG: print ' |-Cluster found: %s' %( self.clusterName ) 57 #if name == 'cluster': 57 58 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': 60 60 61 61 #if name == 'metric': … … 77 77 s = socket.socket(af, socktype, proto) 78 78 except socket.error, msg: 79 print socket.error 80 print msg 79 81 s = None 80 82 continue 81 83 try: 84 print 'connected' 82 85 s.connect(sa) 86 #s.setblocking(1) 83 87 except socket.error, msg: 84 88 s.close() 89 print socket.error 90 print msg 85 91 s = None 86 92 continue … … 91 97 sys.exit(1) 92 98 93 return s.makefile() 99 return s.makefile( 'r' ) 100 #return s 94 101 95 102 #s.send('Hello, world') … … 108 115 myHandler = GangliaXMLHandler() 109 116 myParser.setContentHandler( myHandler ) 117 118 #for line in myXMLGatherer.getFileDescriptor().readlines(): 119 # print line 120 110 121 myParser.parse( myXMLGatherer.getFileDescriptor() ) 111 122
Note: See TracChangeset
for help on using the changeset viewer.