Repository: ignite Updated Branches: refs/heads/ignite-1758 c15eb405f -> 7d03ec2ce
ignite-1758 debug Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7d03ec2c Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7d03ec2c Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7d03ec2c Branch: refs/heads/ignite-1758 Commit: 7d03ec2ce66fb82320fe7c756f1185f2ba787624 Parents: c15eb40 Author: sboikov <[email protected]> Authored: Mon Nov 2 14:28:46 2015 +0300 Committer: sboikov <[email protected]> Committed: Mon Nov 2 14:28:46 2015 +0300 ---------------------------------------------------------------------- .../dht/preloader/GridDhtPartitionsExchangeFuture.java | 6 ++++++ .../tcp/IgniteClientReconnectMassiveShutdownTest.java | 2 +- .../spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java | 2 +- 3 files changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7d03ec2c/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java index 77e47a7..cef38e8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java @@ -1447,6 +1447,12 @@ public class GridDhtPartitionsExchangeFuture extends GridFutureAdapter<AffinityT ", old=" + oldest.id() + ", new=" + newOldest.id() + ']'); } } + else { + ClusterTopologyCheckedException err = new ClusterTopologyCheckedException("Failed to " + + "wait for exchange future, all server nodes left."); + + onDone(err); + } if (set) { // If received any messages, process them. http://git-wip-us.apache.org/repos/asf/ignite/blob/7d03ec2c/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java index 30eb691..da60d7d 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/IgniteClientReconnectMassiveShutdownTest.java @@ -109,7 +109,7 @@ public class IgniteClientReconnectMassiveShutdownTest extends GridCommonAbstract /** * @throws Exception If any error occurs. */ - public void _testMassiveServersShutdown3() throws Exception { + public void testMassiveServersShutdown3() throws Exception { massiveServersShutdown(StopType.CLOSE); } http://git-wip-us.apache.org/repos/asf/ignite/blob/7d03ec2c/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java index 55d48a7..9954653 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java @@ -160,7 +160,7 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { /** * @throws Exception If any error occurs. */ - public void testMultiThreadedClientsRestart() throws Exception { + public void _testMultiThreadedClientsRestart() throws Exception { final AtomicBoolean done = new AtomicBoolean(); try {
