[ARVADOS] updated: 078bdb166766423e1a423523e5285966aff7ec6b

Git user git at public.curoverse.com
Wed Oct 26 11:03:35 EDT 2016


Summary of changes:
 sdk/python/arvados/arvfile.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

       via  078bdb166766423e1a423523e5285966aff7ec6b (commit)
      from  6f04833d7837659acdfd01d4fbcf4ae36e8e5f5c (commit)

Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.


commit 078bdb166766423e1a423523e5285966aff7ec6b
Author: Lucas Di Pentima <lucas at curoverse.com>
Date:   Wed Oct 26 12:01:55 2016 -0300

    10315: Moved the BlockManager's put threads lazy loading to __init__() to avoid locking issues when calling commit_bufferblock() fropm within an already @synchronized method.

diff --git a/sdk/python/arvados/arvfile.py b/sdk/python/arvados/arvfile.py
index aac2595..5ae53f4 100644
--- a/sdk/python/arvados/arvfile.py
+++ b/sdk/python/arvados/arvfile.py
@@ -418,6 +418,7 @@ class _BlockManager(object):
         self.num_get_threads = _BlockManager.DEFAULT_GET_THREADS
         self.copies = copies
         self._pending_write_size = 0
+        self.start_put_threads()
 
     @synchronized
     def alloc_bufferblock(self, blockid=None, starting_capacity=2**14, owner=None):
@@ -626,7 +627,6 @@ class _BlockManager(object):
                 block.set_state(_BufferBlock.ERROR, e)
                 raise
         else:
-            self.start_put_threads()
             self._put_queue.put(block)
 
     @synchronized

-----------------------------------------------------------------------


hooks/post-receive
-- 




More information about the arvados-commits mailing list