1 files changed, 133 insertions, 0 deletions
diff --git a/stats_consolidation/build/lib.linux-x86_64-2.7/stats_consolidation/rrd_files.py b/stats_consolidation/build/lib.linux-x86_64-2.7/stats_consolidation/rrd_files.py
new file mode 100644
index 0000000..a437e0d
--- /dev/null
+++ b/stats_consolidation/build/lib.linux-x86_64-2.7/stats_consolidation/rrd_files.py
@@ -0,0 +1,133 @@
+import rrdtool
+import os
+import sys
+
+class RRD:
+
+	hdr_item  = 0
+	ds_item   = 1
+	data_item = 2
+	DS = {'active':0, 'buddies':0, 'instances':0, 'new':0, 'resumed':0, 'uptime':0}
+
+	def __init__(self, path, name, date_start, date_end):
+
+		self.rrd_name = name
+
+		if date_start == None:
+			self.date_start = str(rrdtool.first(str(os.path.join (path,name))))
+		else:
+			self.date_start = str(date_start)
+			
+
+		if date_end == None:
+			self.date_end = str(rrdtool.last(str(os.path.join(path, name))))
+		else:
+			self.date_end   = str(date_end)
+		
+		self.user_hash = os.path.split(path)[1]
+		
+		self.user_path = os.path.join (
+					self.get_first_part_path(path, 3),
+					"users",
+					"user",
+					self.user_hash[:2],
+					self.user_hash
+					)
+			
+		self.uuid = self.get_uuid_from_file(self.user_path) 
+
+
+		print "*******************************************"
+		print "                  RRD                      "
+		print "start: " + self.date_start
+		print "end: "  + self.date_end
+		print "PATH: " + path
+		print "RRD NAME: " + name
+		print "\n"
+		try:
+			self.rrd = rrdtool.fetch (str(os.path.join(path,name)), 'AVERAGE', '-r 60', '-s '+ self.date_start, '-e '+self.date_end)
+		except:
+			raise
+
+		print "                   DS                       "			
+		for item in self.DS.keys():
+			idx = self.get_ds_index (item)
+			if idx != -1:
+				self.DS[item] = idx
+				print "DS "+ item + ": " + str(self.DS[item])
+			else:
+				print "DS "+ item + " not found in header"
+		print "***********************************************"
+
+	def get_ds_index(self, ds): 
+		i=0
+		for i in range (len (self.rrd[self.ds_item])):
+			if self.rrd[self.ds_item][i] == ds:
+				return i
+			i=+1
+		return -1
+
+	def get_uptime_by_interval (self):
+		ds_name = "uptime"
+		res=list()
+	
+		print "-------Calcule "+ ds_name +"-------"
+		i=0
+		found = False
+		while i < len(self.rrd[self.data_item]):
+			value     = str(self.rrd[self.data_item][i][self.DS[ds_name]])
+			if value != "None":
+				uptime = value
+				end    = str (long(self.date_start) + ((i+1) * 60))
+				if found == False:
+					found = True
+					start = str (long (self.date_start) + ((i+1) * 60))
+			else:
+				if found:
+					print start + "->" + end + ": " + uptime
+					if float(uptime) > 0:
+						res.append((start, uptime))
+					found = False
+			i=i+1
+		return res
+		print "---------------------------------------------------"
+
+
+	def get_name(self):
+		return self.rrd_name.partition(".rrd")[0]
+
+	def show_valid_ds(self, ds_name):
+		print "------------------- DS "+ ds_name +"---------------------"
+		i=0
+		while i < len(self.rrd[self.data_item]):
+			timestamp = str (long (self.date_start) + ((i+1) * 60))
+			value     = str (self.rrd[self.data_item][i][self.DS[ds_name]])
+	
+			if value != "None":
+				print timestamp+ ": " + value
+			i=i+1
+		print "---------------------------------------------------"
+
+
+	def get_date_last_record(self):
+		return self.date_end
+
+	def set_user_hash(self, u_hash):
+		self.user_hash = u_hash
+
+	def get_first_part_path (self, path, idx):
+                l=list()
+                l.append(path)
+                for i in range (idx):
+                        l.append(os.path.split(l[i])[0])
+                return l[idx]
+
+	def get_uuid_from_file(self,path):
+		return open (os.path.join(path, "machine_uuid")).next()
+
+		
+	def get_user_hash(self):
+		return self.user_hash
+
+	def get_uuid (self):
+		return self.uuid