mirror of https://github.com/docker/cli.git
266 lines
7.5 KiB
Go
266 lines
7.5 KiB
Go
package container
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"io"
|
|
"os"
|
|
|
|
"github.com/docker/cli/cli"
|
|
"github.com/docker/cli/cli/command"
|
|
"github.com/docker/cli/cli/command/completion"
|
|
"github.com/docker/cli/cli/config/configfile"
|
|
"github.com/docker/cli/opts"
|
|
"github.com/docker/docker/api/types"
|
|
apiclient "github.com/docker/docker/client"
|
|
"github.com/pkg/errors"
|
|
"github.com/sirupsen/logrus"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
// ExecOptions group options for `exec` command
|
|
type ExecOptions struct {
|
|
DetachKeys string
|
|
Interactive bool
|
|
TTY bool
|
|
Detach bool
|
|
User string
|
|
Privileged bool
|
|
Env opts.ListOpts
|
|
Workdir string
|
|
Container string
|
|
Command []string
|
|
EnvFile opts.ListOpts
|
|
}
|
|
|
|
// NewExecOptions creates a new ExecOptions
|
|
func NewExecOptions() ExecOptions {
|
|
return ExecOptions{
|
|
Env: opts.NewListOpts(opts.ValidateEnv),
|
|
EnvFile: opts.NewListOpts(nil),
|
|
}
|
|
}
|
|
|
|
// NewExecCommand creates a new cobra.Command for `docker exec`
|
|
func NewExecCommand(dockerCli command.Cli) *cobra.Command {
|
|
options := NewExecOptions()
|
|
|
|
cmd := &cobra.Command{
|
|
Use: "exec [OPTIONS] CONTAINER COMMAND [ARG...]",
|
|
Short: "Execute a command in a running container",
|
|
Args: cli.RequiresMinArgs(2),
|
|
RunE: func(cmd *cobra.Command, args []string) error {
|
|
options.Container = args[0]
|
|
options.Command = args[1:]
|
|
return RunExec(context.Background(), dockerCli, options)
|
|
},
|
|
ValidArgsFunction: completion.ContainerNames(dockerCli, false, func(container types.Container) bool {
|
|
return container.State != "paused"
|
|
}),
|
|
Annotations: map[string]string{
|
|
"category-top": "2",
|
|
"aliases": "docker container exec, docker exec",
|
|
},
|
|
}
|
|
|
|
flags := cmd.Flags()
|
|
flags.SetInterspersed(false)
|
|
|
|
flags.StringVarP(&options.DetachKeys, "detach-keys", "", "", "Override the key sequence for detaching a container")
|
|
flags.BoolVarP(&options.Interactive, "interactive", "i", false, "Keep STDIN open even if not attached")
|
|
flags.BoolVarP(&options.TTY, "tty", "t", false, "Allocate a pseudo-TTY")
|
|
flags.BoolVarP(&options.Detach, "detach", "d", false, "Detached mode: run command in the background")
|
|
flags.StringVarP(&options.User, "user", "u", "", `Username or UID (format: "<name|uid>[:<group|gid>]")`)
|
|
flags.BoolVarP(&options.Privileged, "privileged", "", false, "Give extended privileges to the command")
|
|
flags.VarP(&options.Env, "env", "e", "Set environment variables")
|
|
flags.SetAnnotation("env", "version", []string{"1.25"})
|
|
flags.Var(&options.EnvFile, "env-file", "Read in a file of environment variables")
|
|
flags.SetAnnotation("env-file", "version", []string{"1.25"})
|
|
flags.StringVarP(&options.Workdir, "workdir", "w", "", "Working directory inside the container")
|
|
flags.SetAnnotation("workdir", "version", []string{"1.35"})
|
|
|
|
cmd.RegisterFlagCompletionFunc(
|
|
"env",
|
|
func(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) {
|
|
return os.Environ(), cobra.ShellCompDirectiveNoFileComp
|
|
},
|
|
)
|
|
cmd.RegisterFlagCompletionFunc(
|
|
"env-file",
|
|
func(cmd *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) {
|
|
return nil, cobra.ShellCompDirectiveDefault // _filedir
|
|
},
|
|
)
|
|
|
|
return cmd
|
|
}
|
|
|
|
// RunExec executes an `exec` command
|
|
func RunExec(ctx context.Context, dockerCli command.Cli, options ExecOptions) error {
|
|
execConfig, err := parseExec(options, dockerCli.ConfigFile())
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
client := dockerCli.Client()
|
|
|
|
// We need to check the tty _before_ we do the ContainerExecCreate, because
|
|
// otherwise if we error out we will leak execIDs on the server (and
|
|
// there's no easy way to clean those up). But also in order to make "not
|
|
// exist" errors take precedence we do a dummy inspect first.
|
|
if _, err := client.ContainerInspect(ctx, options.Container); err != nil {
|
|
return err
|
|
}
|
|
if !execConfig.Detach {
|
|
if err := dockerCli.In().CheckTty(execConfig.AttachStdin, execConfig.Tty); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
fillConsoleSize(execConfig, dockerCli)
|
|
|
|
response, err := client.ContainerExecCreate(ctx, options.Container, *execConfig)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
execID := response.ID
|
|
if execID == "" {
|
|
return errors.New("exec ID empty")
|
|
}
|
|
|
|
if execConfig.Detach {
|
|
execStartCheck := types.ExecStartCheck{
|
|
Detach: execConfig.Detach,
|
|
Tty: execConfig.Tty,
|
|
ConsoleSize: execConfig.ConsoleSize,
|
|
}
|
|
return client.ContainerExecStart(ctx, execID, execStartCheck)
|
|
}
|
|
return interactiveExec(ctx, dockerCli, execConfig, execID)
|
|
}
|
|
|
|
func fillConsoleSize(execConfig *types.ExecConfig, dockerCli command.Cli) {
|
|
if execConfig.Tty {
|
|
height, width := dockerCli.Out().GetTtySize()
|
|
execConfig.ConsoleSize = &[2]uint{height, width}
|
|
}
|
|
}
|
|
|
|
func interactiveExec(ctx context.Context, dockerCli command.Cli, execConfig *types.ExecConfig, execID string) error {
|
|
// Interactive exec requested.
|
|
var (
|
|
out, stderr io.Writer
|
|
in io.ReadCloser
|
|
)
|
|
|
|
if execConfig.AttachStdin {
|
|
in = dockerCli.In()
|
|
}
|
|
if execConfig.AttachStdout {
|
|
out = dockerCli.Out()
|
|
}
|
|
if execConfig.AttachStderr {
|
|
if execConfig.Tty {
|
|
stderr = dockerCli.Out()
|
|
} else {
|
|
stderr = dockerCli.Err()
|
|
}
|
|
}
|
|
fillConsoleSize(execConfig, dockerCli)
|
|
|
|
client := dockerCli.Client()
|
|
execStartCheck := types.ExecStartCheck{
|
|
Tty: execConfig.Tty,
|
|
ConsoleSize: execConfig.ConsoleSize,
|
|
}
|
|
resp, err := client.ContainerExecAttach(ctx, execID, execStartCheck)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer resp.Close()
|
|
|
|
errCh := make(chan error, 1)
|
|
|
|
go func() {
|
|
defer close(errCh)
|
|
errCh <- func() error {
|
|
streamer := hijackedIOStreamer{
|
|
streams: dockerCli,
|
|
inputStream: in,
|
|
outputStream: out,
|
|
errorStream: stderr,
|
|
resp: resp,
|
|
tty: execConfig.Tty,
|
|
detachKeys: execConfig.DetachKeys,
|
|
}
|
|
|
|
return streamer.stream(ctx)
|
|
}()
|
|
}()
|
|
|
|
if execConfig.Tty && dockerCli.In().IsTerminal() {
|
|
if err := MonitorTtySize(ctx, dockerCli, execID, true); err != nil {
|
|
fmt.Fprintln(dockerCli.Err(), "Error monitoring TTY size:", err)
|
|
}
|
|
}
|
|
|
|
if err := <-errCh; err != nil {
|
|
logrus.Debugf("Error hijack: %s", err)
|
|
return err
|
|
}
|
|
|
|
return getExecExitStatus(ctx, client, execID)
|
|
}
|
|
|
|
func getExecExitStatus(ctx context.Context, client apiclient.ContainerAPIClient, execID string) error {
|
|
resp, err := client.ContainerExecInspect(ctx, execID)
|
|
if err != nil {
|
|
// If we can't connect, then the daemon probably died.
|
|
if !apiclient.IsErrConnectionFailed(err) {
|
|
return err
|
|
}
|
|
return cli.StatusError{StatusCode: -1}
|
|
}
|
|
status := resp.ExitCode
|
|
if status != 0 {
|
|
return cli.StatusError{StatusCode: status}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// parseExec parses the specified args for the specified command and generates
|
|
// an ExecConfig from it.
|
|
func parseExec(execOpts ExecOptions, configFile *configfile.ConfigFile) (*types.ExecConfig, error) {
|
|
execConfig := &types.ExecConfig{
|
|
User: execOpts.User,
|
|
Privileged: execOpts.Privileged,
|
|
Tty: execOpts.TTY,
|
|
Cmd: execOpts.Command,
|
|
Detach: execOpts.Detach,
|
|
WorkingDir: execOpts.Workdir,
|
|
}
|
|
|
|
// collect all the environment variables for the container
|
|
var err error
|
|
if execConfig.Env, err = opts.ReadKVEnvStrings(execOpts.EnvFile.GetAll(), execOpts.Env.GetAll()); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// If -d is not set, attach to everything by default
|
|
if !execOpts.Detach {
|
|
execConfig.AttachStdout = true
|
|
execConfig.AttachStderr = true
|
|
if execOpts.Interactive {
|
|
execConfig.AttachStdin = true
|
|
}
|
|
}
|
|
|
|
if execOpts.DetachKeys != "" {
|
|
execConfig.DetachKeys = execOpts.DetachKeys
|
|
} else {
|
|
execConfig.DetachKeys = configFile.DetachKeys
|
|
}
|
|
return execConfig, nil
|
|
}
|