Changeset 293 for trunk/jobarchived


Ignore:
Timestamp:
03/30/07 10:15:47 (14 years ago)
Author:
bastiaans
Message:

jobarchived/jobarchived.py:

  • Fixed: XMLGatherer'ing
  • Added XMLGather locking
  • Removed conflicting XMLGatherer instances
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/jobarchived/jobarchived.py

    r292 r293  
    460460                """Setup initial XML connection and handlers"""
    461461
    462                 self.myXMLGatherer      = XMLGatherer( ARCHIVE_XMLSOURCE.split( ':' )[0], ARCHIVE_XMLSOURCE.split( ':' )[1] )
     462                #self.myXMLGatherer     = XMLGatherer( ARCHIVE_XMLSOURCE.split( ':' )[0], ARCHIVE_XMLSOURCE.split( ':' )[1] )
    463463                #self.myXMLSource       = self.myXMLGatherer.getFileObject()
    464464                self.myXMLSource        = XMLSource
     
    654654                self.clusters   = { }
    655655                debug_msg( 1, 'Checking existing toga rrd archive..' )
    656                 #self.gatherClusters()
     656                self.gatherClusters()
    657657                debug_msg( 1, 'Check done.' )
    658658
     
    785785        fd              = None
    786786        data            = None
     787        slot            = None
    787788
    788789        # Time since the last update
     
    801802                """Store host and port for connection"""
    802803
    803                 self.host = host
    804                 self.port = port
     804                self.host       = host
     805                self.port       = port
     806                self.slot       = threading.Lock()
    805807
    806808                self.retrieveData()
     
    810812
    811813                self.update_now = True
     814
     815                self.slot.acquire()
    812816
    813817                for res in socket.getaddrinfo( self.host, self.port, socket.AF_UNSPEC, socket.SOCK_STREAM ):
     
    851855
    852856                        self.LAST_UPDATE        = time.time()
     857
     858                self.slot.release()
    853859
    854860                self.update_now = False
     
    929935                self.config             = GangliaConfigParser( GMETAD_CONF )
    930936
    931                 self.myXMLGatherer      = XMLGatherer( ARCHIVE_XMLSOURCE.split( ':' )[0], ARCHIVE_XMLSOURCE.split( ':' )[1] )
     937                #self.myXMLGatherer     = XMLGatherer( ARCHIVE_XMLSOURCE.split( ':' )[0], ARCHIVE_XMLSOURCE.split( ':' )[1] )
    932938                #self.myXMLSource       = self.myXMLGatherer.getFileObject()
    933939                self.myXMLSource        = XMLSource
     
    10481054                my_data = self.myXMLSource.getData()
    10491055
     1056                #print my_data
     1057
    10501058                try:
    10511059                        xml.sax.parseString( my_data, self.myXMLHandler, self.myXMLError )
Note: See TracChangeset for help on using the changeset viewer.