Repository: ignite Updated Branches: refs/heads/master 709612489 -> 4348915d6
IGNITE-8896 fix for wrong javadoc for TcpCommunicationSpi.setSlowClientQueueLimit(). - Fixes #5225. Signed-off-by: Dmitriy Pavlov <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4348915d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4348915d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4348915d Branch: refs/heads/master Commit: 4348915d63a2a8d807017542c593b2a63ab139ea Parents: 7096124 Author: Rodion4ik <[email protected]> Authored: Sat Nov 3 23:29:16 2018 +0300 Committer: Dmitriy Pavlov <[email protected]> Committed: Sat Nov 3 23:29:16 2018 +0300 ---------------------------------------------------------------------- .../ignite/spi/communication/tcp/TcpCommunicationSpi.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/4348915d/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java index 33b1384..427db08 100755 --- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java @@ -1843,7 +1843,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements Communicati * When set to a positive number, communication SPI will monitor clients outbound message queue sizes and will drop * those clients whose queue exceeded this limit. * <p/> - * Usually this value should be set to the same value as {@link #getMessageQueueLimit()} which controls + * This value should be set to less or equal value than {@link #getMessageQueueLimit()} which controls * message back-pressure for server nodes. The default value for this parameter is {@code 0} * which means {@code unlimited}. * @@ -2207,8 +2207,8 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements Communicati "since may produce significant delays with some scenarios."); if (slowClientQueueLimit > 0 && msgQueueLimit > 0 && slowClientQueueLimit >= msgQueueLimit) { - U.quietAndWarn(log, "Slow client queue limit is set to a value greater than message queue limit " + - "(slow client queue limit will have no effect) [msgQueueLimit=" + msgQueueLimit + + U.quietAndWarn(log, "Slow client queue limit is set to a value greater than or equal to message " + + "queue limit (slow client queue limit will have no effect) [msgQueueLimit=" + msgQueueLimit + ", slowClientQueueLimit=" + slowClientQueueLimit + ']'); }
