Changeset 185 for trunk/plugin/togap.py

Timestamp:

08/04/05 09:59:56 (18 years ago)

Author:

bastiaans

Message:

plugin/togap.py:

• Added time difference detection when Torque server time and local time differ. May cause inconsistencies in job time determination

File:

• trunk/plugin/togap.py (modified) (5 diffs)

trunk/plugin/togap.py

@@ -26 +26 @@
 #
 #GMOND_CONF = '/etc/gmond.conf'
+
+# Wether or not to detect differences in 
+# time from Torque server and local time.
+#
+# Ideally both machines (if not the same)
+# should have the same time (via ntp or whatever)
+#
+DETECT_TIME_DIFFS = 1
 
 from PBSQuery import PBSQuery
@@ -127 +135 @@
 
                 self.jobs = { }
+                self.timeoffset = 0
                 self.dp = DataProcessor()
                 self.initPbsQuery()
@@ -219 +228 @@
                                         if nodeslist.count( host ) == 0:
                                                 nodeslist.append( host )
+
+                                if DETECT_TIME_DIFFS:
+
+                                        # If a job start if later than our current date,
+                                        # that must mean the Torque server's time is later
+                                        # than our local time.
+                                
+                                        if int(start_timestamp) > int( int(self.cur_time) + int(self.timeoffset) ):
+
+                                                self.timeoffset = int( int(start_timestamp) - int(self.cur_time) )
 
                         elif status == 'Q':
@@ -254 +273 @@
                         myAttrs['status'] = status
                         myAttrs['start_timestamp'] = start_timestamp
-                        myAttrs['reported'] = str( int( self.cur_time ) )
+                        myAttrs['reported'] = str( int( int( self.cur_time ) + int( self.timeoffset ) ) )
                         myAttrs['nodes'] = nodeslist
                         myAttrs['domain'] = string.join( socket.getfqdn().split( '.' )[1:], '.' )
@@ -277 +296 @@
                 """Submit job info list"""
 
-                self.dp.multicastGmetric( 'TOGA-HEARTBEAT', str( int( self.cur_time ) ) )
+                self.dp.multicastGmetric( 'TOGA-HEARTBEAT', str( int( int( self.cur_time ) + int( self.timeoffset ) ) ) )
 
                 # Now let's spread the knowledge