[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