ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [47/50] [abbrv] ignite git commit: .NET: Fix metrics test (IGNITE-3018)
Date Fri, 14 Apr 2017 08:53:41 GMT
.NET: Fix metrics test (IGNITE-3018)


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

Branch: refs/heads/ignite-4929
Commit: 40347eda88de4c48a2c0535e50a91c5bff683105
Parents: 428f66d
Author: Pavel Tupitsyn <ptupitsyn@apache.org>
Authored: Fri Apr 14 10:40:04 2017 +0300
Committer: Pavel Tupitsyn <ptupitsyn@apache.org>
Committed: Fri Apr 14 10:40:04 2017 +0300

----------------------------------------------------------------------
 .../Apache.Ignite.Core.Tests/Cache/CacheMetricsTest.cs | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/40347eda/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheMetricsTest.cs
----------------------------------------------------------------------
diff --git a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheMetricsTest.cs b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheMetricsTest.cs
index d1d6c7b..d12afd2 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheMetricsTest.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/CacheMetricsTest.cs
@@ -25,6 +25,7 @@ namespace Apache.Ignite.Core.Tests.Cache
     using Apache.Ignite.Core.Impl;
     using Apache.Ignite.Core.Impl.Cache;
     using NUnit.Framework;
+    using System.Linq;
 
     /// <summary>
     /// Tests cache metrics propagation.
@@ -212,7 +213,8 @@ namespace Apache.Ignite.Core.Tests.Cache
         {
             func2 = func2 ?? func;
 
-            var localCache = Ignition.GetIgnite().CreateCache<int, int>(new CacheConfiguration(cacheName)
+            var localIgnite = Ignition.GetIgnite();
+            var localCache = localIgnite.CreateCache<int, int>(new CacheConfiguration(cacheName)
             {
                 EnableStatistics = true
             });
@@ -222,9 +224,12 @@ namespace Apache.Ignite.Core.Tests.Cache
             Assert.IsTrue(localCache.GetConfiguration().EnableStatistics);
             Assert.IsTrue(remoteCache.GetConfiguration().EnableStatistics);
 
-            localCache.Put(1, 1);
-            localCache.Get(1);
-            
+            var aff = localIgnite.GetAffinity(cacheName);
+            var localNode = localIgnite.GetCluster().GetLocalNode();
+            var localKey = Enumerable.Range(1, 10000).First(x => aff.IsPrimary(localNode,
x));
+
+            localCache.Put(localKey, 1);
+            localCache.Get(localKey);
             // Wait for metrics to propagate.
             Thread.Sleep(TcpDiscoverySpi.DefaultHeartbeatFrequency);
 


Mime
View raw message