Fixed update notifier executor service issue.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/28213a31 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/28213a31 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/28213a31 Branch: refs/heads/ignite-264 Commit: 28213a311213cd46e2ade744590f339f4fc385a3 Parents: f1f6be8 Author: vozerov-gridgain <[email protected]> Authored: Fri Sep 4 10:27:17 2015 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Fri Sep 4 10:27:17 2015 +0300 ---------------------------------------------------------------------- .../main/java/org/apache/ignite/internal/IgniteKernal.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/28213a31/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java index ad4940a..70cd56f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java @@ -821,7 +821,7 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable { updateNtfTimer = new Timer("ignite-update-notifier-timer", true); // Setup periodic version check. - updateNtfTimer.scheduleAtFixedRate(new UpdateNotifierTimerTask(this, verChecker), + updateNtfTimer.scheduleAtFixedRate(new UpdateNotifierTimerTask(this, execSvc, verChecker), 0, PERIODIC_VER_CHECK_DELAY); } catch (IgniteCheckedException e) { @@ -3199,15 +3199,15 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable { * Constructor. * * @param kernal Kernal. + * @param execSvc Executor service. * @param verChecker Version checker. */ - private UpdateNotifierTimerTask(IgniteKernal kernal, GridUpdateNotifier verChecker) { + private UpdateNotifierTimerTask(IgniteKernal kernal, ExecutorService execSvc, GridUpdateNotifier verChecker) { kernalRef = new WeakReference<>(kernal); log = kernal.log.getLogger(UpdateNotifierTimerTask.class); - execSvc = kernal.executorService(); - + this.execSvc = execSvc; this.verChecker = verChecker; }
