master - Fixed visor compilation after merge
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f575a245 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f575a245 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f575a245 Branch: refs/heads/ignite-5578 Commit: f575a245cf9958857e0f51d7f56db43f0d3a2d5c Parents: 8b576c1 Author: Alexey Goncharuk <[email protected]> Authored: Tue Aug 1 12:25:25 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Tue Aug 1 12:25:25 2017 +0300 ---------------------------------------------------------------------- .../scala/org/apache/ignite/visor/visor.scala | 20 +++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f575a245/modules/visor-console/src/main/scala/org/apache/ignite/visor/visor.scala ---------------------------------------------------------------------- diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/visor.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/visor.scala index 6db731b..ffc7a00 100644 --- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/visor.scala +++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/visor.scala @@ -29,12 +29,10 @@ import org.apache.ignite.internal.util.lang.{GridFunc => F} import org.apache.ignite.internal.util.typedef._ import org.apache.ignite.internal.util.{GridConfigurationFinder, IgniteUtils => U} import org.apache.ignite.lang._ -import org.apache.ignite.thread.IgniteThreadPoolExecutor +import org.apache.ignite.thread.{IgniteThreadFactory, IgniteThreadPoolExecutor} import org.apache.ignite.visor.commands.common.VisorTextTable - import jline.console.ConsoleReader import org.jetbrains.annotations.Nullable - import java.io._ import java.lang.{Boolean => JavaBoolean} import java.net._ @@ -221,7 +219,13 @@ object visor extends VisorTag { @volatile private var logStarted = false /** Internal thread pool. */ - @volatile var pool: ExecutorService = new IgniteThreadPoolExecutor() + @volatile var pool: ExecutorService = new IgniteThreadPoolExecutor( + Runtime.getRuntime().availableProcessors(), + Runtime.getRuntime().availableProcessors(), + 0L, + new LinkedBlockingQueue[Runnable](), + new IgniteThreadFactory("visorInstance", "visor") + ) /** Configuration file path, if any. */ @volatile var cfgPath: String = _ @@ -2173,7 +2177,13 @@ object visor extends VisorTag { Thread.currentThread.interrupt() } - pool = new IgniteThreadPoolExecutor() + pool = new IgniteThreadPoolExecutor( + Runtime.getRuntime().availableProcessors(), + Runtime.getRuntime().availableProcessors(), + 0L, + new LinkedBlockingQueue[Runnable](), + new IgniteThreadFactory("visorInstance", "visor") + ) } // Call all close callbacks.
