You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/08/01 10:37:47 UTC
[47/49] ignite git commit: master - Fixed visor compilation after
merge
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 <al...@gmail.com>
Authored: Tue Aug 1 12:25:25 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
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.