Changeset 60

Timestamp:

04/11/05 12:14:53 (18 years ago)

Author:

bastiaans

Message:

daemon/togad.py:

• Options added for toga joblist handling server

File:

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

trunk/daemon/togad.py

@@ -14 +14 @@
 import random
 from types import *
+import DBClass
 
 # Specify debugging level here;
@@ -29 +30 @@
 GMETAD_CONF = '/etc/gmetad.conf'
 
+# Wether or not to maintain a archive of all ganglia node data
+# Note: This will require a significant amount of hd space
+#       depending on your cluster size
+#
+ARCHIVE = 0
+
+# Where to grab XML data from
+# Normally: local gmetad (port 8651)
+#
+ARCHIVE_SOURCE = "localhost:8651"
+
+# List of data_source names to archive for
+#
+ARCHIVE_DATASOURCES = [ "LISA Cluster" ]
+
 # Where to store the archived rrd's
 #
 ARCHIVE_PATH = '/data/toga/rrds'
 
-# List of data_source names to archive for
-#
-ARCHIVE_SOURCES = [ "LISA Cluster" ]
-
 # Amount of hours to store in one single archived .rrd
 #
 ARCHIVE_HOURS_PER_RRD = 12
+
+# Wether or not to run a seperate Toga jobinfo server
+#
+TOGA_SERVER = 1
+
+# On what interfaces to listen
+#
+TOGA_SERVER_INTERFACES = [ 'eth0' ]
+
+# On what port to listen
+#
+TOGA_SERVER_PORT = 9048
+
+# Toga's SQL dbase name to use
+#
+TOGA_SERVER_SQL_DBASE = "toga"
 
 # Wether or not to run as a daemon in background
@@ -51 +79 @@
 ######################
 
+###
+# You'll only want to change anything below here unless you 
+# know what you are doing (i.e. your name is Ramon Bastiaans)
+###
+
 # What XML data types not to store
 #
@@ -66 +99 @@
 This is TOrque-GAnglia's data Daemon
 """
+
+#class TogaServer:
+
+#class TogaXMLHandler( ContentHandler ):
 
 class RRDMutator:
@@ -152 +189 @@
                                 clustername = item
 
-                                if not self.clusters.has_key( clustername ) and clustername in ARCHIVE_SOURCES:
+                                if not self.clusters.has_key( clustername ) and clustername in ARCHIVE_DATASOURCES:
 
                                         self.clusters[ clustername ] = RRDHandler( self.config, clustername )
@@ -178 +215 @@
                         self.time = attrs.get( 'LOCALTIME', "" )
 
-                        if not self.clusters.has_key( self.clusterName ) and self.clusterName in ARCHIVE_SOURCES:
+                        if not self.clusters.has_key( self.clusterName ) and self.clusterName in ARCHIVE_DATASOURCES:
 
                                 self.clusters[ self.clusterName ] = RRDHandler( self.config, self.clusterName )
@@ -184 +221 @@
                                 debug_msg( 10, ' |-Cluster found: %s' %( self.clusterName ) )
 
-                elif name == 'HOST' and self.clusterName in ARCHIVE_SOURCES:     
+                elif name == 'HOST' and self.clusterName in ARCHIVE_DATASOURCES:     
 
                         self.hostName = attrs.get( 'NAME', "" )
@@ -192 +229 @@
                         debug_msg( 10, ' | |-Host found: %s - ip %s reported %s' %( self.hostName, self.hostIp, self.hostReported ) )
 
-                elif name == 'METRIC' and self.clusterName in ARCHIVE_SOURCES:
+                elif name == 'METRIC' and self.clusterName in ARCHIVE_DATASOURCES:
 
                         type = attrs.get( 'TYPE', "" )
@@ -295 +332 @@
                 self.config = GangliaConfigParser( GMETAD_CONF )
 
-                self.myXMLGatherer = GangliaXMLGatherer( 'localhost', 8651 ) 
+                self.myXMLGatherer = GangliaXMLGatherer( ARCHIVE_SOURCE.split( ':' )[0], ARCHIVE_SOURCE.split( ':' )[1] ) 
                 self.myParser = make_parser()   
                 self.myHandler = GangliaXMLHandler( self.config )
@@ -859 +896 @@
         "Program startup"
 
-        myProcessor = GangliaXMLProcessor()
-
-        if DAEMONIZE:
-                myProcessor.daemon()
-        else:
-                myProcessor.run()
+        if TOGA_SERVER:
+        
+                myServer = TogaServer()
+
+                if DAEMONIZE:
+                        myServer.daemon()
+                else:
+                        myServer.run()
+
+        if ARCHIVE:
+
+                myProcessor = GangliaXMLProcessor()
+
+                if DAEMONIZE:
+                        myProcessor.daemon()
+                else:
+                        myProcessor.run()
 
 def check_dir( directory ):