Revision 36fa6ffb kamaki/clients/pithos/__init__.py

b/kamaki/clients/pithos/__init__.py
624 624
            for thread in activethreads():
625 625
                thread.join()
626 626
            raise
627
        self._cb_next()
627 628

  
628 629
        r = self.object_put(
629 630
            obj,
......
1359 1360
        finally:
1360 1361
            from time import sleep
1361 1362
            sleep(2 * len(activethreads()))
1363
            self._cb_next()
1362 1364
        return headers.values()
1363 1365

  
1364 1366
    def truncate_object(self, obj, upto_bytes):
......
1427 1429
                data=block)
1428 1430
            headers.append(dict(r.headers))
1429 1431
            offset += len(block)
1430

  
1431
            self._cb_next
1432
            self._cb_next()
1433
        self._cb_next()
1432 1434
        return headers
1433 1435

  
1434 1436
    def copy_object(

Also available in: Unified diff