X-Git-Url: http://nitlanguage.org diff --git a/lib/standard/exec.nit b/lib/standard/exec.nit index eda24a9..1ee3095 100644 --- a/lib/standard/exec.nit +++ b/lib/standard/exec.nit @@ -5,175 +5,175 @@ # # This file is free software, which comes along with NIT. This software is # distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; -# without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# without even the implied warranty of MERCHANTABILITY or FITNESS FOR A # PARTICULAR PURPOSE. You can modify it is you want, provided this header # is kept unaltered, and a notification of the changes is added. # You are allowed to redistribute it and sell it, alone or is a part of # another product. -# This module handle simple system calls -# Standard input and output can be handleb trougth streams. -package exec +# Invocation and management of operating system sub-processes. +# Standard input and output can be handled through streams. +module exec import stream -# Simple sub-processus +# Simple sub-process class Process + # The pid of the process + fun id: Int do return data.id - # The pid of the processus - fun id: Int do return _data.id + # Is the process finished? + fun is_finished: Bool do return data.is_finished - # Is the processus finished? - fun is_finished: Bool do return _data.is_finished - - # wait the terminaison of the process + # Wait the termination of the process fun wait do - _data.wait + data.wait assert is_finished end - + # The status once finished fun status: Int do assert is_finished - return _data.status + return data.status end - # send a signal to the process - fun kill(signal: Int) do _data.kill(signal) + # The executable run + # Is a filepath, or a executable found in PATH + var command: String - # send the TERM (15) signal - fun term do kill(15) + # The arguments of the command + # Starts with the first real arguments---ie. does not include the progname (`argv[0]`, in C) + var arguments: nullable Array[String] - # launch a command with some arguments + # Launch a command with some arguments init(command: String, arguments: String...) do - execute(command, arguments, 0) + self.command = command + self.arguments = arguments + execute end - # launch a simple command without arguments - init init_(command: String) + # Launch a simple command with arguments passed as an array + init from_a(command: String, arguments: nullable Array[String]) do - execute(command, null, 0) + self.command = command + self.arguments = arguments + execute end - # Internal code to handle execusion - protected init execute(command: String, arguments: nullable Array[String], pipeflags: Int) + # flags used internally to know whith pipe to open + private fun pipeflags: Int do return 0 + + # Internal code to handle execution + protected fun execute do - var args = new Buffer + # The pass the arguments as a big C string where elements are separated with '\0' + var args = new FlatBuffer var l = 1 # Number of elements in args args.append(command) if arguments != null then for a in arguments do args.add('\0') + #a.output_class_name args.append(a) end l += arguments.length end - _data = basic_exec_execute(command.to_cstring, args.to_s.to_cstring, l, pipeflags) + data = basic_exec_execute(command.to_cstring, args.to_s.to_cstring, l, pipeflags) end - - var _data: NativeProcess + + private var data: NativeProcess private fun basic_exec_execute(p: NativeString, av: NativeString, ac: Int, pf: Int): NativeProcess is extern "exec_Process_Process_basic_exec_execute_4" end -# stdout of the processus is readable +# stdout of the process is readable class IProcess -special Process -special IStream - var _in: FDIStream - - redef fun close do _in.close - - redef fun read_char do return _in.read_char + super Process + super IStream - redef fun eof do return _in.eof + # File Descriptor used for the input. + var stream_in: FDIStream is noinit - init(command: String, arguments: String...) - do - execute(command, arguments, 2) - _in = new FDIStream(_data.out_fd) - end - - init init_(command: String) + redef fun close do stream_in.close + + redef fun read_char do return stream_in.read_char + + redef fun eof do return stream_in.eof + + redef fun pipeflags do return 2 + + redef fun execute do - execute(command, null, 2) - _in = new FDIStream(_data.out_fd) + super + stream_in = new FDIStream(data.out_fd) end end -# stdin of the processus is writable +# stdin of the process is writable class OProcess -special Process -special OStream - var _out: OStream + super Process + super OStream - redef fun close do _out.close + # File Descriptor used for the output. + var stream_out: OStream is noinit - redef fun is_writable do return _out.is_writable + redef fun close do stream_out.close - redef fun write(s) do _out.write(s) - - init(command: String, arguments: String...) - do - execute(command, arguments, 1) - _out = new FDOStream(_data.in_fd) - end - - init init_(command: String) + redef fun is_writable do return stream_out.is_writable + + redef fun write(s) do stream_out.write(s) + + redef fun pipeflags do return 1 + + redef fun execute do - execute(command, null, 1) - _out = new FDOStream(_data.in_fd) + super + stream_out = new FDOStream(data.in_fd) end end # stdin and stdout are both accessible class IOProcess -special IProcess -special OProcess -special IOStream + super IProcess + super OProcess + super IOStream redef fun close do - _in.close - _out.close + stream_in.close + stream_out.close end - init(command: String, arguments: String...) - do - execute(command, arguments, 3) - _in = new FDIStream(_data.out_fd) - _out = new FDOStream(_data.in_fd) - end - - init init_(command: String) + redef fun pipeflags do return 3 + + redef fun execute do - execute(command, null, 3) - _in = new FDIStream(_data.out_fd) - _out = new FDOStream(_data.in_fd) + super end end redef class Sys - # Execute a shell command and return it's error code + # Execute a shell command and return its error code fun system(command: String): Int do - return command.to_cstring.system + return command.to_cstring.system end end redef class NativeString + # Execute self as a shell command. + # + # See the posix function system(3). fun system: Int is extern "string_NativeString_NativeString_system_0" end -private universal NativeProcess -special Pointer +private extern class NativeProcess fun id: Int is extern "exec_NativeProcess_NativeProcess_id_0" fun is_finished: Bool is extern "exec_NativeProcess_NativeProcess_is_finished_0" fun status: Int is extern "exec_NativeProcess_NativeProcess_status_0" fun wait is extern "exec_NativeProcess_NativeProcess_wait_0" - fun kill(s: Int) is extern "exec_NativeProcess_NativeProcess_kill_1" fun in_fd: Int is extern "exec_NativeProcess_NativeProcess_in_fd_0" fun out_fd: Int is extern "exec_NativeProcess_NativeProcess_out_fd_0"