Repository: ignite Updated Branches: refs/heads/ignite-1758 88803d195 -> 63cab5d9d
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/63cab5d9 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/63cab5d9 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/63cab5d9 Branch: refs/heads/ignite-1758 Commit: 63cab5d9d69c78326f7a2ebba389b9039a6d2628 Parents: 88803d1 Author: sboikov <[email protected]> Authored: Thu Nov 5 16:59:03 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Nov 5 16:59:03 2015 +0300 ---------------------------------------------------------------------- .../main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 2 +- .../ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/63cab5d9/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 74b8f8f..638ccb4 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 @@ -1897,7 +1897,7 @@ class ServerImpl extends TcpDiscoveryImpl { */ private class PendingMessages implements Iterable<TcpDiscoveryAbstractMessage> { /** */ - private static final int MAX = 3 * 1024; + private static final int MAX = 10 * 1024; /** Pending messages. */ private final Queue<TcpDiscoveryAbstractMessage> msgs = new ArrayDeque<>(MAX * 2); http://git-wip-us.apache.org/repos/asf/ignite/blob/63cab5d9/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 86064d3..72549b3 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 @@ -340,7 +340,7 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { // Generate unique name to simplify debugging. int startIdx = srvStartIdx.getAndIncrement(); - Thread.currentThread().setName("start-server-" + getTestGridName(stopIdx)); + Thread.currentThread().setName("start-server-" + getTestGridName(startIdx)); log.info("Start server: " + startIdx);
