Allow graphite to flush rrdcached based on a parameter

tmm1 · Apr 5, 2012 · 72f0117 · 72f0117
1 parent d038647
commit 72f0117
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/webapp/graphite/settings.py b/webapp/graphite/settings.py
@@ -114,6 +114,8 @@
   join(WEB_DIR, 'templates'),
 )
 
+FLUSHRRDCACHED = False
+
 #Pull in overrides from local_settings.py
 try:
   from graphite.local_settings import *

diff --git a/webapp/graphite/storage.py b/webapp/graphite/storage.py
@@ -358,6 +358,8 @@ def fetch(self, startTime, endTime):
     startString = time.strftime("%H:%M_%Y%m%d+%Ss", time.localtime(startTime))
     endString = time.strftime("%H:%M_%Y%m%d+%Ss", time.localtime(endTime))
 
+    if settings.FLUSHRRDCACHED:
+      rrdtool.flushcached(self.fs_path, '--daemon', settings.FLUSHRRDCACHED)
     (timeInfo,columns,rows) = rrdtool.fetch(self.fs_path,'AVERAGE','-s' + startString,'-e' + endString)
     colIndex = list(columns).index(self.name)
     rows.pop() #chop off the latest value because RRD returns crazy last values sometimes