ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [49/50] [abbrv] ignite git commit: master - Fixed visor compilation after merge
Date Tue, 01 Aug 2017 09:27:34 GMT
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-5757
Commit: f575a245cf9958857e0f51d7f56db43f0d3a2d5c
Parents: 8b576c1
Author: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Authored: Tue Aug 1 12:25:25 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@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.


Mime
View raw message