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/master Commit: 171e9b172564bcaafd54532abbce3b16c7ffbc65 Parents: 4ba911f Author: ashutak <ashu...@gridgain.com> Authored: Thu Dec 3 18:15:40 2015 +0300 Committer: ashutak <ashu...@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;