You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/11/30 13:10:13 UTC
[30/50] [abbrv] ignite git commit: ignite-2020
GridProjectionLocalJobMultipleArgumentsSelfTest fixed
ignite-2020 GridProjectionLocalJobMultipleArgumentsSelfTest fixed
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f3cb64e3
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f3cb64e3
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f3cb64e3
Branch: refs/heads/ignite-843-rc1
Commit: f3cb64e375ff97a35b25ec0687b7d599f212afbd
Parents: 6312737
Author: agura <ag...@gridgain.com>
Authored: Fri Nov 27 17:26:20 2015 +0300
Committer: agura <ag...@gridgain.com>
Committed: Fri Nov 27 17:39:46 2015 +0300
----------------------------------------------------------------------
.../GridProjectionLocalJobMultipleArgumentsSelfTest.java | 11 +++++------
1 file changed, 5 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/f3cb64e3/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionLocalJobMultipleArgumentsSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionLocalJobMultipleArgumentsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionLocalJobMultipleArgumentsSelfTest.java
index 58ff1fb..356e002 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionLocalJobMultipleArgumentsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/GridProjectionLocalJobMultipleArgumentsSelfTest.java
@@ -43,7 +43,7 @@ public class GridProjectionLocalJobMultipleArgumentsSelfTest extends GridCommonA
private static final TcpDiscoveryIpFinder IP_FINDER = new TcpDiscoveryVmIpFinder(true);
/** */
- private static Collection<Integer> ids;
+ private static Collection<Object> ids;
/** */
private static AtomicInteger res;
@@ -90,7 +90,7 @@ public class GridProjectionLocalJobMultipleArgumentsSelfTest extends GridCommonA
for (int i : F.asList(1, 2, 3)) {
res.add(grid().compute().affinityCall(null, i, new IgniteCallable<Integer>() {
@Override public Integer call() {
- ids.add(System.identityHashCode(this));
+ ids.add(this);
return 10;
}
@@ -108,7 +108,7 @@ public class GridProjectionLocalJobMultipleArgumentsSelfTest extends GridCommonA
for (int i : F.asList(1, 2, 3)) {
grid().compute().affinityRun(null, i, new IgniteRunnable() {
@Override public void run() {
- ids.add(System.identityHashCode(this));
+ ids.add(this);
res.addAndGet(10);
}
@@ -125,8 +125,7 @@ public class GridProjectionLocalJobMultipleArgumentsSelfTest extends GridCommonA
public void testCall() throws Exception {
Collection<Integer> res = grid().compute().apply(new C1<Integer, Integer>() {
@Override public Integer apply(Integer arg) {
-
- ids.add(System.identityHashCode(this));
+ ids.add(this);
return 10 + arg;
}
@@ -144,7 +143,7 @@ public class GridProjectionLocalJobMultipleArgumentsSelfTest extends GridCommonA
Collection<Integer> res = grid().compute().apply(new C1<Integer, Integer>() {
@Override public Integer apply(Integer arg) {
- ids.add(System.identityHashCode(this));
+ ids.add(this);
return 10 + arg;
}