You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2018/10/16 14:50:31 UTC
ignite git commit: IGNITE-9895 DiscoveryMessageNotifierWorker must be
instanceof IgniteDiscoveryThread - Fixes #5000.
Repository: ignite
Updated Branches:
refs/heads/master 153daeb73 -> a6741cf00
IGNITE-9895 DiscoveryMessageNotifierWorker must be instanceof IgniteDiscoveryThread - Fixes #5000.
Signed-off-by: Alexey Goncharuk <al...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a6741cf0
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a6741cf0
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a6741cf0
Branch: refs/heads/master
Commit: a6741cf00f6cf2996fb368ab3bddcad17c4f995b
Parents: 153daeb
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Tue Oct 16 17:49:40 2018 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Tue Oct 16 17:49:40 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/a6741cf0/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<>();