Change in asterixdb[trinity]: [NO ISSUE][STO] Add a way to wait only for flushes

[AsterixDB Code Review <do...@asterix-gerrit.ics.uci.edu>]

From Murtadha Hubail <mh...@apache.org>:

Murtadha Hubail has uploaded this change for review. ( https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18777 )


Change subject: [NO ISSUE][STO] Add a way to wait only for flushes
......................................................................

[NO ISSUE][STO] Add a way to wait only for flushes

- user model changes: no
- storage format changes: no
- interface changes: no

Details:

- Add a method that can be used by extentions to wait only for
  pending fllushes on a dataset rather than all IO ops.

Ext-ref: MB-63316
Change-Id: I02daf3cd9680070d02fd133572950e37e68fe319
---
M asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetInfo.java
1 file changed, 33 insertions(+), 0 deletions(-)



  git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/77/18777/1

diff --git a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetInfo.java b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetInfo.java
index 87a3c2f..bb28ef1 100644
--- a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetInfo.java
+++ b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetInfo.java
@@ -280,6 +280,20 @@
         }
     }
 
+    public void waitForFlushes() throws HyracksDataException {
+        logManager.log(waitLog);
+        synchronized (this) {
+            while (pendingFlushes > 0) {
+                try {
+                    wait();
+                } catch (InterruptedException e) {
+                    Thread.currentThread().interrupt();
+                    throw HyracksDataException.create(e);
+                }
+            }
+        }
+    }
+
     public synchronized int getPendingFlushes() {
         return pendingFlushes;
     }

-- 
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18777
To unsubscribe, or for help writing mail filters, visit https://asterix-gerrit.ics.uci.edu/settings

Gerrit-Project: asterixdb
Gerrit-Branch: trinity
Gerrit-Change-Id: I02daf3cd9680070d02fd133572950e37e68fe319
Gerrit-Change-Number: 18777
Gerrit-PatchSet: 1
Gerrit-Owner: Murtadha Hubail <mh...@apache.org>
Gerrit-MessageType: newchange