← Back to branch summary

~certify-web-dev/twisted/certify-trunk

« back to all changes in this revision

Viewing changes to twisted/internet/base.py

  • Committer: Bazaar Package Importer
  • Author(s): Matthias Klose
  • Date: 2007-01-17 14:52:35 UTC
  • mfrom: (1.1.5 upstream) (2.1.2 etch)
  • Revision ID: james.westby@ubuntu.com-20070117145235-btmig6qfmqfen0om
Tags: 2.5.0-0ubuntu1
New upstream version, compatible with python2.5.

Show diffs side-by-side

added added

removed removed

Lines of Context:
twisted/internet/base.py
29
29
from twisted.internet.interfaces import IResolverSimple, IReactorPluggableResolver
30
30
from twisted.internet.interfaces import IConnector, IDelayedCall
31
31
from twisted.internet import main, error, abstract, defer, threads
32
 
from twisted.python import log, failure, reflect, components
 
32
from twisted.python import log, failure, reflect
33
33
from twisted.python.runtime import seconds, platform
34
34
from twisted.internet.defer import Deferred, DeferredList
35
35
from twisted.persisted import styles
527
527
            # making them, in case another call is added to the queue
528
528
            # while we're in this loop.
529
529
            count = 0
 
530
            total = len(self.threadCallQueue)
530
531
            for (f, a, kw) in self.threadCallQueue:
531
532
                try:
532
533
                    f(*a, **kw)
533
534
                except:
534
535
                    log.err()
535
536
                count += 1
 
537
                if count == total:
 
538
                    break
536
539
            del self.threadCallQueue[:count]
537
 
 
 
540
            if self.threadCallQueue:
 
541
                if self.waker:
 
542
                    self.waker.wakeUp()
 
543
 
538
544
        # insert new delayed calls now
539
545
        self._insertNewDelayedCalls()
540
546