eio 0.10 · OCaml Package

Managing child processes.

Example:

# Eio_main.run @@ fun env ->
  let proc_mgr = Eio.Stdenv.process_mgr env in
  Eio.Process.parse_out proc_mgr Eio.Buf_read.line ["echo"; "hello"]

Status and error types

type exit_status = [

| `Exited of int
(*
Process exited with the given return code.
*)
| `Signaled of int
(*
Process was killed by the given signal.
*)

]

type status = [

| exit_status
| `Stopped of int
(*
Process was stopped (paused) by the given signal.
*)

]

val pp_status : [< status ] Fmt.t

type error =

| Executable_not_found of string
(*
The requested executable does not exist.
*)
| Child_error of exit_status
(*
The process exited with an error status.
*)

type Exn.err +=

| E of error

val err : error -> exn

err e is Eio.Exn.create (E e)

val pp_args : string list Fmt.t

Formats a list of arguments, quoting any that might cause confusion to the reader.

This is intended for use in error messages and logging.

Processes

class virtual t : object ... end

A process.

val pid : t -> int

pid t is the process ID of t.

val await : t -> exit_status

await t waits for process t to exit and then reports the status.

val await_exn : t -> unit

Like await except an exception is raised if the status is not `Exited 0.

val signal : t -> int -> unit

signal t i sends the signal i to process t.

If the process has already exited then this does nothing (it will not signal a different process, even if the PID has been reused).

See Sys for the signal numbers.

Spawning processes

class virtual mgr : object ... end

A process manager capable of spawning new processes.

val spawn : 
  sw:Switch.t ->
  mgr ->
  ?cwd:Fs.dir Path.t ->
  ?stdin:Flow.source ->
  ?stdout:Flow.sink ->
  ?stderr:Flow.sink ->
  ?env:string array ->
  ?executable:string ->
  string list ->
  t

spawn ~sw mgr args creates a new child process that is connected to the switch sw.

The child process will be sent Sys.sigkill when the switch is released.

If the flows stdin, stdout and stderr are not backed by file descriptors then this also creates pipes and spawns fibers to copy the data as necessary. If you need more control over file descriptors, see Eio_unix.Process.

parameter cwd
The current working directory of the process (default: same as parent process).

parameter stdin
The flow to attach to the process's standard input (default: same as parent process).

parameter stdout
A flow that the process's standard output goes to (default: same as parent process).

parameter stderr
A flow that the process's standard error goes to (default: same as parent process).

parameter env
The environment for the process (default: same as parent process).

parameter executable
The path of the executable to run. If not given then the first item in args is used, searching $PATH for it if necessary.

val run : 
  mgr ->
  ?cwd:Fs.dir Path.t ->
  ?stdin:Flow.source ->
  ?stdout:Flow.sink ->
  ?stderr:Flow.sink ->
  ?env:string array ->
  ?executable:string ->
  string list ->
  unit

run does spawn followed by await_exn, with the advantage that if the process fails then the error message includes the command that failed.

Note: If spawn needed to create extra fibers to copy stdin, etc, then it also waits for those to finish.

val parse_out : 
  mgr ->
  'a Buf_read.parser ->
  ?cwd:Fs.dir Path.t ->
  ?stdin:Flow.source ->
  ?stderr:Flow.sink ->
  ?env:string array ->
  ?executable:string ->
  string list ->
  'a

parse_out mgr parser args runs args and parses the child's stdout with parser.

It also waits for the process to finish and checks its exit status is zero.

Note that parser must consume the entire output of the process (like Buf_read.parse).

To return all the output as a string, use Buf_read.take_all as the parser.

This is a convenience wrapper around run, and the optional arguments have the same meanings.

Pipes

val pipe : 
  sw:Switch.t ->
  mgr ->
  < Flow.source ; Flow.close > * < Flow.sink ; Flow.close >

pipe ~sw mgr creates a pipe backed by the OS.

The flows can be used by spawn without the need for extra fibers to copy the data. This can be used to connect multiple processes together.

package eio

Status and error types

Processes

Spawning processes

Pipes