ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject ignite git commit: IGNITE-7773 Add 'rebalanceClearingPartitionsLeft' metric to .NET - Fixes #3613.
Date Mon, 12 Mar 2018 15:17:23 GMT
Repository: ignite
Updated Branches:
  refs/heads/master ed2435c81 -> 447a8a9d0


IGNITE-7773 Add 'rebalanceClearingPartitionsLeft' metric to .NET - Fixes #3613.

Signed-off-by: Alexey Goncharuk <alexey.goncharuk@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/447a8a9d
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/447a8a9d
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/447a8a9d

Branch: refs/heads/master
Commit: 447a8a9d0da87128b28d37f4ebaa2e3040e5febb
Parents: ed2435c
Author: Pavel Kovalenko <jokserfn@gmail.com>
Authored: Mon Mar 12 18:16:34 2018 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Committed: Mon Mar 12 18:16:34 2018 +0300

----------------------------------------------------------------------
 .../internal/processors/platform/cache/PlatformCache.java   | 1 +
 .../dotnet/Apache.Ignite.Core/Cache/ICacheMetrics.cs        | 9 +++++++++
 .../Apache.Ignite.Core/Impl/Cache/CacheMetricsImpl.cs       | 7 +++++++
 3 files changed, 17 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/447a8a9d/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
index 86774c1..19dac83 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
@@ -1482,6 +1482,7 @@ public class PlatformCache extends PlatformAbstractTarget {
         writer.writeLong(metrics.getHeapEntriesCount());
         writer.writeLong(metrics.getEstimatedRebalancingFinishTime());
         writer.writeLong(metrics.getRebalancingStartTime());
+        writer.writeLong(metrics.getRebalanceClearingPartitionsLeft());
     }
 
     /**

http://git-wip-us.apache.org/repos/asf/ignite/blob/447a8a9d/modules/platforms/dotnet/Apache.Ignite.Core/Cache/ICacheMetrics.cs
----------------------------------------------------------------------
diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Cache/ICacheMetrics.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Cache/ICacheMetrics.cs
index 43a54c7..a328cf5 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Core/Cache/ICacheMetrics.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Core/Cache/ICacheMetrics.cs
@@ -637,5 +637,14 @@ namespace Apache.Ignite.Core.Cache
         /// Rebalancing start time.
         /// </returns>
         long RebalancingStartTime { get; }
+
+        /// <summary>
+        /// Gets number of partitions.
+        /// need to be cleared before actual rebalance start.
+        /// </summary>
+        /// <returns>
+        /// Number of clearing partitions for rebalance.
+        /// </returns>
+        long RebalanceClearingPartitionsLeft { get; }
     }
 }
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/ignite/blob/447a8a9d/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheMetricsImpl.cs
----------------------------------------------------------------------
diff --git a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheMetricsImpl.cs b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheMetricsImpl.cs
index 1a3f0dc..fbc5d4c 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheMetricsImpl.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/CacheMetricsImpl.cs
@@ -241,6 +241,9 @@ namespace Apache.Ignite.Core.Impl.Cache
         /** */
         private readonly long _rebalancingStartTime;
 
+        /** */
+        private readonly long _rebalancingClearingPartitionsLeft;
+
         /// <summary>
         /// Initializes a new instance of the <see cref="CacheMetricsImpl"/> class.
         /// </summary>
@@ -319,6 +322,7 @@ namespace Apache.Ignite.Core.Impl.Cache
             _heapEntriesCount = reader.ReadLong();
             _estimatedRebalancingFinishTime = reader.ReadLong();
             _rebalancingStartTime = reader.ReadLong();
+            _rebalancingClearingPartitionsLeft = reader.ReadLong();
         }
 
         /** <inheritDoc /> */
@@ -536,5 +540,8 @@ namespace Apache.Ignite.Core.Impl.Cache
 
         /** <inheritDoc /> */
         public long RebalancingStartTime { get { return _rebalancingStartTime; } }
+
+        /** <inheritDoc /> */
+        public long RebalanceClearingPartitionsLeft { get { return _rebalancingClearingPartitionsLeft;
} }
     }
 }
\ No newline at end of file


Mime
View raw message