commit d7e0ba2d070c7ed5a5bbe6a4677deac8ce230c17
author alexander.behm <alexander.behm@123451ca-8445-de46-9d55-352943316053> Sat Jan 28 03:42:47 2012 +0000
committer alexander.behm <alexander.behm@123451ca-8445-de46-9d55-352943316053> Sat Jan 28 03:42:47 2012 +0000
tree f6705447e0103713d036eec0eb169b9d1ba7252a
parent c25867764c31bd2fd96773e656da2cf461ead9b2

Added proper synchronization for LSM-BTree bulk load.

git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_lsm_tree@1082 123451ca-8445-de46-9d55-352943316053

hyracks-storage-am-lsm-btree/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/btree/impls/LSMBTree.java

diff --git a/hyracks-storage-am-lsm-btree/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/btree/impls/LSMBTree.java b/hyracks-storage-am-lsm-btree/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/btree/impls/LSMBTree.java
index 005e712..3f88dce 100644
--- a/hyracks-storage-am-lsm-btree/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/btree/impls/LSMBTree.java
+++ b/hyracks-storage-am-lsm-btree/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/btree/impls/LSMBTree.java
@@ -549,7 +549,9 @@
     public void endBulkLoad(IIndexBulkLoadContext ictx) throws HyracksDataException {
         LSMTreeBulkLoadContext bulkLoadCtx = (LSMTreeBulkLoadContext) ictx;
         bulkLoadCtx.getBTree().endBulkLoad(bulkLoadCtx.getBulkLoadCtx());
-        diskBTrees.addFirst(bulkLoadCtx.getBTree());
+        synchronized (diskBTrees) {
+            diskBTrees.addFirst(bulkLoadCtx.getBTree());
+        }
     }
 
     @Override