Changeset 930

Timestamp:

07/31/13 16:33:20 (10 years ago)

Author:

ramonb

Message:

jobarchived/jobarchived.py:

• rearranged RRDHandler's class variables to be explicitly set in constructor so that they are local to instance
• small changes to debug messages
• see #173

File:

• branches/1.1/jobarchived/jobarchived.py (modified) (8 diffs)

branches/1.1/jobarchived/jobarchived.py

@@ -932 +932 @@
         """
 
+        global ARCHIVE_DATASOURCES
+
         jobinfo = { }
 
@@ -1025 +1027 @@
                     debug_msg( 10, 'jobinfo for job %s has changed' %jobid )
             else:
-                debug_msg( 1, 'new job %s' %jobid )
+                debug_msg( 10, 'new job %s' %jobid )
 
                 if not jobid in self.jobs_to_store:
@@ -1144 +1146 @@
         """Find all existing clusters in archive dir"""
 
+        global ARCHIVE_DATASOURCES
+
         archive_dir    = check_dir(ARCHIVE_PATH)
 
@@ -1173 +1177 @@
                     self.clusters[ clustername ] = RRDHandler( self.config, clustername )
 
-        debug_msg( 9, "Found "+str(len(self.clusters.keys()))+" clusters" )
+                    debug_msg( 9, 'Found cluster dir: %s' %( clustername ) )
+
+        debug_msg( 9, "Found "+str(len(self.clusters.keys()))+" cluster dirs" )
 
     def startElement( self, name, attrs ):
         """Memorize appropriate data from xml start tags"""
 
+        global ARCHIVE_DATASOURCES
+
         if name == 'GANGLIA_XML':
 
@@ -1201 +1209 @@
                 self.clusters[ self.clusterName ] = RRDHandler( self.config, self.clusterName )
 
-                debug_msg( 10, ' |-Cluster found: %s' %( self.clusterName ) )
+            debug_msg( 10, ' |-Cluster found: %s' %( self.clusterName ) )
 
         elif name == 'HOST' and self.clusterName in ARCHIVE_DATASOURCES:     
@@ -1238 +1246 @@
                 self.clusters[ self.clusterName ].memMetric( self.hostName, myMetric )
 
+                debug_msg( 9, 'added metric %s from host %s to cluster %s' %( myMetric['name'], self.hostName, self.clusterName ) )
                 debug_msg( 11, ' | | |-metric: %s:%s' %( myMetric['name'], myMetric['val'] ) )
 
@@ -1670 +1679 @@
     """Class for handling RRD activity"""
 
-    myMetrics   = { }
-    lastStored  = { }
-    timeserials = { }
-    slot = None
 
     def __init__( self, config, cluster ):
@@ -1684 +1689 @@
         self.config  = config
         self.slot    = threading.Lock()
+        self.myMetrics   = { }
+        self.lastStored  = { }
+        self.timeserials = { }
 
         if MODRRDTOOL: