Repository: ignite Updated Branches: refs/heads/ignite-4154 617c178e5 -> 76126bb3a
ignite-4154 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/76126bb3 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/76126bb3 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/76126bb3 Branch: refs/heads/ignite-4154 Commit: 76126bb3a90c5349b934d44b07f94990747b93d6 Parents: 617c178 Author: sboikov <[email protected]> Authored: Tue Nov 1 15:29:26 2016 +0300 Committer: sboikov <[email protected]> Committed: Tue Nov 1 15:29:26 2016 +0300 ---------------------------------------------------------------------- .../ignite/spi/discovery/tcp/ServerImpl.java | 70 ++++++++++---------- 1 file changed, 35 insertions(+), 35 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/76126bb3/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 632346b..0277061 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 @@ -2163,41 +2163,41 @@ class ServerImpl extends TcpDiscoveryImpl { * */ void cleanup() { - Iterator<TcpDiscoveryAbstractMessage> msgIt = msgs.iterator(); - - boolean skipMsg = discardId != null; - boolean skipCustomMsg = customDiscardId != null; - - while (msgIt.hasNext()) { - TcpDiscoveryAbstractMessage msg0 = msgIt.next(); - - if (msg0 instanceof TcpDiscoveryCustomEventMessage) { - if (skipCustomMsg) { - assert customDiscardId != null; - - if (F.eq(customDiscardId, msg0.id())) - skipCustomMsg = false; - else - msgIt.remove(); - - continue; - } - } - else { - if (skipMsg) { - assert discardId != null; - - if (F.eq(discardId, msg0.id())) - skipMsg = false; - else - msgIt.remove(); - - continue; - } - } - - break; - } +// Iterator<TcpDiscoveryAbstractMessage> msgIt = msgs.iterator(); +// +// boolean skipMsg = discardId != null; +// boolean skipCustomMsg = customDiscardId != null; +// +// while (msgIt.hasNext()) { +// TcpDiscoveryAbstractMessage msg0 = msgIt.next(); +// +// if (msg0 instanceof TcpDiscoveryCustomEventMessage) { +// if (skipCustomMsg) { +// assert customDiscardId != null; +// +// if (F.eq(customDiscardId, msg0.id())) +// skipCustomMsg = false; +// else +// msgIt.remove(); +// +// continue; +// } +// } +// else { +// if (skipMsg) { +// assert discardId != null; +// +// if (F.eq(discardId, msg0.id())) +// skipMsg = false; +// else +// msgIt.remove(); +// +// continue; +// } +// } +// +// break; +// } } /**
