Changeset 75


Ignore:
Timestamp:
04/15/05 11:56:55 (19 years ago)
Author:
bastiaans
Message:

plugin/togap.py:

  • Misc fixes for compatibility with toga daemon
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/plugin/togap.py

    r69 r75  
    4040                        self.binary = binary
    4141
    42                 self.dmax = TORQUE_POLL_INTERVAL
     42                self.tmax = str( TORQUE_POLL_INTERVAL )
    4343
    4444                try:
     
    9292                return incompatible
    9393
    94         def multicastGmetric( self, metricname, metricval, valtype='string', tmax='15' ):
     94        def multicastGmetric( self, metricname, metricval, valtype='string' ):
    9595                """Call gmetric binary and multicast"""
    9696
     
    102102                        debug_msg( 10, 'Assuming /etc/gmond.conf for gmetric cmd (ommitting)' )
    103103
    104                 cmd = cmd + ' -n' + metricname + ' -v"' + metricval + '" -t' + valtype + ' -x' + tmax + ' -d' + str( self.dmax )
     104                cmd = cmd + ' -n' + str( metricname )+ ' -v"' + str( metricval )+ '" -t' + str( valtype ) + ' -x' + str( self.tmax )
    105105
    106106                print cmd
     
    198198                        myAttrs['status'] = status
    199199                        myAttrs['start_timestamp'] = start_timestamp
    200                         myAttrs['reported_timestamp'] = str( int( self.cur_time ) )
     200                        myAttrs['reported'] = str( int( self.cur_time ) )
    201201                        myAttrs['nodes'] = nodeslist
    202202                        myAttrs['domain'] = string.join( socket.getfqdn().split( '.' )[1:], '.' )
     
    244244                queue_str = 'queue=' + jobattrs['queue']
    245245                owner_str = 'owner=' + jobattrs['owner']
    246                 rtime_str = 'rtime=' + jobattrs['requested_time']
    247                 rmem_str = 'rmem=' + jobattrs['requested_memory']
     246                rtime_str = 'requested_time=' + jobattrs['requested_time']
     247                rmem_str = 'requested_memory=' + jobattrs['requested_memory']
    248248                ppn_str = 'ppn=' + jobattrs['ppn']
    249249                status_str = 'status=' + jobattrs['status']
    250                 stime_str = 'stime=' + jobattrs['start_timestamp']
    251                 reported_str = 'reported=' + jobattrs['reported_timestamp']
     250                stime_str = 'start_timestamp=' + jobattrs['start_timestamp']
     251                reported_str = 'reported=' + jobattrs['reported']
    252252                domain_str = 'domain=' + jobattrs['domain']
    253253                node_str = 'nodes=' + self.makeNodeString( jobattrs['nodes'] )
Note: See TracChangeset for help on using the changeset viewer.