Changeset 512 for trunk/jobmond


Ignore:
Timestamp:
03/07/08 17:58:33 (16 years ago)
Author:
bastiaans
Message:

web/addons/job_monarch/templates/overview.tpl,
web/addons/job_monarch/overview.php,
jobmond/jobmond.py:

  • added Craig West's support for offline/down PBS nodes
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/jobmond/jobmond.py

    r508 r512  
    462462                """Submit job info list"""
    463463
     464                global BATCH_API
     465
    464466                self.dp.multicastGmetric( 'MONARCH-HEARTBEAT', str( int( int( self.cur_time ) + int( self.timeoffset ) ) ) )
    465467
     
    483485                self.dp.multicastGmetric( 'MONARCH-RJ', str( running_jobs ), 'uint32', 'jobs' )
    484486                self.dp.multicastGmetric( 'MONARCH-QJ', str( queued_jobs ), 'uint32', 'jobs' )
     487
     488                # Report down/offline nodes in batch (PBS only ATM)
     489                #
     490                if BATCH_API == 'pbs':
     491
     492                        downed_nodes    = list()
     493                        offline_nodes   = list()
     494               
     495                        l               = ['state']
     496               
     497                        for name, node in self.pq.getnodes().items():
     498
     499                                if ( node[ 'state' ].find( "down" ) != -1 ):
     500
     501                                        downed_nodes.append( name )
     502
     503                                if ( node[ 'state' ].find( "offline" ) != -1 ):
     504
     505                                        offline_nodes.append( name )
     506
     507                        self.dp.multicastGmetric( 'MONARCH-DOWN'   , str( downed_nodes ),  'uint32', 'jobs' )
     508                        self.dp.multicastGmetric( 'MONARCH-OFFLINE', str( offline_nodes ), 'uint32', 'jobs' )
    485509
    486510                # Now let's spread the knowledge
Note: See TracChangeset for help on using the changeset viewer.