Repository: ignite Updated Branches: refs/heads/ignite-2.7 57545e0b1 -> e9ea04e2a
IGNITE-9895 DiscoveryMessageNotifierWorker must be instanceof IgniteDiscoveryThread - Fixes #5000. Signed-off-by: Alexey Goncharuk <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e9ea04e2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e9ea04e2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e9ea04e2 Branch: refs/heads/ignite-2.7 Commit: e9ea04e2a9dd5bb292653c2359d5196d41dad870 Parents: 57545e0 Author: Alexey Goncharuk <[email protected]> Authored: Tue Oct 16 17:49:40 2018 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Tue Oct 16 17:51:04 2018 +0300 ---------------------------------------------------------------------- .../ignite/internal/managers/discovery/GridDiscoveryManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e9ea04e2/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java index b27f92a..907720a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java @@ -134,6 +134,7 @@ import org.apache.ignite.spi.discovery.DiscoverySpiListener; import org.apache.ignite.spi.discovery.DiscoverySpiMutableCustomMessageSupport; import org.apache.ignite.spi.discovery.DiscoverySpiNodeAuthenticator; import org.apache.ignite.spi.discovery.DiscoverySpiOrderSupport; +import org.apache.ignite.spi.discovery.IgniteDiscoveryThread; import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; import org.apache.ignite.spi.discovery.tcp.internal.TcpDiscoveryNode; import org.apache.ignite.thread.IgniteThread; @@ -2636,7 +2637,7 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> { /** * */ - private class DiscoveryMessageNotifierWorker extends GridWorker { + private class DiscoveryMessageNotifierWorker extends GridWorker implements IgniteDiscoveryThread { /** Queue. */ private final BlockingQueue<T2<GridFutureAdapter, Runnable>> queue = new LinkedBlockingQueue<>();
