Repository: ignite Updated Branches: refs/heads/ignite-1093-2 09b683268 -> 07d683fd3
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/07d683fd Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/07d683fd Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/07d683fd Branch: refs/heads/ignite-1093-2 Commit: 07d683fd37f294ed5c88bccc7628e0c664eb1a06 Parents: 09b6832 Author: Anton Vinogradov <[email protected]> Authored: Mon Sep 14 14:04:51 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Mon Sep 14 14:04:51 2015 +0300 ---------------------------------------------------------------------- .../tcp/GridOrderedMessageCancelSelfTest.java | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/07d683fd/modules/indexing/src/test/java/org/apache/ignite/spi/communication/tcp/GridOrderedMessageCancelSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/spi/communication/tcp/GridOrderedMessageCancelSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/spi/communication/tcp/GridOrderedMessageCancelSelfTest.java index 0226046..582bfe3 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/spi/communication/tcp/GridOrderedMessageCancelSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/spi/communication/tcp/GridOrderedMessageCancelSelfTest.java @@ -107,25 +107,33 @@ public class GridOrderedMessageCancelSelfTest extends GridCommonAbstractTest { * @throws Exception If failed. */ public void testTask() throws Exception { + Map map = U.field(((IgniteKernal)grid(0)).context().io(), "msgSetMap"); + + int initSize = map.size(); + ComputeTaskFuture<?> fut = executeAsync(compute(grid(0).cluster().forRemotes()), Task.class, null); - testMessageSet(fut); + testMessageSet(fut, initSize, map); } /** * @throws Exception If failed. */ public void testTaskException() throws Exception { + Map map = U.field(((IgniteKernal)grid(0)).context().io(), "msgSetMap"); + + int initSize = map.size(); + ComputeTaskFuture<?> fut = executeAsync(compute(grid(0).cluster().forRemotes()), FailTask.class, null); - testMessageSet(fut); + testMessageSet(fut, initSize, map); } /** * @param fut Future to cancel. * @throws Exception If failed. */ - private void testMessageSet(IgniteFuture<?> fut) throws Exception { + private void testMessageSet(IgniteFuture<?> fut, int initSize, Map map) throws Exception { cancelLatch.await(); assertTrue(fut.cancel()); @@ -134,11 +142,9 @@ public class GridOrderedMessageCancelSelfTest extends GridCommonAbstractTest { assertTrue(U.await(finishLatch, 5000, MILLISECONDS)); - Map map = U.field(((IgniteKernal)grid(0)).context().io(), "msgSetMap"); - info("Map: " + map); - assertTrue(map.isEmpty()); + assertEquals(map.size(), initSize); } /**
