src/Pure/General/ssh.scala
author wenzelm
Thu, 09 Feb 2017 15:40:34 +0100
changeset 65009 eda9366bbfac
parent 64347 602483aa7818
child 65010 a27e9908dcf7
permissions -rw-r--r--
remote database access via ssh port forwarding;
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
     1
/*  Title:      Pure/General/ssh.scala
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
     2
    Author:     Makarius
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
     3
64124
818265654e60 tuned comment;
wenzelm
parents: 64123
diff changeset
     4
SSH client based on JSch (see also http://www.jcraft.com/jsch/examples).
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
     5
*/
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
     6
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
     7
package isabelle
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
     8
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
     9
64134
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
    10
import java.io.{InputStream, OutputStream, ByteArrayOutputStream}
64131
f01fca58e0a5 more specific channels;
wenzelm
parents: 64130
diff changeset
    11
64134
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
    12
import scala.collection.{mutable, JavaConversions}
64131
f01fca58e0a5 more specific channels;
wenzelm
parents: 64130
diff changeset
    13
64222
184e3a932778 clarified signature;
wenzelm
parents: 64191
diff changeset
    14
import com.jcraft.jsch.{JSch, Logger => JSch_Logger, Session => JSch_Session, SftpException,
64132
c2594513687b more Sftp operations;
wenzelm
parents: 64131
diff changeset
    15
  OpenSSHConfig, UserInfo, Channel => JSch_Channel, ChannelExec, ChannelSftp, SftpATTRS}
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    16
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    17
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    18
object SSH
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    19
{
64185
wenzelm
parents: 64166
diff changeset
    20
  /* target machine: user@host syntax */
64141
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    21
64185
wenzelm
parents: 64166
diff changeset
    22
  object Target
64141
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    23
  {
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    24
    val Pattern = "^([^@]+)@(.+)$".r
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    25
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    26
    def parse(s: String): (String, String) =
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    27
      s match {
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    28
        case Pattern(user, host) => (user, host)
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    29
        case _ => ("", s)
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    30
      }
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    31
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    32
    def unapplySeq(s: String): Option[List[String]] =
64185
wenzelm
parents: 64166
diff changeset
    33
      parse(s) match {
wenzelm
parents: 64166
diff changeset
    34
        case (_, "") => None
wenzelm
parents: 64166
diff changeset
    35
        case (user, host) => Some(List(user, host))
wenzelm
parents: 64166
diff changeset
    36
      }
64141
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    37
  }
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    38
64142
954451356017 proper type for Library.using;
wenzelm
parents: 64141
diff changeset
    39
  val default_port = 22
954451356017 proper type for Library.using;
wenzelm
parents: 64141
diff changeset
    40
64257
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    41
  def connect_timeout(options: Options): Int =
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    42
    options.seconds("ssh_connect_timeout").ms.toInt
64141
79cd4be708fb support user@host syntax;
wenzelm
parents: 64137
diff changeset
    43
64325
47e03cb99274 prevent sporadic disconnection;
wenzelm
parents: 64306
diff changeset
    44
  def alive_interval(options: Options): Int =
47e03cb99274 prevent sporadic disconnection;
wenzelm
parents: 64306
diff changeset
    45
    options.seconds("ssh_alive_interval").ms.toInt
47e03cb99274 prevent sporadic disconnection;
wenzelm
parents: 64306
diff changeset
    46
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    47
64257
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    48
  /* init context */
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    49
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    50
  def init_context(options: Options): Context =
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    51
  {
64130
e17c211a0bb6 clarified treatment of options;
wenzelm
parents: 64129
diff changeset
    52
    val config_dir = Path.explode(options.string("ssh_config_dir"))
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    53
    if (!config_dir.is_dir) error("Bad ssh config directory: " + config_dir)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    54
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    55
    val jsch = new JSch
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    56
64130
e17c211a0bb6 clarified treatment of options;
wenzelm
parents: 64129
diff changeset
    57
    val config_file = Path.explode(options.string("ssh_config_file"))
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    58
    if (config_file.is_file)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    59
      jsch.setConfigRepository(OpenSSHConfig.parseFile(File.platform_path(config_file)))
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    60
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    61
    val known_hosts = config_dir + Path.explode("known_hosts")
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    62
    if (!known_hosts.is_file) known_hosts.file.createNewFile
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    63
    jsch.setKnownHosts(File.platform_path(known_hosts))
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    64
64130
e17c211a0bb6 clarified treatment of options;
wenzelm
parents: 64129
diff changeset
    65
    val identity_files =
e17c211a0bb6 clarified treatment of options;
wenzelm
parents: 64129
diff changeset
    66
      Library.space_explode(':', options.string("ssh_identity_files")).map(Path.explode(_))
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    67
    for (identity_file <- identity_files if identity_file.is_file)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    68
      jsch.addIdentity(File.platform_path(identity_file))
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    69
64257
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    70
    new Context(options, jsch)
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    71
  }
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    72
64257
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    73
  class Context private[SSH](val options: Options, val jsch: JSch)
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    74
  {
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    75
    def update_options(new_options: Options): Context = new Context(new_options, jsch)
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    76
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    77
    def open_session(host: String, user: String = "", port: Int = default_port): Session =
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    78
    {
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    79
      val session = jsch.getSession(if (user == "") null else user, host, port)
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    80
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    81
      session.setUserInfo(No_User_Info)
64325
47e03cb99274 prevent sporadic disconnection;
wenzelm
parents: 64306
diff changeset
    82
      session.setServerAliveInterval(alive_interval(options))
64257
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    83
      session.setConfig("MaxAuthTries", "3")
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    84
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    85
      if (options.bool("ssh_compression")) {
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    86
        session.setConfig("compression.s2c", "zlib@openssh.com,zlib,none")
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    87
        session.setConfig("compression.c2s", "zlib@openssh.com,zlib,none")
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    88
        session.setConfig("compression_level", "9")
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    89
      }
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    90
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    91
      session.connect(connect_timeout(options))
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    92
      new Session(options, session)
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    93
    }
9d51ac055cec tuned signature;
wenzelm
parents: 64256
diff changeset
    94
  }
64130
e17c211a0bb6 clarified treatment of options;
wenzelm
parents: 64129
diff changeset
    95
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    96
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    97
  /* logging */
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    98
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
    99
  def logging(verbose: Boolean = true, debug: Boolean = false)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   100
  {
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   101
    JSch.setLogger(if (verbose) new Logger(debug) else null)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   102
  }
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   103
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   104
  private class Logger(debug: Boolean) extends JSch_Logger
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   105
  {
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   106
    def isEnabled(level: Int): Boolean = level != JSch_Logger.DEBUG || debug
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   107
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   108
    def log(level: Int, msg: String)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   109
    {
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   110
      level match {
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   111
        case JSch_Logger.ERROR | JSch_Logger.FATAL => Output.error_message(msg)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   112
        case JSch_Logger.WARN => Output.warning(msg)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   113
        case _ => Output.writeln(msg)
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   114
      }
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   115
    }
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   116
  }
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   117
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   118
64128
wenzelm
parents: 64127
diff changeset
   119
  /* user info */
wenzelm
parents: 64127
diff changeset
   120
wenzelm
parents: 64127
diff changeset
   121
  object No_User_Info extends UserInfo
wenzelm
parents: 64127
diff changeset
   122
  {
wenzelm
parents: 64127
diff changeset
   123
    def getPassphrase: String = null
wenzelm
parents: 64127
diff changeset
   124
    def getPassword: String = null
wenzelm
parents: 64127
diff changeset
   125
    def promptPassword(msg: String): Boolean = false
wenzelm
parents: 64127
diff changeset
   126
    def promptPassphrase(msg: String): Boolean = false
wenzelm
parents: 64127
diff changeset
   127
    def promptYesNo(msg: String): Boolean = false
wenzelm
parents: 64127
diff changeset
   128
    def showMessage(msg: String): Unit = Output.writeln(msg)
wenzelm
parents: 64127
diff changeset
   129
  }
wenzelm
parents: 64127
diff changeset
   130
wenzelm
parents: 64127
diff changeset
   131
65009
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   132
  /* port forwarding */
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   133
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   134
  sealed case class Port_Forwarding(ssh: SSH.Session, host: String, port: Int)
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   135
  {
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   136
    def close() { ssh.session.delPortForwardingL(host, port) }
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   137
  }
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   138
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   139
64191
wenzelm
parents: 64190
diff changeset
   140
  /* Sftp channel */
wenzelm
parents: 64190
diff changeset
   141
wenzelm
parents: 64190
diff changeset
   142
  type Attrs = SftpATTRS
wenzelm
parents: 64190
diff changeset
   143
64233
ef6f7e8a018c clarified signature: more static types;
wenzelm
parents: 64228
diff changeset
   144
  sealed case class Dir_Entry(name: Path, attrs: Attrs)
64191
wenzelm
parents: 64190
diff changeset
   145
  {
wenzelm
parents: 64190
diff changeset
   146
    def is_file: Boolean = attrs.isReg
wenzelm
parents: 64190
diff changeset
   147
    def is_dir: Boolean = attrs.isDir
wenzelm
parents: 64190
diff changeset
   148
  }
wenzelm
parents: 64190
diff changeset
   149
wenzelm
parents: 64190
diff changeset
   150
64132
c2594513687b more Sftp operations;
wenzelm
parents: 64131
diff changeset
   151
  /* exec channel */
c2594513687b more Sftp operations;
wenzelm
parents: 64131
diff changeset
   152
64134
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   153
  private val exec_wait_delay = Time.seconds(0.3)
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   154
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   155
  class Exec private[SSH](session: Session, channel: ChannelExec)
64131
f01fca58e0a5 more specific channels;
wenzelm
parents: 64130
diff changeset
   156
  {
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   157
    override def toString: String = "exec " + session.toString
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   158
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   159
    def close() { channel.disconnect }
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   160
64134
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   161
    val exit_status: Future[Int] =
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   162
      Future.thread("ssh_wait") {
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   163
        while (!channel.isClosed) Thread.sleep(exec_wait_delay.ms)
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   164
        channel.getExitStatus
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   165
      }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   166
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   167
    val stdin: OutputStream = channel.getOutputStream
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   168
    val stdout: InputStream = channel.getInputStream
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   169
    val stderr: InputStream = channel.getErrStream
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   170
64166
44925cf6ded1 tuned signature;
wenzelm
parents: 64142
diff changeset
   171
    // connect after preparing streams
44925cf6ded1 tuned signature;
wenzelm
parents: 64142
diff changeset
   172
    channel.connect(connect_timeout(session.options))
64134
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   173
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   174
    def result(
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   175
      progress_stdout: String => Unit = (_: String) => (),
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   176
      progress_stderr: String => Unit = (_: String) => (),
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   177
      strict: Boolean = true): Process_Result =
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   178
    {
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   179
      stdin.close
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   180
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   181
      def read_lines(stream: InputStream, progress: String => Unit): List[String] =
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   182
      {
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   183
        val result = new mutable.ListBuffer[String]
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   184
        val line_buffer = new ByteArrayOutputStream(100)
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   185
        def line_flush()
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   186
        {
64326
ff3c383b9163 extra trim_line for the sake of Windows;
wenzelm
parents: 64325
diff changeset
   187
          val line = Library.trim_line(line_buffer.toString(UTF8.charset_name))
64134
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   188
          progress(line)
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   189
          result += line
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   190
          line_buffer.reset
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   191
        }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   192
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   193
        var c = 0
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   194
        var finished = false
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   195
        while (!finished) {
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   196
          while ({ c = stream.read; c != -1 && c != 10 }) line_buffer.write(c)
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   197
          if (c == 10) line_flush()
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   198
          else if (channel.isClosed) {
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   199
            if (line_buffer.size > 0) line_flush()
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   200
            finished = true
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   201
          }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   202
          else Thread.sleep(exec_wait_delay.ms)
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   203
        }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   204
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   205
        result.toList
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   206
      }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   207
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   208
      val out_lines = Future.thread("ssh_stdout") { read_lines(stdout, progress_stdout) }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   209
      val err_lines = Future.thread("ssh_stderr") { read_lines(stderr, progress_stderr) }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   210
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   211
      def terminate()
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   212
      {
64136
7c5191489457 close more thoroughly;
wenzelm
parents: 64135
diff changeset
   213
        close
64134
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   214
        out_lines.join
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   215
        err_lines.join
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   216
        exit_status.join
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   217
      }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   218
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   219
      val rc =
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   220
        try { exit_status.join }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   221
        catch { case Exn.Interrupt() => terminate(); Exn.Interrupt.return_code }
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   222
64136
7c5191489457 close more thoroughly;
wenzelm
parents: 64135
diff changeset
   223
      close
64134
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   224
      if (strict && rc == Exn.Interrupt.return_code) throw Exn.Interrupt()
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   225
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   226
      Process_Result(rc, out_lines.join, err_lines.join)
57581e4026fe proper support for exec channel (see also bash.scala);
wenzelm
parents: 64133
diff changeset
   227
    }
64131
f01fca58e0a5 more specific channels;
wenzelm
parents: 64130
diff changeset
   228
  }
f01fca58e0a5 more specific channels;
wenzelm
parents: 64130
diff changeset
   229
f01fca58e0a5 more specific channels;
wenzelm
parents: 64130
diff changeset
   230
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   231
  /* session */
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   232
64166
44925cf6ded1 tuned signature;
wenzelm
parents: 64142
diff changeset
   233
  class Session private[SSH](val options: Options, val session: JSch_Session)
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   234
  {
64166
44925cf6ded1 tuned signature;
wenzelm
parents: 64142
diff changeset
   235
    def update_options(new_options: Options): Session = new Session(new_options, session)
44925cf6ded1 tuned signature;
wenzelm
parents: 64142
diff changeset
   236
64347
602483aa7818 support for URL notation;
wenzelm
parents: 64326
diff changeset
   237
    def user_prefix: String = if (session.getUserName == null) "" else session.getUserName + "@"
602483aa7818 support for URL notation;
wenzelm
parents: 64326
diff changeset
   238
    def host: String = if (session.getHost == null) "" else session.getHost
602483aa7818 support for URL notation;
wenzelm
parents: 64326
diff changeset
   239
    def port_suffix: String = if (session.getPort == default_port) "" else ":" + session.getPort
602483aa7818 support for URL notation;
wenzelm
parents: 64326
diff changeset
   240
    def hg_url: String = "ssh://" + user_prefix + host + port_suffix + "/"
602483aa7818 support for URL notation;
wenzelm
parents: 64326
diff changeset
   241
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   242
    override def toString: String =
64347
602483aa7818 support for URL notation;
wenzelm
parents: 64326
diff changeset
   243
      user_prefix + host + port_suffix + (if (session.isConnected) "" else " (disconnected)")
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   244
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   245
65009
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   246
    /* port forwarding */
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   247
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   248
    def port_forwarding(
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   249
        remote_port: Int, remote_host: String = "localhost",
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   250
        local_port: Int = 0, local_host: String = "localhost"): Port_Forwarding =
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   251
      Port_Forwarding(this, local_host,
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   252
        session.setPortForwardingL(local_host, local_port, remote_host, remote_port))
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   253
eda9366bbfac remote database access via ssh port forwarding;
wenzelm
parents: 64347
diff changeset
   254
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   255
    /* sftp channel */
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   257
    val sftp: ChannelSftp = session.openChannel("sftp").asInstanceOf[ChannelSftp]
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   258
    sftp.connect(connect_timeout(options))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   259
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   260
    def close() { sftp.disconnect; session.disconnect }
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   261
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   262
    val settings: Map[String, String] =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   263
    {
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   264
      val home = sftp.getHome
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   265
      Map("HOME" -> home, "USER_HOME" -> home)
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   266
    }
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   267
    def expand_path(path: Path): Path = path.expand_env(settings)
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   268
    def remote_path(path: Path): String = expand_path(path).implode
64304
96bc94c87a81 clarified modules;
wenzelm
parents: 64258
diff changeset
   269
    def bash_path(path: Path): String = Bash.string(remote_path(path))
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   270
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   271
    def chmod(permissions: Int, path: Path): Unit = sftp.chmod(permissions, remote_path(path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   272
    def mv(path1: Path, path2: Path): Unit = sftp.rename(remote_path(path1), remote_path(path2))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   273
    def rm(path: Path): Unit = sftp.rm(remote_path(path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   274
    def mkdir(path: Path): Unit = sftp.mkdir(remote_path(path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   275
    def rmdir(path: Path): Unit = sftp.rmdir(remote_path(path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   276
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   277
    def stat(path: Path): Option[Dir_Entry] =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   278
      try { Some(Dir_Entry(expand_path(path), sftp.stat(remote_path(path)))) }
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   279
      catch { case _: SftpException => None }
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   280
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   281
    def is_file(path: Path): Boolean = stat(path).map(_.is_file) getOrElse false
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   282
    def is_dir(path: Path): Boolean = stat(path).map(_.is_dir) getOrElse false
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   283
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   284
    def mkdirs(path: Path): Unit =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   285
      if (!is_dir(path)) {
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   286
        execute(
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   287
          "perl -e \"use File::Path make_path; make_path('" + remote_path(path) + "');\"")
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   288
        if (!is_dir(path)) error("Failed to create directory: " + quote(remote_path(path)))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   289
      }
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   290
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   291
    def read_dir(path: Path): List[Dir_Entry] =
64191
wenzelm
parents: 64190
diff changeset
   292
    {
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   293
      val dir = sftp.ls(remote_path(path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   294
      (for {
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   295
        i <- (0 until dir.size).iterator
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   296
        a = dir.get(i).asInstanceOf[AnyRef]
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   297
        name = Untyped.get[String](a, "filename")
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   298
        attrs = Untyped.get[Attrs](a, "attrs")
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   299
        if name != "." && name != ".."
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   300
      } yield Dir_Entry(Path.basic(name), attrs)).toList
64191
wenzelm
parents: 64190
diff changeset
   301
    }
64135
865dda40e1cc provide execute operation, similar to Isabelle_System.bash;
wenzelm
parents: 64134
diff changeset
   302
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   303
    def find_files(root: Path, pred: Dir_Entry => Boolean = _ => true): List[Dir_Entry] =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   304
    {
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   305
      def find(dir: Path): List[Dir_Entry] =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   306
        read_dir(dir).flatMap(entry =>
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   307
          {
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   308
            val file = dir + entry.name
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   309
            if (entry.is_dir) find(file)
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   310
            else if (pred(entry)) List(entry.copy(name = file))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   311
            else Nil
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   312
          })
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   313
      find(root)
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   314
    }
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   315
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   316
    def open_input(path: Path): InputStream = sftp.get(remote_path(path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   317
    def open_output(path: Path): OutputStream = sftp.put(remote_path(path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   318
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   319
    def read_file(path: Path, local_path: Path): Unit =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   320
      sftp.get(remote_path(path), File.platform_path(local_path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   321
    def read_bytes(path: Path): Bytes = using(open_input(path))(Bytes.read_stream(_))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   322
    def read(path: Path): String = using(open_input(path))(File.read_stream(_))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   323
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   324
    def write_file(path: Path, local_path: Path): Unit =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   325
      sftp.put(File.platform_path(local_path), remote_path(path))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   326
    def write_bytes(path: Path, bytes: Bytes): Unit =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   327
      using(open_output(path))(bytes.write_stream(_))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   328
    def write(path: Path, text: String): Unit =
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   329
      using(open_output(path))(stream => Bytes(text).write_stream(stream))
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   330
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   331
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   332
    /* exec channel */
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   333
64166
44925cf6ded1 tuned signature;
wenzelm
parents: 64142
diff changeset
   334
    def exec(command: String): Exec =
64129
fce8b7c746b4 support for remote command execution;
wenzelm
parents: 64128
diff changeset
   335
    {
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   336
      val channel = session.openChannel("exec").asInstanceOf[ChannelExec]
64190
c62b99e3ec07 provide USER_HOME, such that symbolic Path.explode("~") can be used remotely;
wenzelm
parents: 64185
diff changeset
   337
      channel.setCommand("export USER_HOME=\"$HOME\"\n" + command)
64256
c3197aeae90b simplified SSH.Session: sftp channel is always open and its operations provided by the main interface;
wenzelm
parents: 64254
diff changeset
   338
      new Exec(this, channel)
64129
fce8b7c746b4 support for remote command execution;
wenzelm
parents: 64128
diff changeset
   339
    }
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   340
64191
wenzelm
parents: 64190
diff changeset
   341
    def execute(command: String,
wenzelm
parents: 64190
diff changeset
   342
        progress_stdout: String => Unit = (_: String) => (),
wenzelm
parents: 64190
diff changeset
   343
        progress_stderr: String => Unit = (_: String) => (),
wenzelm
parents: 64190
diff changeset
   344
        strict: Boolean = true): Process_Result =
wenzelm
parents: 64190
diff changeset
   345
      exec(command).result(progress_stdout, progress_stderr, strict)
64137
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   346
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   347
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   348
    /* tmp dirs */
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   349
64306
7b6dc1b36f20 tuned signature, in accordance to Isabelle_System;
wenzelm
parents: 64304
diff changeset
   350
    def rm_tree(dir: Path): Unit = rm_tree(remote_path(dir))
7b6dc1b36f20 tuned signature, in accordance to Isabelle_System;
wenzelm
parents: 64304
diff changeset
   351
64137
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   352
    def rm_tree(remote_dir: String): Unit =
64304
96bc94c87a81 clarified modules;
wenzelm
parents: 64258
diff changeset
   353
      execute("rm -r -f " + Bash.string(remote_dir)).check
64137
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   354
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   355
    def tmp_dir(): String =
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   356
      execute("mktemp -d -t tmp.XXXXXXXXXX").check.out
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   357
64233
ef6f7e8a018c clarified signature: more static types;
wenzelm
parents: 64228
diff changeset
   358
    def with_tmp_dir[A](body: Path => A): A =
64137
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   359
    {
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   360
      val remote_dir = tmp_dir()
64233
ef6f7e8a018c clarified signature: more static types;
wenzelm
parents: 64228
diff changeset
   361
      try { body(Path.explode(remote_dir)) } finally { rm_tree(remote_dir) }
64137
e9b3d9c1bc5a support for remote tmp dirs;
wenzelm
parents: 64136
diff changeset
   362
    }
64123
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   363
  }
a967b5a07f92 support for SSH in Isabelle/Scala;
wenzelm
parents:
diff changeset
   364
}