| commit | 5ade8edc73c771d340d9907805bb747e31761a97 | [log] [tgz] |
|---|---|---|
| author | salsubaiee <salsubaiee@gmail.com> | Tue Jul 30 06:27:55 2013 -0700 |
| committer | salsubaiee <salsubaiee@gmail.com> | Wed Aug 14 20:55:59 2013 -0700 |
| tree | cd8f4ac6e78ac579ee52f26aebdb30db83eb8508 | |
| parent | 34963157fe441a9f9b3cf7bb575876658d768b9a [diff] |
Fix for issue 589.
diff --git a/hyracks/hyracks-storage-am-lsm-common/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/common/impls/LSMHarness.java b/hyracks/hyracks-storage-am-lsm-common/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/common/impls/LSMHarness.java index de691e5..3817e5a 100644 --- a/hyracks/hyracks-storage-am-lsm-common/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/common/impls/LSMHarness.java +++ b/hyracks/hyracks-storage-am-lsm-common/src/main/java/edu/uci/ics/hyracks/storage/am/lsm/common/impls/LSMHarness.java
@@ -64,8 +64,9 @@ lsmIndex.getOperationalComponents(ctx); List<ILSMComponent> components = ctx.getComponentHolder(); try { - // The purpose of the synchronized block is to make the beforeOperation call and entering the mutable component an atomic operation. - synchronized (this) { + // The purpose of the synchronized block is to make bumping the counter inside the op. tracker + // and entering the mutable component an atomic operation. + synchronized (opTracker) { for (ILSMComponent c : components) { if (!c.threadEnter(opType)) { break;