You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by an...@apache.org on 2015/03/04 09:52:06 UTC

[7/7] incubator-ignite git commit: # ignite-185 Append exit in batch mode.

# ignite-185 Append exit in batch mode.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/e9356ab0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/e9356ab0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/e9356ab0

Branch: refs/heads/ignite-185
Commit: e9356ab06e53a147cb472f3113f2bfaddfec9402
Parents: 25cafd4
Author: anovikov <an...@gridgain.com>
Authored: Wed Mar 4 15:51:33 2015 +0700
Committer: anovikov <an...@gridgain.com>
Committed: Wed Mar 4 15:51:33 2015 +0700

----------------------------------------------------------------------
 .../ignite/visor/commands/VisorConsole.scala    | 30 +++++++++++---------
 1 file changed, 17 insertions(+), 13 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/e9356ab0/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
----------------------------------------------------------------------
diff --git a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
index 66cbe3e..3cf6619 100644
--- a/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
+++ b/modules/visor-console/src/main/scala/org/apache/ignite/visor/commands/VisorConsole.scala
@@ -17,17 +17,18 @@
 
 package org.apache.ignite.visor.commands
 
-import java.awt.Image
-import java.io._
-import java.text.SimpleDateFormat
-import java.util
-import javax.swing.ImageIcon
-
 import org.apache.ignite.internal.IgniteVersionUtils._
 import org.apache.ignite.internal.util.scala.impl
 import org.apache.ignite.internal.util.{IgniteUtils => U}
 import org.apache.ignite.startup.cmdline.AboutDialog
 
+import javax.swing.ImageIcon
+import java._
+import java.awt.Image
+import java.io._
+import java.text.SimpleDateFormat
+import java.util._
+
 // Built-in commands.
 // Note the importing of implicit conversions.
 import org.apache.ignite.visor.commands.ack.VisorAckCommand
@@ -117,7 +118,7 @@ object VisorConsole extends App {
         visor.quit()
     }
 
-    var inputStream: InputStream = new FileInputStream(FileDescriptor.in)
+    var batchStream: Option[InputStream] = None
 
     batchFile.foreach(name => {
         val f = U.resolveIgnitePath(name)
@@ -131,16 +132,19 @@ object VisorConsole extends App {
             visor.quit()
         }
 
-        inputStream = new FileInputStream(f)
+        batchStream = Some(new FileInputStream(f))
     })
 
-    batchCommand.foreach(commands => {
-        val ended = if (commands.endsWith(";")) commands else commands + ";"
+    batchCommand.foreach(commands =>
+        batchStream = Some(new ByteArrayInputStream(commands.replaceAll(";", "\n").getBytes("UTF-8"))))
 
-        val input = (if (ended.endsWith("exit;")) ended else ended + "exit;").replace(";", "\n")
+    val inputStream = batchStream match {
+        case Some(stream) =>
+            new SequenceInputStream(Collections.enumeration(util.Arrays.asList(stream,
+                new ByteArrayInputStream("\nquit\n".getBytes("UTF-8")))))
 
-        inputStream = new ByteArrayInputStream(input.getBytes("UTF-8"))
-    })
+        case None => new FileInputStream(FileDescriptor.in)
+    }
 
     private val reader = new ConsoleReader(inputStream, System.out, null, null)