Changeset 724


Ignore:
Timestamp:
03/22/13 11:50:13 (8 years ago)
Author:
ramonb
Message:
  • renamed MONARCH-metrics to zplugin-monarch-metrics
File:
1 edited

Legend:

Unmodified
Added
Removed
  • branches/0.4/jobmond/jobmond.py

    r707 r724  
    824824        global BATCH_API
    825825
    826         self.dp.multicastGmetric( 'MONARCH-HEARTBEAT', str( int( int( self.cur_time ) + int( self.timeoffset ) ) ) )
    827 
    828         running_jobs    = 0
    829         queued_jobs    = 0
     826        self.dp.multicastGmetric( 'zplugin-monarch-heartbeat', str( int( int( self.cur_time ) + int( self.timeoffset ) ) ) )
     827
     828        running_jobs = 0
     829        queued_jobs  = 0
    830830
    831831        # Count how many running/queued jobs we found
     
    843843        # Report running/queued jobs as seperate metric for a nice RRD graph
    844844        #
    845         self.dp.multicastGmetric( 'MONARCH-RJ', str( running_jobs ), 'uint32', 'jobs' )
    846         self.dp.multicastGmetric( 'MONARCH-QJ', str( queued_jobs ), 'uint32', 'jobs' )
     845        self.dp.multicastGmetric( 'zplugin-monarch-rj', str( running_jobs ), 'uint32', 'jobs' )
     846        self.dp.multicastGmetric( 'zplugin-monarch-qj', str( queued_jobs ), 'uint32', 'jobs' )
    847847
    848848        # Report down/offline nodes in batch (PBS only ATM)
     
    872872            down_str    = 'nodes=%s domain=%s reported=%s' %( string.join( downnodeslist, ';' ), domain, str( int( int( self.cur_time ) + int( self.timeoffset ) ) ) )
    873873            offl_str    = 'nodes=%s domain=%s reported=%s' %( string.join( offlinenodeslist, ';' ), domain, str( int( int( self.cur_time ) + int( self.timeoffset ) ) ) )
    874             self.dp.multicastGmetric( 'MONARCH-DOWN'   , down_str )
    875             self.dp.multicastGmetric( 'MONARCH-OFFLINE', offl_str )
     874            self.dp.multicastGmetric( 'zplugin-monarch-down'   , down_str )
     875            self.dp.multicastGmetric( 'zplugin-monarch-offline', offl_str )
    876876
    877877        # Now let's spread the knowledge
     
    889889            for val in gmetric_val:
    890890
    891                 self.dp.multicastGmetric( 'MONARCH-JOB-' + jobid + '-' + str(metric_increment), val )
     891                self.dp.multicastGmetric( 'zplugin-monarch-job-' + jobid + '-' + str(metric_increment), val )
    892892
    893893                # Increase follow number if this jobinfo is split up amongst more than 1 gmetric
Note: See TracChangeset for help on using the changeset viewer.