added rrdtool

1 files changed, 11 insertions, 2 deletions

diff --git a/src/daq/flumotion-rrd/flumotion-rrd.py b/src/daq/flumotion-rrd/flumotion-rrd.py
index a661e31..71d3257 100755
--- a/src/daq/flumotion-rrd/flumotion-rrd.py
+++ b/src/daq/flumotion-rrd/flumotion-rrd.py
@@ -35,6 +35,7 @@ from twisted.internet import protocol, reactor
 from socket import error as socket_error
 import simplejson as json
 import datetime
+import rrdtool
 
 _MAX_PACKET_SIZE = 8192 # in bytes
 
@@ -63,7 +64,6 @@ class SFiveProto(protocol.ConnectedDatagramProtocol):
             self._importer._socketError()
 
 
-
 class FlumotionRRD():
     """Class to batch import flumotion rrd statistics into the spreadspace streaming statistic suite"""
 
@@ -76,6 +76,8 @@ class FlumotionRRD():
         self._format = properties['format']
         self._quality = properties['quality']
         self._tags = properties['tags']
+        self._bytes_rrdfile = properties['bytes-rrdfile']
+        self._clients_rrdfile = properties['clients-rrdfile']
 
         self._proto = None
         self._conn = None
@@ -96,14 +98,21 @@ class FlumotionRRD():
 
     def _socketReady(self):
         print 'SFive: connection to sfive hub established'
+        self._importRRD()
         self._sendInit()
-
         # TODO: start data import
         self._sendDataset(datetime.datetime.utcnow(), 5, 17, 1214, 14214)
         print 'SFive: sent %d datasets' % (1)
 
         reactor.stop()
 
+    def _importRRD(self):
+        print "bytes:\n"
+        print rrdtool.info(self._bytes_rrdfile)
+
+        print "\n\nclients:\n"
+        print rrdtool.info(self._clients_rrdfile)
+
     def _sendInit(self):
         initdata = { "hostname": self._hostname,
                      "streamer-id": { "content-id": self._content_id, "format": self._format, "quality": self._quality },