Revision cccff590 kamaki/clients/pithos.py

b/kamaki/clients/pithos.py
392 392 
        blocks will be written to normal_position - 10"""
393 393 
        finished = []
394 394 
        for i, (start, g) in enumerate(flying.items()):
395 
            #if i % self.POOL_SIZE == 0:
396 
            #    g.join(0.1)
397 395 
            if not g.isAlive():
398 396 
                if g.exception:
399 397 
                    raise g.exception
......
494 492 
                range,
495 493 
                **restargs)
496 494 
        else:
497 
            if len(remote_hashes) > self.POOL_SIZE:
498 
                self.POOL_SIZE = len(remote_hashes) // 10
499 495 
            self._dump_blocks_async(obj,
500 496 
                remote_hashes,
501 497 
                blocksize,

Also available in: Unified diff