commit 6526a36c317ba5120dae63afae54a45917b1ace5
author salsubaiee <salsubaiee@gmail.com> Sat Aug 10 15:14:24 2013 -0700
committer salsubaiee <salsubaiee@gmail.com> Wed Aug 14 23:13:59 2013 -0700
tree d0ed73f1b520d000ddf7158a7768ff426cc45012
parent 35119a99d0ab1f0d3a60edf6c6a85ca47465eeba

Code refactoring.

asterix-common/src/main/java/edu/uci/ics/asterix/common/context/PrimaryIndexOperationTracker.java

diff --git a/asterix-common/src/main/java/edu/uci/ics/asterix/common/context/PrimaryIndexOperationTracker.java b/asterix-common/src/main/java/edu/uci/ics/asterix/common/context/PrimaryIndexOperationTracker.java
index c13cd42..69dba5e 100644
--- a/asterix-common/src/main/java/edu/uci/ics/asterix/common/context/PrimaryIndexOperationTracker.java
+++ b/asterix-common/src/main/java/edu/uci/ics/asterix/common/context/PrimaryIndexOperationTracker.java
@@ -25,6 +25,7 @@
 import edu.uci.ics.hyracks.storage.am.lsm.common.api.ILSMIOOperationCallbackFactory;
 import edu.uci.ics.hyracks.storage.am.lsm.common.api.ILSMIndex;
 import edu.uci.ics.hyracks.storage.am.lsm.common.api.ILSMIndexAccessor;
+import edu.uci.ics.hyracks.storage.am.lsm.common.api.ILSMIndexInternal;
 import edu.uci.ics.hyracks.storage.am.lsm.common.impls.LSMOperationType;
 
 public class PrimaryIndexOperationTracker extends BaseOperationTracker {
@@ -76,7 +77,7 @@
         // If we need a flush, and this is the last completing operation, then schedule the flush. 
         boolean needsFlush = false;
         for (ILSMIndex lsmIndex : indexes) {
-            if (lsmIndex.getFlushStatus()) {
+            if (((ILSMIndexInternal)lsmIndex).hasFlushRequestForCurrentMutableComponent()) {
                 needsFlush = true;
                 break;
             }