[asterixdb] branch master updated: [NO ISSUE][OTH] Add pending replicate ops in io stats

[mhubail]

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

mhubail 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 072ee50  [NO ISSUE][OTH] Add pending replicate ops in io stats
072ee50 is described below

commit 072ee5035413aedbc252fa63322dad38e30427df
Author: Murtadha Hubail <murtadha.hub...@couchbase.com>
AuthorDate: Fri Aug 27 00:43:47 2021 +0300

    [NO ISSUE][OTH] Add pending replicate ops in io stats
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Details:
    
    - Include pending replicate ops in the IO stats.
    
    Change-Id: I56213b6d2027d98c2bf973fac5db5316d6e7fd8e
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/13003
    Reviewed-by: Murtadha Hubail <mhub...@apache.org>
    Reviewed-by: Ali Alsuliman <ali.al.solai...@gmail.com>
    Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
---
 .../java/org/apache/asterix/common/context/DatasetInfo.java   | 11 +++++++++++
 .../asterix/common/context/DatasetLifecycleManager.java       |  1 +
 .../org/apache/asterix/common/storage/StorageIOStats.java     |  9 +++++++++
 3 files changed, 21 insertions(+)

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 72dacc4..7483a17 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
@@ -45,6 +45,7 @@ public class DatasetInfo extends Info implements 
Comparable<DatasetInfo> {
     private int numActiveIOOps;
     private int pendingFlushes;
     private int pendingMerges;
+    private int pendingReplications;
     private long lastAccess;
     private boolean isExternal;
     private boolean isRegistered;
@@ -82,6 +83,9 @@ public class DatasetInfo extends Info implements 
Comparable<DatasetInfo> {
             case MERGE:
                 pendingMerges++;
                 break;
+            case REPLICATE:
+                pendingReplications++;
+                break;
             default:
                 break;
         }
@@ -96,6 +100,9 @@ public class DatasetInfo extends Info implements 
Comparable<DatasetInfo> {
             case MERGE:
                 pendingMerges--;
                 break;
+            case REPLICATE:
+                pendingReplications--;
+                break;
             default:
                 break;
         }
@@ -251,4 +258,8 @@ public class DatasetInfo extends Info implements 
Comparable<DatasetInfo> {
     public synchronized int getPendingMerges() {
         return pendingMerges;
     }
+
+    public synchronized int getPendingReplications() {
+        return pendingReplications;
+    }
 }
diff --git 
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java
 
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java
index bd24696..c431dca 100644
--- 
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java
+++ 
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/context/DatasetLifecycleManager.java
@@ -562,6 +562,7 @@ public class DatasetLifecycleManager implements 
IDatasetLifecycleManager, ILifeC
         for (DatasetResource dsr : datasets.values()) {
             stats.addPendingFlushes(dsr.getDatasetInfo().getPendingFlushes());
             stats.addPendingMerges(dsr.getDatasetInfo().getPendingMerges());
+            
stats.addPendingReplications(dsr.getDatasetInfo().getPendingReplications());
         }
         return stats;
     }
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 0b44f76..da4578f 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
@@ -22,6 +22,7 @@ public class StorageIOStats {
 
     private int pendingFlushes;
     private int pendingMerges;
+    private int pendingReplications;
 
     public void addPendingFlushes(int pending) {
         pendingFlushes += pending;
@@ -31,6 +32,10 @@ public class StorageIOStats {
         pendingMerges += pending;
     }
 
+    public void addPendingReplications(int pending) {
+        pendingReplications += pending;
+    }
+
     public int getPendingFlushes() {
         return pendingFlushes;
     }
@@ -38,4 +43,8 @@ public class StorageIOStats {
     public int getPendingMerges() {
         return pendingMerges;
     }
+
+    public int getPendingReplications() {
+        return pendingReplications;
+    }
 }