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