Changeset 43 for trunk

Timestamp:

04/05/05 16:24:32 (18 years ago)

Author:

bastiaans

Message:

daemon/togad.py:

• Problem was caused by gmetad! Bug!!
• Reported to developers.

• togad seems to be working

To do: check in memory rrd values to which file they belong before writing

• Now all values are written to the latest cycled rrd

File:

• trunk/daemon/togad.py (modified) (7 diffs)

trunk/daemon/togad.py

@@ -23 +23 @@
 # 7  = daemon threading
 #
-DEBUG_LEVEL = 9
+DEBUG_LEVEL = 7
 
 # Where is the gmetad.conf located
@@ -39 +39 @@
 # Amount of hours to store in one single archived .rrd
 #
-ARCHIVE_HOURS_PER_RRD = 1
+ARCHIVE_HOURS_PER_RRD = 12
 
 # Wether or not to run as a daemon in background
@@ -348 +348 @@
                 # Store metrics somewhere between every 60 and 180 seconds
                 #
-                #STORE_INTERVAL = random.randint( 60, 180 )
-                STORE_INTERVAL = 180
+                STORE_INTERVAL = random.randint( 60, 180 )
+                #STORE_INTERVAL = 30
 
                 storethread = threading.Thread( None, self.storeThread, 'storemetricthread' )
@@ -393 +393 @@
 
                         debug_msg( 7, self.printTime() + ' - xmlthread(): parsethread() still running, waiting to finish..' )
-                        parsethread.join( 60 ) # Maximum time for XML thread to finish
+                        parsethread.join( 180 ) # Maximum time for XML thread to finish
                         debug_msg( 7, self.printTime() + ' - xmlthread(): Done waiting.' )
 
@@ -592 +592 @@
                                 if self.checkStoreMetric( host, metricname, metric ):
                                         update_list.append( '%s:%s' %( metric['time'], metric['val'] ) )
-                                else:
-                                        print 'allready wrote metric %s with timestamp %s' %( metric['name'], metric['time'] )
+                                #else:
+                                        #print 'allready wrote metric %s with timestamp %s' %( metric['name'], metric['time'] )
 
                 return update_list
@@ -603 +603 @@
                         if self.lastStored[ host ].has_key( metricname ):
 
-                                if self.lastStored[ host ][ metricname ] <= metric['time']:
+                                if metric['time'] <= self.lastStored[ host ][ metricname ]:
 
                                         # Allready wrote a value with this timestamp, skip tnx
@@ -631 +631 @@
                                 else:
                                         debug_msg( 9, 'metric update failed' )
+
+                                #sys.exit(1)
 
         def makeTimeSerial( self ):