Changeset 929 for branches/1.1
- Timestamp:
- 07/31/13 16:27:18 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/1.1/jobarchived/jobarchived.py
r928 r929 932 932 """ 933 933 934 global ARCHIVE_DATASOURCES935 936 934 jobinfo = { } 937 935 … … 1027 1025 debug_msg( 10, 'jobinfo for job %s has changed' %jobid ) 1028 1026 else: 1029 debug_msg( 1 0, 'new job %s' %jobid )1027 debug_msg( 1, 'new job %s' %jobid ) 1030 1028 1031 1029 if not jobid in self.jobs_to_store: … … 1146 1144 """Find all existing clusters in archive dir""" 1147 1145 1148 global ARCHIVE_DATASOURCES1149 1150 1146 archive_dir = check_dir(ARCHIVE_PATH) 1151 1147 … … 1177 1173 self.clusters[ clustername ] = RRDHandler( self.config, clustername ) 1178 1174 1179 debug_msg( 9, 'Found cluster dir: %s' %( clustername ) ) 1180 1181 debug_msg( 9, "Found "+str(len(self.clusters.keys()))+" cluster dirs" ) 1175 debug_msg( 9, "Found "+str(len(self.clusters.keys()))+" clusters" ) 1182 1176 1183 1177 def startElement( self, name, attrs ): 1184 1178 """Memorize appropriate data from xml start tags""" 1185 1179 1186 global ARCHIVE_DATASOURCES1187 1188 1180 if name == 'GANGLIA_XML': 1189 1181 … … 1209 1201 self.clusters[ self.clusterName ] = RRDHandler( self.config, self.clusterName ) 1210 1202 1211 debug_msg( 10, ' |-Cluster found: %s' %( self.clusterName ) )1203 debug_msg( 10, ' |-Cluster found: %s' %( self.clusterName ) ) 1212 1204 1213 1205 elif name == 'HOST' and self.clusterName in ARCHIVE_DATASOURCES: … … 1246 1238 self.clusters[ self.clusterName ].memMetric( self.hostName, myMetric ) 1247 1239 1248 debug_msg( 9, 'added metric %s from host %s to cluster %s' %( myMetric['name'], self.hostName, self.clusterName ) )1249 1240 debug_msg( 11, ' | | |-metric: %s:%s' %( myMetric['name'], myMetric['val'] ) ) 1250 1241 … … 1679 1670 """Class for handling RRD activity""" 1680 1671 1672 myMetrics = { } 1673 lastStored = { } 1674 timeserials = { } 1675 slot = None 1681 1676 1682 1677 def __init__( self, config, cluster ): … … 1689 1684 self.config = config 1690 1685 self.slot = threading.Lock() 1691 self.myMetrics = { }1692 self.lastStored = { }1693 self.timeserials = { }1694 1686 1695 1687 if MODRRDTOOL:
Note: See TracChangeset
for help on using the changeset viewer.