Revision 2005b18e kamaki/clients/__init__.py

b/kamaki/clients/__init__.py
125 125
    def _watch_thread_limit(self, threadlist):
126 126
        recvlog.debug('# running threads: %s' % len(threadlist))
127 127
        if (self._elapsed_old > self._elapsed_new) and (
128
            self._thread_limit < self.POOL_SIZE):
129
                self._thread_limit += 1
128
                self._thread_limit < self.POOL_SIZE):
129
            self._thread_limit += 1
130 130
        elif self._elapsed_old < self._elapsed_new and self._thread_limit > 1:
131 131
            self._thread_limit -= 1
132 132

  

Also available in: Unified diff