Repository: ignite Updated Branches: refs/heads/ignite-1758 d4936bd73 -> c329bd323
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/c329bd32 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c329bd32 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c329bd32 Branch: refs/heads/ignite-1758 Commit: c329bd3236392431d9eac85a4f37c2944eed3fb2 Parents: d4936bd Author: sboikov <[email protected]> Authored: Thu Nov 5 15:42:12 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Nov 5 15:42:12 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 4 ++-- .../spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java | 6 ++---- 2 files changed, 4 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/c329bd32/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java index 22c0b98..74b8f8f 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java @@ -1895,9 +1895,9 @@ class ServerImpl extends TcpDiscoveryImpl { /** * Pending messages container. */ - private static class PendingMessages implements Iterable<TcpDiscoveryAbstractMessage> { + private class PendingMessages implements Iterable<TcpDiscoveryAbstractMessage> { /** */ - private static final int MAX = 2 * 1024; + private static final int MAX = 3 * 1024; /** Pending messages. */ private final Queue<TcpDiscoveryAbstractMessage> msgs = new ArrayDeque<>(MAX * 2); http://git-wip-us.apache.org/repos/asf/ignite/blob/c329bd32/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 137ad29..2931d67 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 @@ -209,16 +209,14 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { /** * @throws Exception If any error occurs. */ - public void _testMultiThreadedClientsServersRestart() throws Throwable { - fail("https://issues.apache.org/jira/browse/IGNITE-1123";); - + public void testMultiThreadedClientsServersRestart() throws Throwable { multiThreadedClientsServersRestart(GRID_CNT, CLIENT_GRID_CNT); } /** * @throws Exception If any error occurs. */ - public void testMultiThreadedServersRestart() throws Throwable { + public void _testMultiThreadedServersRestart() throws Throwable { multiThreadedClientsServersRestart(GRID_CNT * 2, 0); }
