ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: Fixed failover tests for binary marshaller
Date Thu, 03 Dec 2015 15:15:23 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1.5 4ba911f0a -> 171e9b172


Fixed failover tests for binary marshaller


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

Branch: refs/heads/ignite-1.5
Commit: 171e9b172564bcaafd54532abbce3b16c7ffbc65
Parents: 4ba911f
Author: ashutak <ashutak@gridgain.com>
Authored: Thu Dec 3 18:15:40 2015 +0300
Committer: ashutak <ashutak@gridgain.com>
Committed: Thu Dec 3 18:15:40 2015 +0300

----------------------------------------------------------------------
 .../failover/IgniteTransactionalInvokeRetryBenchmark.java      | 4 ++--
 .../failover/IgniteTransactionalWriteInvokeBenchmark.java      | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/171e9b17/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalInvokeRetryBenchmark.java
----------------------------------------------------------------------
diff --git a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalInvokeRetryBenchmark.java
b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalInvokeRetryBenchmark.java
index 16b0959..b5a08da 100644
--- a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalInvokeRetryBenchmark.java
+++ b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalInvokeRetryBenchmark.java
@@ -169,7 +169,7 @@ public class IgniteTransactionalInvokeRetryBenchmark extends IgniteFailoverAbstr
                 if (ex != null)
                     throw ex;
 
-                asyncCache.invoke(key, new IncrementCacheEntryProcessor());
+                asyncCache.invoke(key, new IncrementInvokeRetryCacheEntryProcessor());
                 asyncCache.future().get(args.cacheOperationTimeoutMillis());
 
                 AtomicLong prevVal = map.putIfAbsent(key, new AtomicLong(0));
@@ -195,7 +195,7 @@ public class IgniteTransactionalInvokeRetryBenchmark extends IgniteFailoverAbstr
 
     /**
      */
-    private static class IncrementCacheEntryProcessor implements CacheEntryProcessor<String,
Long, Long> {
+    private static class IncrementInvokeRetryCacheEntryProcessor implements CacheEntryProcessor<String,
Long, Long> {
         /** */
         private static final long serialVersionUID = 0;
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/171e9b17/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
----------------------------------------------------------------------
diff --git a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
index a52ea78..9f9b5f7 100644
--- a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
+++ b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/failover/IgniteTransactionalWriteInvokeBenchmark.java
@@ -123,7 +123,7 @@ public class IgniteTransactionalWriteInvokeBenchmark extends IgniteFailoverAbstr
                         Set<Long> values = new HashSet<>(map.values());
 
                         if (values.size() != 1)
-                            throw new IgniteConsistencyException("Found different values
for keys [map="+map+"]");
+                            throw new IgniteConsistencyException("Found different values
for keys [map=" + map + "]");
 
                         break;
                     case 1: // Invoke scenario.
@@ -137,7 +137,7 @@ public class IgniteTransactionalWriteInvokeBenchmark extends IgniteFailoverAbstr
                         asyncCache.future().get(timeout);
 
                         for (String key : keys) {
-                            asyncCache.invoke(key, new IncrementCacheEntryProcessor(), cacheName());
+                            asyncCache.invoke(key, new IncrementWriteInvokeCacheEntryProcessor(),
cacheName());
                             Object o = asyncCache.future().get(timeout);
 
                             if (o != null)
@@ -165,7 +165,7 @@ public class IgniteTransactionalWriteInvokeBenchmark extends IgniteFailoverAbstr
 
     /**
      */
-    private static class IncrementCacheEntryProcessor implements CacheEntryProcessor<String,
Long, Object> {
+    private static class IncrementWriteInvokeCacheEntryProcessor implements CacheEntryProcessor<String,
Long, Object> {
         /** */
         private static final long serialVersionUID = 0;
 


Mime
View raw message