Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(4)  |  Call(4)  |  Derive(0)  |  Import(0)

src/h/e/hellanzb-HEAD/Hellanzb/PostProcessor.py   hellanzb(Download)
 
        if not self.isSubDir:
            Hellanzb.postProcessorLock.acquire()
            Hellanzb.postProcessors.remove(self)
            self.archive.postProcessor = None
    def run(self):
        """ do the work """
        if not self.isSubDir:
            Hellanzb.postProcessorLock.acquire()
            # FIXME: could block if there are too many processors going

src/h/e/hellanzb-HEAD/Hellanzb/HellaXMLRPC/__init__.py   hellanzb(Download)
        s['currently_downloading'] = [self.makeNZBStruct(nzb) for nzb in currentNZBs]
 
        Hellanzb.postProcessorLock.acquire()
        s['currently_processing'] = [self.makeNZBStruct(processor) for processor in \
                                     Hellanzb.postProcessors]

src/h/e/hellanzb-HEAD/Hellanzb/NZBQueue.py   hellanzb(Download)
    h = writer.start('hellanzbState', {'version': Hellanzb.version})
 
    Hellanzb.postProcessorLock.acquire()
    postProcessors = Hellanzb.postProcessors[:]
    Hellanzb.postProcessorLock.release()