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

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

src/h/e/hellanzb-HEAD/Hellanzb/Daemon.py   hellanzb(Download)
    writeStateXML()
 
    if not len(Hellanzb.queue.currentNZBs()):
        # END
        return
 
    currentNZB = Hellanzb.queue.currentNZBs()[0]
def isActive():
    """ Whether or not we're actively downloading """
    return len(Hellanzb.queue.currentNZBs()) > 0
 
def cancelCurrent():
 
    canceled = False
    for nzb in Hellanzb.queue.currentNZBs():
        # FIXME: should GC here
        canceled = True
        nzbFile.interruptedAssembly = False
 
    for nzb in Hellanzb.queue.currentNZBs():
        for nzbFile in nzb.nzbFiles:
            if nzbFile.interruptedAssembly:

src/h/e/hellanzb-HEAD/Hellanzb/NZBQueue.py   hellanzb(Download)
    Hellanzb.postProcessorLock.release()
 
    for container in (Hellanzb.queue.currentNZBs(), postProcessors, Hellanzb.nzbQueue):
        for item in container:
            item.toStateXML(writer)
            # now. Unless it's the first run of scanQueue (not writeQueue),
            # then we FIXME: probably need to scan it
            if nzb.totalBytes == 0 and (len(Hellanzb.queue.currentNZBs()) or \
                    not writeQueue):
                from Hellanzb.NZBLeecher.NZBParser import NZBTotalBytesParser

src/h/e/hellanzb-HEAD/Hellanzb/NZBLeecher/NZBModel.py   hellanzb(Download)
    def postpone(self):
        """ Postpone an active NZB """
        assert self in Hellanzb.queue.currentNZBs(), \
            'Attempting to postpone an NZB not actively being downloaded: %s' % self.archiveName
        postponed = os.path.join(Hellanzb.POSTPONED_DIR, self.archiveName)
    def toStateXML(self, xmlWriter):
        """ Write a brief version of this object to an elementtree.SimpleXMLWriter.XMLWriter """
        attribs = self.getStateAttribs()
        if self in Hellanzb.queue.currentNZBs():
            type = 'downloading'

src/h/e/hellanzb-HEAD/Hellanzb/NZBLeecher/NZBSegmentQueue.py   hellanzb(Download)
    def isNZBDone(self, nzb, postponed = None):
        """ Determine whether or not all of the specified NZB as been thoroughly downloaded """
        if postponed is None:
            if nzb not in Hellanzb.queue.currentNZBs():
                postponed = True

src/h/e/hellanzb-HEAD/Hellanzb/HellaXMLRPC/__init__.py   hellanzb(Download)
 
        s['percent_complete'] = 0
        currentNZBs = Hellanzb.queue.currentNZBs()
        if len(currentNZBs):
            currentNZB = currentNZBs[0]