(asterixdb) branch master updated: [NO ISSUE][OTH] Add I/O related helper methods

[wyk]

This is an automated email from the ASF dual-hosted git repository.

wyk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 1cd257dee1 [NO ISSUE][OTH] Add I/O related helper methods
1cd257dee1 is described below

commit 1cd257dee19c3e1313b0f889c1a8c687fb565f56
Author: Wail Alkowaileet <wael....@gmail.com>
AuthorDate: Tue Nov 7 15:16:33 2023 -0800

    [NO ISSUE][OTH] Add I/O related helper methods
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Details:
    Add I/O related helper methods
    
    Change-Id: I15167705e1fad0a5331ecc736d6867eff845f417
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17931
    Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Tested-by: Wail Alkowaileet <wael....@gmail.com>
    Reviewed-by: Wail Alkowaileet <wael....@gmail.com>
    Reviewed-by: Murtadha Hubail <mhub...@apache.org>
---
 .../src/test/java/org/apache/asterix/api/common/LocalCloudUtil.java   | 4 +++-
 .../asterix/common/replication/AllDatasetsReplicationStrategy.java    | 1 +
 .../main/java/org/apache/asterix/common/storage/StorageIOStats.java   | 4 ++++
 3 files changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/asterixdb/asterix-app/src/test/java/org/apache/asterix/api/common/LocalCloudUtil.java
 
b/asterixdb/asterix-app/src/test/java/org/apache/asterix/api/common/LocalCloudUtil.java
index 773fa4e053..9e3fdc4b3a 100644
--- 
a/asterixdb/asterix-app/src/test/java/org/apache/asterix/api/common/LocalCloudUtil.java
+++ 
b/asterixdb/asterix-app/src/test/java/org/apache/asterix/api/common/LocalCloudUtil.java
@@ -50,8 +50,10 @@ public class LocalCloudUtil {
     }
 
     public static void main(String[] args) {
+        String cleanStartString = System.getProperty("cleanup.start", "true");
+        boolean cleanStart = Boolean.parseBoolean(cleanStartString);
         // Change to 'true' if you want to delete "s3mock" folder on start
-        startS3CloudEnvironment(true);
+        startS3CloudEnvironment(cleanStart);
     }
 
     public static S3Mock startS3CloudEnvironment(boolean cleanStart) {
diff --git 
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
 
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
index c96977777a..84f0a39539 100644
--- 
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
+++ 
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
@@ -19,6 +19,7 @@
 package org.apache.asterix.common.replication;
 
 public class AllDatasetsReplicationStrategy implements IReplicationStrategy {
+    public static final IReplicationStrategy INSTANCE = new 
AllDatasetsReplicationStrategy();
 
     @Override
     public boolean isMatch(int datasetId) {
diff --git 
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
 
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
index da4578fbee..b58f63deff 100644
--- 
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
+++ 
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
@@ -47,4 +47,8 @@ public class StorageIOStats {
     public int getPendingReplications() {
         return pendingReplications;
     }
+
+    public int getTotalPendingOperations() {
+        return pendingFlushes + pendingMerges + pendingReplications;
+    }
 }