View Source exec (erlexec v2.0.7)
OS shell command runner.
It communicates with a separate C++ port process exec-port
spawned by this module, which is responsible
for starting, killing, listing, terminating, and notifying of
state changes.
The port program serves as a middle-man between
the OS and the virtual machine to carry out OS-specific low-level
process control. The Erlang/C++ protocol is described in the
exec.cpp
file. The exec
application can execute tasks by
impersonating as a different effective user. This impersonation
can be accomplished in one of the following two ways (assuming
that the emulator is not running as root
:
- Having the user account running the erlang emulator added to
the
/etc/sudoers
file, so that it can executeexec-port
task asroot
. (Preferred option) - Setting
root
ownership onexec-port
, and setting the SUID bit:chown root:root exec-port; chmod 4755 exec-port
. (This option is discouraged as it's less secure).
In either of these two cases, exec:start_link/2
must be started
with options [root, {user, User}, {limit_users, Users}]
,
so that exec-port
process will not actually run as
root but will switch to the effective User
, and set the kernel
capabilities so that it's able to start processes as other
effective users given in the Users
list and adjust process
priorities.
Though, in the initial design, exec
prohibited such use, upon
user requests a feature was added (in order to support docker
deployment and CI testing) to be able to execute exec-port
as
root
without switching the effective user to anying other than
root
. To accomplish this use the following options to start
exec
: [root, {user, "root"}, {limit_users, ["root"]}]
.
At exit the port program makes its best effort to perform clean shutdown of all child OS processes. Every started OS process is linked to a spawned light-weight Erlang process returned by the run/2, run_link/2 command. The application ensures that termination of spawned OsPid leads to termination of the associated Erlang Pid, and vice versa.
debugging
Debugging
exec
supports several debugging options passed to exec:start/1
:
{debug, Level}
- turns on debug verbosity in the port program.verbose
- turns on verbosity in the Erlang code.valgrind
- runs exec under the Valgrind tool, which needs to be installed in the OS. This generates a localvalgrind.YYYYMMDDhhmmss.log
file containing Valgrind's output. If you need to customize the Valgrind command options, use{valgrind, "/path/to/valgrind Args ..."}
option.
Link to this section Summary
Types
Command to be executed. If specified as a string, the specified command
will be executed through the shell. The current shell is obtained
from environment variable SHELL
. This can be useful if you
are using Erlang primarily for the enhanced control flow it
offers over most system shells and still want convenient
access to other shell features such as shell pipes, filename
wildcards, environment variable expansion, and expansion of
~
to a user's home directory. All command arguments must
be properly escaped including whitespace and shell
metacharacters.
Command options
Options passed to the exec process at startup. They can be specified in the
sys.config
file for the erlexec
application to customize application
startup.
Representation of OS group ID
Representation of OS process ID
Output device option
Defines file opening attributes
Pty options.
List of pty options
Functions
Set debug level of the port process
Send a Signal
to a child Pid
, OsPid
or an Erlang Port
Get OsPid
of the given Erlang Pid
. The Pid
must be created
previously by running the run/2 or run_link/2 commands.
Get Pid
of the given OsPid
. The OsPid
must be created
previously by running the run/2 or run_link/2 commands.
Set the pty terminal options of the OS process identified by OsPid
.
Run an external program. OsPid
is the OS process identifier of
the new process. If sync
is specified in Options
the return
value is {ok, Status}
where Status
is OS process exit status.
The Status
can be decoded with status/1
to determine the
process's exit code and if it was killed by signal.
Run an external program and link to the OsPid. If OsPid exits,
the calling process will be killed or if it's trapping exits,
it'll get {'EXIT', OsPid, Status} message. If the calling process
dies the OsPid will be killed.
The Status
can be decoded with status/1
to determine the
process's exit code and if it was killed by signal.
Send Data
to stdin of the OS process identified by OsPid
.
Change group ID of a given OsPid
to Gid
Convert a signal number to atom
Start of an external program manager without supervision.
Note that the port program requires SHELL
environment variable to
be set.
Supervised start an external program manager.
Decode the program's exit_status. If the program exited by signal
the function returns {signal, Signal, Core}
where the Signal
is the signal number or atom, and Core
indicates if the core file
was generated.
Terminate a managed Pid
, OsPid
, or Port
process. The OS process is
terminated gracefully. If it was given a {kill, Cmd}
option at
startup, that command is executed and a timer is started. If
the program doesn't exit, then the default termination is
performed. Default termination implies sending a SIGTERM
command
followed by SIGKILL
in 5 seconds, if the program doesn't get
killed.
Terminate a managed Pid
, OsPid
, or Port
process, like
stop/1
, and wait for it to exit.
Get a list of children managed by port program
Set the pty terminal Rows
and Cols
of the OS process identified by OsPid
.
Link to this section Types
-type cmd() :: binary() | string() | [string()].
Command to be executed. If specified as a string, the specified command
will be executed through the shell. The current shell is obtained
from environment variable SHELL
. This can be useful if you
are using Erlang primarily for the enhanced control flow it
offers over most system shells and still want convenient
access to other shell features such as shell pipes, filename
wildcards, environment variable expansion, and expansion of
~
to a user's home directory. All command arguments must
be properly escaped including whitespace and shell
metacharacters.
Any part of the command string can contain unicode characters.
Warning: Executing shell commands that
incorporate unsanitized input from an untrusted source makes
a program vulnerable to
shell injection,
a serious security flaw which can result in arbitrary command
execution. For this reason, the use of shell
is strongly
discouraged in cases where the command string is constructed
from external input:
1> {ok, Filename} = io:read("Enter filename: ").
Enter filename: "non_existent; rm -rf / #".
{ok, "non_existent; rm -rf / #"}
2> exec(Filename, []) % Argh!!! This is not good!
When command is given in the form of a list of strings,
it is passed to execve(3)
library call directly without
involving the shell process, so the list of strings
represents the program to be executed given with a full path,
followed by the list of arguments (e.g. ["/bin/echo", "ok"]
).
In this case all shell-based features are disabled
and there's no shell injection vulnerability.
-type cmd_option() :: monitor | sync | link | {executable, string() | binary()} | {cd, WorkDir :: string() | binary()} | {env, [string() | clear | {Name :: string() | binary(), Val :: string() | binary() | false}, ...]} | {kill, KillCmd :: string() | binary()} | {kill_timeout, Sec :: non_neg_integer()} | kill_group | {group, GID :: string() | binary() | integer()} | {user, RunAsUser :: string() | binary()} | {nice, Priority :: integer()} | {success_exit_code, ExitCode :: integer()} | stdin | {stdin, null | close | string() | binary()} | stdout | stderr | {stdout, stderr | output_dev_opt()} | {stderr, stdout | output_dev_opt()} | {stdout | stderr, string() | binary(), [output_file_opt()]} | {winsz, {Rows :: non_neg_integer(), Cols :: non_neg_integer()}} | pty | {pty, pty_opts()} | pty_echo | debug | {debug, integer()}.
Command options:
monitor
: Set up a monitor for the spawned process. The monitor is not a standarderlang:montior/2
function call, but it's emulated by ensuring that the monitoring process receives notification in the form:{'DOWN', OsPid::integer(), process, Pid::pid(), Reason}
. If theReason
isnormal
, then process exited with status0
, otherwise there was an error. If the Reason is{status, Status}
the returnedStatus
can be decoded withstatus/1
to determine the exit code of the process and if it was killed by signal.sync
: Block the caller until the OS command exits{executable, Executable::string()}
: Specifies a replacement program to execute. It is very seldom needed. When the port program executes a child process usingexecve(3)
call, the call takes the following arguments:(Executable, Args, Env)
. WhenCmd
argument passed to therun/2
function is specified as the list of strings, the executable replaces the first parameter in the call, and the original args provided in theCmd
parameter are passed as as the second parameter. Most programs treat the program specified by args as the command name, which can then be different from the program actually executed. On Unix, the args name becomes the display name for the executable in utilities such asps
.If
Cmd
argument passed to therun/2
function is given as a string, on Unix theExecutable
specifies a replacement shell for the default/bin/sh
.{cd, WorkDir}
: Working directory{env, Env :: [{Name,Value}|string()|clear]}
: List of "VAR=VALUE" environment variables or list of {Name, Value} tuples or strings (like "NAME=VALUE") orclear
.clear
will clear environment of a spawned child OS process (so that it doesn't inherit parent's environment). IfValue
isfalse
then theVar
env variable is unset.{kill, KillCmd}
: This command will be used for killing the process. After a 5-sec timeout if the process is still alive, it'll be killed with SIGKILL. The kill command will have aCHILD_PID
environment variable set to the pid of the process it is expected to kill. If thekill
option is not specified, by default first the command is sent aSIGTERM
signal, followed bySIGKILL
after a default timeout.{kill_timeout, Sec::integer()}
: Number of seconds to wait after issuing a SIGTERM or executing the customkill
command (if specified) before killing the process with theSIGKILL
signalkill_group
: At process exit kill the whole process group associated with this pid. The process group is obtained by the call to getpgid(3).{group, GID}
: Sets the effective group ID of the spawned process. The value 0 means to create a new group ID equal to the OS pid of the process.{user, RunAsUser}
: When exec-port was compiled with capability (Linux) support enabled and has a suid bit set, it's capable of running commands with a different RunAsUser effective user. Passing "root" value ofRunAsUser
is prohibited.{success_exit_code, IntExitCode}
: On success useIntExitCode
return value instead of default 0.{nice, Priority}
: Set process priority between -20 and 20. Note that negative values can be specified only whenexec-port
is started with a root suid bit set.stdin | {stdin, null | close | Filename}
: Enable communication with an OS process via itsstdin
. The input to the process is sent byexec:send(OsPid, Data)
. When specified as a tuple,null
means redirection from/dev/null
,close
means to closestdin
stream, andFilename
means to take input from file.stdout
: Same as{stdout, self()}
.stderr
: Same as{stderr, self()}
.{stdout, output_device()}
: Redirect process's standard output stream{stderr, output_device()}
: Redirect process's standard error stream{stdout | stderr, Filename::string(), [output_dev_opt()]}
: Redirect process's stdout/stderr stream to file{winsz, {Rows, Cols}}
: Set the (psudo) terminal's dimensions of rows and columnspty
: Use pseudo terminal for the process's stdin, stdout and stderrpty_echo
: Allow the pty to run in echo mode, disabled by defaultdebug
: Same as{debug, 1}
{debug, Level::integer()}
: Enable debug printing in port program for this command
-type cmd_options() :: [cmd_option()].
-type exec_option() ::
debug |
{debug, integer()} |
root |
{root, boolean()} |
verbose |
{args, [string() | binary(), ...]} |
{alarm, non_neg_integer()} |
{user, string() | binary()} |
{limit_users, [string() | binary(), ...]} |
{portexe, string() | binary()} |
{env, [{string() | binary(), string() | binary() | false}, ...]} |
valgrind |
{valgrind, string()}.
Options passed to the exec process at startup. They can be specified in the
sys.config
file for the erlexec
application to customize application
startup.
debug
: Same as{debug, 1}
{debug, Level}
: Enable port-programs debug trace atLevel
.verbose
: Enable verbose prints of the Erlang process.root | {root, Boolean}
: Allow running child processes as root.{args, Args}
: AppendArgs
to the port command.{alarm, Secs}
: GiveSecs
deadline for the port program to clean up child pids before exiting{user, User}
: When the port program was compiled with capability (Linux) support enabled, and is owned by root with a a suid bit set, this option must be specified so that upon startup the port program is running under the effective user different from root. This is a security measure that will also prevent the port program to execute root commands.{limit_users, LimitUsers}
: Limit execution of external commands to these set of users. This option is only valid when the port program is owned by root.{portexe, Exe}
: Provide an alternative location of the port program. This option is useful when this application is stored on NFS and the port program needs to be copied locally so that root suid bit can be set.{env, Env}
: Extend environment of the port program by usingEnv
specification.Env
should be a list of tuples{Name, Val}
, where Name is the name of an environment variable, and Val is the value it is to have in the spawned port process. If Val isfalse
, then theName
environment variable is unset.valgrind
: Start port-exec by valgrind in order to check for memory and resource leaks. This is only adviseable for testing. For Valgrind support make sure that the tool is installed. Install with:
The Valgrind log will be written to the filesudo apt install valgrind # Ubuntu, Debian, etc. sudo yum install valgrind # RHEL, CentOS, Fedora, etc. sudo pacman -Syu valgrind debuginfod # Arch, Manjaro, Garuda, etc. sudo pkg ins valgrind # FreeBSD
valgrind-YYYYMMDDhhmmss.log
{valgrind, Command}
: Same asvalgrind
, but allows to specify the Valgrind command and its options (e.g. "/path/to/valgrind --leak-check=full")
-type exec_options() :: [exec_option()].
-type osgid() :: integer().
Representation of OS group ID
-type ospid() :: integer().
Representation of OS process ID
-type output_dev_opt() ::
null | close | print |
string() |
binary() |
pid() |
fun((stdout | stderr, integer(), binary()) -> none()).
Output device option:
null
: Suppress output.close
: Close file descriptor for writing.print
: A debugging convenience device that prints the output to the console shellFilename
: Save output to file by overwriting it.pid()
: Redirect output to this pid.fun((Stream, OsPid, Data) -> none())
: Execute this callback on receiving output data
-type output_file_opt() :: append | {mode, Mode :: integer()}.
Defines file opening attributes:
append
: Open the file inappend
mode{mode, Mode}
: File creation access mode <b>specified in base 8</b> (e.g. 8#0644)
-type pty_opt() :: {tty_char(), byte()} | {tty_mode(), boolean() | 0 | 1} | {tty_speed(), non_neg_integer()}.
Pty options.
See termios(3). See RFC4254.
{tty_char(), Byte}
: A special character with value from 0 to 255{tty_mode(), Enable}
: Enable/disable a tty mode{tty_speed(), Speed}
: Specify input or output baud rate. Provided for completeness. Not useful for pseudo terminals.
-type pty_opts() :: [pty_opt()].
List of pty options
-type tty_char() ::
vintr | vquit | verase | vkill | veof | veol | veol2 | vstart | vstop | vsusp | vdsusp |
vreprint | vwerase | vlnext | vflush | vswtch | vstatus | vdiscard.
-type tty_mode() ::
ignpar | parmrk | inpck | istrip | inlcr | igncr | icrnl | xcase | iuclc | ixon | ixany |
ixoff | imaxbel | iutf8 | isig | icanon | echo | echoe | echok | echonl | noflsh | tostop |
iexten | echoctl | echoke | pendin | opost | olcuc | onlcr | ocrnl | onocr | onlret | cs7 |
cs8 | parenb | parodd.
-type tty_speed() :: tty_op_ispeed | tty_op_ospeed.
Link to this section Functions
-spec debug(Level :: integer()) -> {ok, OldLevel :: integer()} | {error, timeout}.
Set debug level of the port process
-spec default() -> [{atom(), term()}].
-spec kill(pid() | ospid(), atom() | integer()) -> ok | {error, any()}.
Send a Signal
to a child Pid
, OsPid
or an Erlang Port
-spec ospid(pid()) -> ospid() | {error, Reason :: any()}.
Get OsPid
of the given Erlang Pid
. The Pid
must be created
previously by running the run/2 or run_link/2 commands.
-spec pid(OsPid :: ospid()) -> pid() | undefined | {error, timeout}.
Get Pid
of the given OsPid
. The OsPid
must be created
previously by running the run/2 or run_link/2 commands.
Set the pty terminal options of the OS process identified by OsPid
.
The process must have been created with the pty
option.
-spec run(cmd(), cmd_options(), integer()) -> {ok, pid(), ospid()} | {ok, [{stdout | stderr, [binary()]}]} | {error, any()}.
Run an external program. OsPid
is the OS process identifier of
the new process. If sync
is specified in Options
the return
value is {ok, Status}
where Status
is OS process exit status.
The Status
can be decoded with status/1
to determine the
process's exit code and if it was killed by signal.
-spec run_link(cmd(), cmd_options(), integer()) -> {ok, pid(), ospid()} | {ok, [{stdout | stderr, [binary()]}]} | {error, any()}.
Run an external program and link to the OsPid. If OsPid exits,
the calling process will be killed or if it's trapping exits,
it'll get {'EXIT', OsPid, Status} message. If the calling process
dies the OsPid will be killed.
The Status
can be decoded with status/1
to determine the
process's exit code and if it was killed by signal.
-spec send(OsPid :: ospid() | pid(), binary() | eof) -> ok.
Send Data
to stdin of the OS process identified by OsPid
.
Sending eof instead of binary Data causes close of stdin of the corresponding process. Data sent to closed stdin is ignored.
Change group ID of a given OsPid
to Gid
-spec signal(integer()) -> atom() | integer().
Convert a signal number to atom
-spec start() -> {ok, pid()} | {error, any()}.
Start of an external program manager without supervision.
Note that the port program requires SHELL
environment variable to
be set.
-spec start(exec_options()) -> {ok, pid()} | {error, any()}.
-spec start_link(exec_options()) -> {ok, pid()} | {error, any()}.
Supervised start an external program manager.
Note that the port program requires SHELL
environment variable to be set.
-spec status(integer()) ->
{status, ExitStatus :: integer()} |
{signal, Signal :: integer() | atom(), Core :: boolean()}.
Decode the program's exit_status. If the program exited by signal
the function returns {signal, Signal, Core}
where the Signal
is the signal number or atom, and Core
indicates if the core file
was generated.
-spec stop(pid() | ospid() | port()) -> ok | {error, any()}.
Terminate a managed Pid
, OsPid
, or Port
process. The OS process is
terminated gracefully. If it was given a {kill, Cmd}
option at
startup, that command is executed and a timer is started. If
the program doesn't exit, then the default termination is
performed. Default termination implies sending a SIGTERM
command
followed by SIGKILL
in 5 seconds, if the program doesn't get
killed.
-spec stop_and_wait(pid() | ospid() | port(), integer()) -> term() | {error, any()}.
Terminate a managed Pid
, OsPid
, or Port
process, like
stop/1
, and wait for it to exit.
-spec which_children() -> [ospid(), ...].
Get a list of children managed by port program
-spec winsz(OsPid :: ospid() | pid(), integer(), integer()) -> ok | {error, Reason :: any()}.
Set the pty terminal Rows
and Cols
of the OS process identified by OsPid
.
The process must have been created with the pty
option.