1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141 |
- package daemon
- import (
- "encoding/json"
- "errors"
- "fmt"
- "io"
- "io/ioutil"
- "os"
- "path/filepath"
- "sync"
- "syscall"
- "time"
- "github.com/opencontainers/runc/libcontainer/label"
- "github.com/Sirupsen/logrus"
- "github.com/docker/docker/context"
- "github.com/docker/docker/daemon/execdriver"
- "github.com/docker/docker/daemon/logger"
- "github.com/docker/docker/daemon/logger/jsonfilelog"
- "github.com/docker/docker/daemon/network"
- derr "github.com/docker/docker/errors"
- "github.com/docker/docker/image"
- "github.com/docker/docker/pkg/archive"
- "github.com/docker/docker/pkg/broadcastwriter"
- "github.com/docker/docker/pkg/fileutils"
- "github.com/docker/docker/pkg/ioutils"
- "github.com/docker/docker/pkg/mount"
- "github.com/docker/docker/pkg/nat"
- "github.com/docker/docker/pkg/promise"
- "github.com/docker/docker/pkg/signal"
- "github.com/docker/docker/pkg/symlink"
- "github.com/docker/docker/runconfig"
- "github.com/docker/docker/volume"
- )
- var (
- // ErrRootFSReadOnly is returned when a container
- // rootfs is marked readonly.
- ErrRootFSReadOnly = errors.New("container rootfs is marked read-only")
- )
- type streamConfig struct {
- stdout *broadcastwriter.BroadcastWriter
- stderr *broadcastwriter.BroadcastWriter
- stdin io.ReadCloser
- stdinPipe io.WriteCloser
- }
- // CommonContainer holds the fields for a container which are
- // applicable across all platforms supported by the daemon.
- type CommonContainer struct {
- streamConfig
- // embed for Container to support states directly.
- *State `json:"State"` // Needed for remote api version <= 1.11
- root string // Path to the "home" of the container, including metadata.
- basefs string // Path to the graphdriver mountpoint
- ID string
- Created time.Time
- Path string
- Args []string
- Config *runconfig.Config
- ImageID string `json:"Image"`
- NetworkSettings *network.Settings
- LogPath string
- Name string
- Driver string
- ExecDriver string
- // MountLabel contains the options for the 'mount' command
- MountLabel string
- ProcessLabel string
- RestartCount int
- HasBeenStartedBefore bool
- HasBeenManuallyStopped bool // used for unless-stopped restart policy
- hostConfig *runconfig.HostConfig
- command *execdriver.Command
- monitor *containerMonitor
- execCommands *execStore
- daemon *Daemon
- // logDriver for closing
- logDriver logger.Logger
- logCopier *logger.Copier
- }
- func (container *Container) fromDisk() error {
- pth, err := container.jsonPath()
- if err != nil {
- return err
- }
- jsonSource, err := os.Open(pth)
- if err != nil {
- return err
- }
- defer jsonSource.Close()
- dec := json.NewDecoder(jsonSource)
- // Load container settings
- if err := dec.Decode(container); err != nil {
- return err
- }
- if err := label.ReserveLabel(container.ProcessLabel); err != nil {
- return err
- }
- return container.readHostConfig()
- }
- func (container *Container) toDisk() error {
- data, err := json.Marshal(container)
- if err != nil {
- return err
- }
- pth, err := container.jsonPath()
- if err != nil {
- return err
- }
- if err := ioutil.WriteFile(pth, data, 0666); err != nil {
- return err
- }
- return container.writeHostConfig()
- }
- func (container *Container) toDiskLocking() error {
- container.Lock()
- err := container.toDisk()
- container.Unlock()
- return err
- }
- func (container *Container) readHostConfig() error {
- container.hostConfig = &runconfig.HostConfig{}
- // If the hostconfig file does not exist, do not read it.
- // (We still have to initialize container.hostConfig,
- // but that's OK, since we just did that above.)
- pth, err := container.hostConfigPath()
- if err != nil {
- return err
- }
- _, err = os.Stat(pth)
- if os.IsNotExist(err) {
- return nil
- }
- f, err := os.Open(pth)
- if err != nil {
- return err
- }
- defer f.Close()
- return json.NewDecoder(f).Decode(&container.hostConfig)
- }
- func (container *Container) writeHostConfig() error {
- data, err := json.Marshal(container.hostConfig)
- if err != nil {
- return err
- }
- pth, err := container.hostConfigPath()
- if err != nil {
- return err
- }
- return ioutil.WriteFile(pth, data, 0666)
- }
- func (container *Container) logEvent(ctx context.Context, action string) {
- d := container.daemon
- d.EventsService.Log(
- ctx,
- action,
- container.ID,
- container.Config.Image,
- )
- }
- // GetResourcePath evaluates `path` in the scope of the container's basefs, with proper path
- // sanitisation. Symlinks are all scoped to the basefs of the container, as
- // though the container's basefs was `/`.
- //
- // The basefs of a container is the host-facing path which is bind-mounted as
- // `/` inside the container. This method is essentially used to access a
- // particular path inside the container as though you were a process in that
- // container.
- //
- // NOTE: The returned path is *only* safely scoped inside the container's basefs
- // if no component of the returned path changes (such as a component
- // symlinking to a different path) between using this method and using the
- // path. See symlink.FollowSymlinkInScope for more details.
- func (container *Container) GetResourcePath(path string) (string, error) {
- // IMPORTANT - These are paths on the OS where the daemon is running, hence
- // any filepath operations must be done in an OS agnostic way.
- cleanPath := filepath.Join(string(os.PathSeparator), path)
- r, e := symlink.FollowSymlinkInScope(filepath.Join(container.basefs, cleanPath), container.basefs)
- return r, e
- }
- // Evaluates `path` in the scope of the container's root, with proper path
- // sanitisation. Symlinks are all scoped to the root of the container, as
- // though the container's root was `/`.
- //
- // The root of a container is the host-facing configuration metadata directory.
- // Only use this method to safely access the container's `container.json` or
- // other metadata files. If in doubt, use container.GetResourcePath.
- //
- // NOTE: The returned path is *only* safely scoped inside the container's root
- // if no component of the returned path changes (such as a component
- // symlinking to a different path) between using this method and using the
- // path. See symlink.FollowSymlinkInScope for more details.
- func (container *Container) getRootResourcePath(path string) (string, error) {
- // IMPORTANT - These are paths on the OS where the daemon is running, hence
- // any filepath operations must be done in an OS agnostic way.
- cleanPath := filepath.Join(string(os.PathSeparator), path)
- return symlink.FollowSymlinkInScope(filepath.Join(container.root, cleanPath), container.root)
- }
- func (container *Container) exportContainerRw() (archive.Archive, error) {
- if container.daemon == nil {
- return nil, derr.ErrorCodeUnregisteredContainer.WithArgs(container.ID)
- }
- archive, err := container.daemon.diff(container)
- if err != nil {
- return nil, err
- }
- return ioutils.NewReadCloserWrapper(archive, func() error {
- err := archive.Close()
- return err
- }),
- nil
- }
- // Start prepares the container to run by setting up everything the
- // container needs, such as storage and networking, as well as links
- // between containers. The container is left waiting for a signal to
- // begin running.
- func (container *Container) Start(ctx context.Context) (err error) {
- container.Lock()
- defer container.Unlock()
- if container.Running {
- return nil
- }
- if container.removalInProgress || container.Dead {
- return derr.ErrorCodeContainerBeingRemoved
- }
- // if we encounter an error during start we need to ensure that any other
- // setup has been cleaned up properly
- defer func() {
- if err != nil {
- container.setError(err)
- // if no one else has set it, make sure we don't leave it at zero
- if container.ExitCode == 0 {
- container.ExitCode = 128
- }
- container.toDisk()
- container.cleanup(ctx)
- container.logEvent(ctx, "die")
- }
- }()
- if err := container.Mount(ctx); err != nil {
- return err
- }
- // Make sure NetworkMode has an acceptable value. We do this to ensure
- // backwards API compatibility.
- container.hostConfig = runconfig.SetDefaultNetModeIfBlank(container.hostConfig)
- if err := container.initializeNetworking(ctx); err != nil {
- return err
- }
- linkedEnv, err := container.setupLinkedContainers(ctx)
- if err != nil {
- return err
- }
- if err := container.setupWorkingDirectory(); err != nil {
- return err
- }
- env := container.createDaemonEnvironment(linkedEnv)
- if err := populateCommand(ctx, container, env); err != nil {
- return err
- }
- if !container.hostConfig.IpcMode.IsContainer() && !container.hostConfig.IpcMode.IsHost() {
- if err := container.setupIpcDirs(); err != nil {
- return err
- }
- }
- mounts, err := container.setupMounts()
- if err != nil {
- return err
- }
- mounts = append(mounts, container.ipcMounts()...)
- container.command.Mounts = mounts
- return container.waitForStart(ctx)
- }
- // streamConfig.StdinPipe returns a WriteCloser which can be used to feed data
- // to the standard input of the container's active process.
- // Container.StdoutPipe and Container.StderrPipe each return a ReadCloser
- // which can be used to retrieve the standard output (and error) generated
- // by the container's active process. The output (and error) are actually
- // copied and delivered to all StdoutPipe and StderrPipe consumers, using
- // a kind of "broadcaster".
- func (streamConfig *streamConfig) StdinPipe() io.WriteCloser {
- return streamConfig.stdinPipe
- }
- func (streamConfig *streamConfig) StdoutPipe() io.ReadCloser {
- reader, writer := io.Pipe()
- streamConfig.stdout.AddWriter(writer)
- return ioutils.NewBufReader(reader)
- }
- func (streamConfig *streamConfig) StderrPipe() io.ReadCloser {
- reader, writer := io.Pipe()
- streamConfig.stderr.AddWriter(writer)
- return ioutils.NewBufReader(reader)
- }
- func (container *Container) isNetworkAllocated() bool {
- return container.NetworkSettings.IPAddress != ""
- }
- // cleanup releases any network resources allocated to the container along with any rules
- // around how containers are linked together. It also unmounts the container's root filesystem.
- func (container *Container) cleanup(ctx context.Context) {
- container.releaseNetwork()
- if err := container.unmountIpcMounts(); err != nil {
- logrus.Errorf("%s: Failed to umount ipc filesystems: %v", container.ID, err)
- }
- if err := container.Unmount(ctx); err != nil {
- logrus.Errorf("%s: Failed to umount filesystem: %v", container.ID, err)
- }
- for _, eConfig := range container.execCommands.s {
- container.daemon.unregisterExecCommand(eConfig)
- }
- container.unmountVolumes(false)
- }
- // killSig sends the container the given signal. This wrapper for the
- // host specific kill command prepares the container before attempting
- // to send the signal. An error is returned if the container is paused
- // or not running, or if there is a problem returned from the
- // underlying kill command.
- func (container *Container) killSig(ctx context.Context, sig int) error {
- logrus.Debugf("Sending %d to %s", sig, container.ID)
- container.Lock()
- defer container.Unlock()
- // We could unpause the container for them rather than returning this error
- if container.Paused {
- return derr.ErrorCodeUnpauseContainer.WithArgs(container.ID)
- }
- if !container.Running {
- return derr.ErrorCodeNotRunning.WithArgs(container.ID)
- }
- // signal to the monitor that it should not restart the container
- // after we send the kill signal
- container.monitor.ExitOnNext()
- // if the container is currently restarting we do not need to send the signal
- // to the process. Telling the monitor that it should exit on it's next event
- // loop is enough
- if container.Restarting {
- return nil
- }
- if err := container.daemon.kill(container, sig); err != nil {
- return err
- }
- container.logEvent(ctx, "kill")
- return nil
- }
- // Wrapper aroung killSig() suppressing "no such process" error.
- func (container *Container) killPossiblyDeadProcess(ctx context.Context, sig int) error {
- err := container.killSig(ctx, sig)
- if err == syscall.ESRCH {
- logrus.Debugf("Cannot kill process (pid=%d) with signal %d: no such process.", container.getPID(), sig)
- return nil
- }
- return err
- }
- func (container *Container) pause(ctx context.Context) error {
- container.Lock()
- defer container.Unlock()
- // We cannot Pause the container which is not running
- if !container.Running {
- return derr.ErrorCodeNotRunning.WithArgs(container.ID)
- }
- // We cannot Pause the container which is already paused
- if container.Paused {
- return derr.ErrorCodeAlreadyPaused.WithArgs(container.ID)
- }
- if err := container.daemon.execDriver.Pause(container.command); err != nil {
- return err
- }
- container.Paused = true
- container.logEvent(ctx, "pause")
- return nil
- }
- func (container *Container) unpause(ctx context.Context) error {
- container.Lock()
- defer container.Unlock()
- // We cannot unpause the container which is not running
- if !container.Running {
- return derr.ErrorCodeNotRunning.WithArgs(container.ID)
- }
- // We cannot unpause the container which is not paused
- if !container.Paused {
- return derr.ErrorCodeNotPaused.WithArgs(container.ID)
- }
- if err := container.daemon.execDriver.Unpause(container.command); err != nil {
- return err
- }
- container.Paused = false
- container.logEvent(ctx, "unpause")
- return nil
- }
- // Kill forcefully terminates a container.
- func (container *Container) Kill(ctx context.Context) error {
- if !container.IsRunning() {
- return derr.ErrorCodeNotRunning.WithArgs(container.ID)
- }
- // 1. Send SIGKILL
- if err := container.killPossiblyDeadProcess(ctx, int(syscall.SIGKILL)); err != nil {
- // While normally we might "return err" here we're not going to
- // because if we can't stop the container by this point then
- // its probably because its already stopped. Meaning, between
- // the time of the IsRunning() call above and now it stopped.
- // Also, since the err return will be exec driver specific we can't
- // look for any particular (common) error that would indicate
- // that the process is already dead vs something else going wrong.
- // So, instead we'll give it up to 2 more seconds to complete and if
- // by that time the container is still running, then the error
- // we got is probably valid and so we return it to the caller.
- if container.IsRunning() {
- container.WaitStop(2 * time.Second)
- if container.IsRunning() {
- return err
- }
- }
- }
- // 2. Wait for the process to die, in last resort, try to kill the process directly
- if err := killProcessDirectly(container); err != nil {
- return err
- }
- container.WaitStop(-1 * time.Second)
- return nil
- }
- // Stop halts a container by sending a stop signal, waiting for the given
- // duration in seconds, and then calling SIGKILL and waiting for the
- // process to exit. If a negative duration is given, Stop will wait
- // for the initial signal forever. If the container is not running Stop returns
- // immediately.
- func (container *Container) Stop(ctx context.Context, seconds int) error {
- if !container.IsRunning() {
- return nil
- }
- // 1. Send a SIGTERM
- if err := container.killPossiblyDeadProcess(ctx, container.stopSignal()); err != nil {
- logrus.Infof("Failed to send SIGTERM to the process, force killing")
- if err := container.killPossiblyDeadProcess(ctx, 9); err != nil {
- return err
- }
- }
- // 2. Wait for the process to exit on its own
- if _, err := container.WaitStop(time.Duration(seconds) * time.Second); err != nil {
- logrus.Infof("Container %v failed to exit within %d seconds of SIGTERM - using the force", container.ID, seconds)
- // 3. If it doesn't, then send SIGKILL
- if err := container.Kill(ctx); err != nil {
- container.WaitStop(-1 * time.Second)
- return err
- }
- }
- container.logEvent(ctx, "stop")
- return nil
- }
- // Restart attempts to gracefully stop and then start the
- // container. When stopping, wait for the given duration in seconds to
- // gracefully stop, before forcefully terminating the container. If
- // given a negative duration, wait forever for a graceful stop.
- func (container *Container) Restart(ctx context.Context, seconds int) error {
- // Avoid unnecessarily unmounting and then directly mounting
- // the container when the container stops and then starts
- // again
- if err := container.Mount(ctx); err == nil {
- defer container.Unmount(ctx)
- }
- if err := container.Stop(ctx, seconds); err != nil {
- return err
- }
- if err := container.Start(ctx); err != nil {
- return err
- }
- container.logEvent(ctx, "restart")
- return nil
- }
- // Resize changes the TTY of the process running inside the container
- // to the given height and width. The container must be running.
- func (container *Container) Resize(ctx context.Context, h, w int) error {
- if !container.IsRunning() {
- return derr.ErrorCodeNotRunning.WithArgs(container.ID)
- }
- if err := container.command.ProcessConfig.Terminal.Resize(h, w); err != nil {
- return err
- }
- container.logEvent(ctx, "resize")
- return nil
- }
- func (container *Container) export(ctx context.Context) (archive.Archive, error) {
- if err := container.Mount(ctx); err != nil {
- return nil, err
- }
- archive, err := archive.Tar(container.basefs, archive.Uncompressed)
- if err != nil {
- container.Unmount(ctx)
- return nil, err
- }
- arch := ioutils.NewReadCloserWrapper(archive, func() error {
- err := archive.Close()
- container.Unmount(ctx)
- return err
- })
- container.logEvent(ctx, "export")
- return arch, err
- }
- // Mount sets container.basefs
- func (container *Container) Mount(ctx context.Context) error {
- return container.daemon.Mount(ctx, container)
- }
- func (container *Container) changes() ([]archive.Change, error) {
- container.Lock()
- defer container.Unlock()
- return container.daemon.changes(container)
- }
- func (container *Container) getImage(ctx context.Context) (*image.Image, error) {
- if container.daemon == nil {
- return nil, derr.ErrorCodeImageUnregContainer
- }
- return container.daemon.graph.Get(container.ImageID)
- }
- // Unmount asks the daemon to release the layered filesystems that are
- // mounted by the container.
- func (container *Container) Unmount(ctx context.Context) error {
- return container.daemon.unmount(container)
- }
- func (container *Container) hostConfigPath() (string, error) {
- return container.getRootResourcePath("hostconfig.json")
- }
- func (container *Container) jsonPath() (string, error) {
- return container.getRootResourcePath("config.json")
- }
- // This method must be exported to be used from the lxc template
- // This directory is only usable when the container is running
- func (container *Container) rootfsPath() string {
- return container.basefs
- }
- func validateID(id string) error {
- if id == "" {
- return derr.ErrorCodeEmptyID
- }
- return nil
- }
- func (container *Container) copy(ctx context.Context, resource string) (rc io.ReadCloser, err error) {
- container.Lock()
- defer func() {
- if err != nil {
- // Wait to unlock the container until the archive is fully read
- // (see the ReadCloseWrapper func below) or if there is an error
- // before that occurs.
- container.Unlock()
- }
- }()
- if err := container.Mount(ctx); err != nil {
- return nil, err
- }
- defer func() {
- if err != nil {
- // unmount any volumes
- container.unmountVolumes(true)
- // unmount the container's rootfs
- container.Unmount(ctx)
- }
- }()
- if err := container.mountVolumes(); err != nil {
- return nil, err
- }
- basePath, err := container.GetResourcePath(resource)
- if err != nil {
- return nil, err
- }
- stat, err := os.Stat(basePath)
- if err != nil {
- return nil, err
- }
- var filter []string
- if !stat.IsDir() {
- d, f := filepath.Split(basePath)
- basePath = d
- filter = []string{f}
- } else {
- filter = []string{filepath.Base(basePath)}
- basePath = filepath.Dir(basePath)
- }
- archive, err := archive.TarWithOptions(basePath, &archive.TarOptions{
- Compression: archive.Uncompressed,
- IncludeFiles: filter,
- })
- if err != nil {
- return nil, err
- }
- reader := ioutils.NewReadCloserWrapper(archive, func() error {
- err := archive.Close()
- container.unmountVolumes(true)
- container.Unmount(ctx)
- container.Unlock()
- return err
- })
- container.logEvent(ctx, "copy")
- return reader, nil
- }
- // Returns true if the container exposes a certain port
- func (container *Container) exposes(p nat.Port) bool {
- _, exists := container.Config.ExposedPorts[p]
- return exists
- }
- func (container *Container) getLogConfig() runconfig.LogConfig {
- cfg := container.hostConfig.LogConfig
- if cfg.Type != "" || len(cfg.Config) > 0 { // container has log driver configured
- if cfg.Type == "" {
- cfg.Type = jsonfilelog.Name
- }
- return cfg
- }
- // Use daemon's default log config for containers
- return container.daemon.defaultLogConfig
- }
- func (container *Container) getLogger() (logger.Logger, error) {
- if container.logDriver != nil && container.IsRunning() {
- return container.logDriver, nil
- }
- cfg := container.getLogConfig()
- if err := logger.ValidateLogOpts(cfg.Type, cfg.Config); err != nil {
- return nil, err
- }
- c, err := logger.GetLogDriver(cfg.Type)
- if err != nil {
- return nil, derr.ErrorCodeLoggingFactory.WithArgs(err)
- }
- ctx := logger.Context{
- Config: cfg.Config,
- ContainerID: container.ID,
- ContainerName: container.Name,
- ContainerEntrypoint: container.Path,
- ContainerArgs: container.Args,
- ContainerImageID: container.ImageID,
- ContainerImageName: container.Config.Image,
- ContainerCreated: container.Created,
- }
- // Set logging file for "json-logger"
- if cfg.Type == jsonfilelog.Name {
- ctx.LogPath, err = container.getRootResourcePath(fmt.Sprintf("%s-json.log", container.ID))
- if err != nil {
- return nil, err
- }
- }
- return c(ctx)
- }
- func (container *Container) startLogging() error {
- cfg := container.getLogConfig()
- if cfg.Type == "none" {
- return nil // do not start logging routines
- }
- l, err := container.getLogger()
- if err != nil {
- return derr.ErrorCodeInitLogger.WithArgs(err)
- }
- copier := logger.NewCopier(container.ID, map[string]io.Reader{"stdout": container.StdoutPipe(), "stderr": container.StderrPipe()}, l)
- container.logCopier = copier
- copier.Run()
- container.logDriver = l
- // set LogPath field only for json-file logdriver
- if jl, ok := l.(*jsonfilelog.JSONFileLogger); ok {
- container.LogPath = jl.LogPath()
- }
- return nil
- }
- func (container *Container) waitForStart(ctx context.Context) error {
- container.monitor = newContainerMonitor(container, container.hostConfig.RestartPolicy)
- // block until we either receive an error from the initial start of the container's
- // process or until the process is running in the container
- select {
- case <-container.monitor.startSignal:
- case err := <-promise.Go(func() error { return container.monitor.Start(ctx) }):
- return err
- }
- return nil
- }
- func (container *Container) getProcessLabel() string {
- // even if we have a process label return "" if we are running
- // in privileged mode
- if container.hostConfig.Privileged {
- return ""
- }
- return container.ProcessLabel
- }
- func (container *Container) getMountLabel() string {
- if container.hostConfig.Privileged {
- return ""
- }
- return container.MountLabel
- }
- func (container *Container) stats() (*execdriver.ResourceStats, error) {
- return container.daemon.stats(container)
- }
- func (container *Container) getExecIDs() []string {
- return container.execCommands.List()
- }
- func (container *Container) exec(ctx context.Context, ExecConfig *ExecConfig) error {
- container.Lock()
- defer container.Unlock()
- callback := func(ctx context.Context, processConfig *execdriver.ProcessConfig, pid int, chOOM <-chan struct{}) error {
- if processConfig.Tty {
- // The callback is called after the process Start()
- // so we are in the parent process. In TTY mode, stdin/out/err is the PtySlave
- // which we close here.
- if c, ok := processConfig.Stdout.(io.Closer); ok {
- c.Close()
- }
- }
- close(ExecConfig.waitStart)
- return nil
- }
- // We use a callback here instead of a goroutine and an chan for
- // synchronization purposes
- cErr := promise.Go(func() error { return container.monitorExec(ctx, ExecConfig, callback) })
- // Exec should not return until the process is actually running
- select {
- case <-ExecConfig.waitStart:
- case err := <-cErr:
- return err
- }
- return nil
- }
- func (container *Container) monitorExec(ctx context.Context, ExecConfig *ExecConfig, callback execdriver.DriverCallback) error {
- var (
- err error
- exitCode int
- )
- pipes := execdriver.NewPipes(ExecConfig.streamConfig.stdin, ExecConfig.streamConfig.stdout, ExecConfig.streamConfig.stderr, ExecConfig.OpenStdin)
- exitCode, err = container.daemon.Exec(ctx, container, ExecConfig, pipes, callback)
- if err != nil {
- logrus.Errorf("Error running command in existing container %s: %s", container.ID, err)
- }
- logrus.Debugf("Exec task in container %s exited with code %d", container.ID, exitCode)
- if ExecConfig.OpenStdin {
- if err := ExecConfig.streamConfig.stdin.Close(); err != nil {
- logrus.Errorf("Error closing stdin while running in %s: %s", container.ID, err)
- }
- }
- if err := ExecConfig.streamConfig.stdout.Clean(); err != nil {
- logrus.Errorf("Error closing stdout while running in %s: %s", container.ID, err)
- }
- if err := ExecConfig.streamConfig.stderr.Clean(); err != nil {
- logrus.Errorf("Error closing stderr while running in %s: %s", container.ID, err)
- }
- if ExecConfig.ProcessConfig.Terminal != nil {
- if err := ExecConfig.ProcessConfig.Terminal.Close(); err != nil {
- logrus.Errorf("Error closing terminal while running in container %s: %s", container.ID, err)
- }
- }
- // remove the exec command from the container's store only and not the
- // daemon's store so that the exec command can be inspected.
- container.execCommands.Delete(ExecConfig.ID)
- return err
- }
- // Attach connects to the container's TTY, delegating to standard
- // streams or websockets depending on the configuration.
- func (container *Container) Attach(stdin io.ReadCloser, stdout io.Writer, stderr io.Writer) chan error {
- return attach(&container.streamConfig, container.Config.OpenStdin, container.Config.StdinOnce, container.Config.Tty, stdin, stdout, stderr)
- }
- func (container *Container) attachWithLogs(ctx context.Context, stdin io.ReadCloser, stdout, stderr io.Writer, logs, stream bool) error {
- if logs {
- logDriver, err := container.getLogger()
- if err != nil {
- return err
- }
- cLog, ok := logDriver.(logger.LogReader)
- if !ok {
- return logger.ErrReadLogsNotSupported
- }
- logs := cLog.ReadLogs(logger.ReadConfig{Tail: -1})
- LogLoop:
- for {
- select {
- case msg, ok := <-logs.Msg:
- if !ok {
- break LogLoop
- }
- if msg.Source == "stdout" && stdout != nil {
- stdout.Write(msg.Line)
- }
- if msg.Source == "stderr" && stderr != nil {
- stderr.Write(msg.Line)
- }
- case err := <-logs.Err:
- logrus.Errorf("Error streaming logs: %v", err)
- break LogLoop
- }
- }
- }
- container.logEvent(ctx, "attach")
- //stream
- if stream {
- var stdinPipe io.ReadCloser
- if stdin != nil {
- r, w := io.Pipe()
- go func() {
- defer w.Close()
- defer logrus.Debugf("Closing buffered stdin pipe")
- io.Copy(w, stdin)
- }()
- stdinPipe = r
- }
- <-container.Attach(stdinPipe, stdout, stderr)
- // If we are in stdinonce mode, wait for the process to end
- // otherwise, simply return
- if container.Config.StdinOnce && !container.Config.Tty {
- container.WaitStop(-1 * time.Second)
- }
- }
- return nil
- }
- func attach(streamConfig *streamConfig, openStdin, stdinOnce, tty bool, stdin io.ReadCloser, stdout io.Writer, stderr io.Writer) chan error {
- var (
- cStdout, cStderr io.ReadCloser
- cStdin io.WriteCloser
- wg sync.WaitGroup
- errors = make(chan error, 3)
- )
- if stdin != nil && openStdin {
- cStdin = streamConfig.StdinPipe()
- wg.Add(1)
- }
- if stdout != nil {
- cStdout = streamConfig.StdoutPipe()
- wg.Add(1)
- }
- if stderr != nil {
- cStderr = streamConfig.StderrPipe()
- wg.Add(1)
- }
- // Connect stdin of container to the http conn.
- go func() {
- if stdin == nil || !openStdin {
- return
- }
- logrus.Debugf("attach: stdin: begin")
- defer func() {
- if stdinOnce && !tty {
- cStdin.Close()
- } else {
- // No matter what, when stdin is closed (io.Copy unblock), close stdout and stderr
- if cStdout != nil {
- cStdout.Close()
- }
- if cStderr != nil {
- cStderr.Close()
- }
- }
- wg.Done()
- logrus.Debugf("attach: stdin: end")
- }()
- var err error
- if tty {
- _, err = copyEscapable(cStdin, stdin)
- } else {
- _, err = io.Copy(cStdin, stdin)
- }
- if err == io.ErrClosedPipe {
- err = nil
- }
- if err != nil {
- logrus.Errorf("attach: stdin: %s", err)
- errors <- err
- return
- }
- }()
- attachStream := func(name string, stream io.Writer, streamPipe io.ReadCloser) {
- if stream == nil {
- return
- }
- defer func() {
- // Make sure stdin gets closed
- if stdin != nil {
- stdin.Close()
- }
- streamPipe.Close()
- wg.Done()
- logrus.Debugf("attach: %s: end", name)
- }()
- logrus.Debugf("attach: %s: begin", name)
- _, err := io.Copy(stream, streamPipe)
- if err == io.ErrClosedPipe {
- err = nil
- }
- if err != nil {
- logrus.Errorf("attach: %s: %v", name, err)
- errors <- err
- }
- }
- go attachStream("stdout", stdout, cStdout)
- go attachStream("stderr", stderr, cStderr)
- return promise.Go(func() error {
- wg.Wait()
- close(errors)
- for err := range errors {
- if err != nil {
- return err
- }
- }
- return nil
- })
- }
- // Code c/c from io.Copy() modified to handle escape sequence
- func copyEscapable(dst io.Writer, src io.ReadCloser) (written int64, err error) {
- buf := make([]byte, 32*1024)
- for {
- nr, er := src.Read(buf)
- if nr > 0 {
- // ---- Docker addition
- // char 16 is C-p
- if nr == 1 && buf[0] == 16 {
- nr, er = src.Read(buf)
- // char 17 is C-q
- if nr == 1 && buf[0] == 17 {
- if err := src.Close(); err != nil {
- return 0, err
- }
- return 0, nil
- }
- }
- // ---- End of docker
- nw, ew := dst.Write(buf[0:nr])
- if nw > 0 {
- written += int64(nw)
- }
- if ew != nil {
- err = ew
- break
- }
- if nr != nw {
- err = io.ErrShortWrite
- break
- }
- }
- if er == io.EOF {
- break
- }
- if er != nil {
- err = er
- break
- }
- }
- return written, err
- }
- func (container *Container) shouldRestart() bool {
- return container.hostConfig.RestartPolicy.Name == "always" ||
- (container.hostConfig.RestartPolicy.Name == "unless-stopped" && !container.HasBeenManuallyStopped) ||
- (container.hostConfig.RestartPolicy.Name == "on-failure" && container.ExitCode != 0)
- }
- func (container *Container) mountVolumes() error {
- mounts, err := container.setupMounts()
- if err != nil {
- return err
- }
- for _, m := range mounts {
- dest, err := container.GetResourcePath(m.Destination)
- if err != nil {
- return err
- }
- var stat os.FileInfo
- stat, err = os.Stat(m.Source)
- if err != nil {
- return err
- }
- if err = fileutils.CreateIfNotExists(dest, stat.IsDir()); err != nil {
- return err
- }
- opts := "rbind,ro"
- if m.Writable {
- opts = "rbind,rw"
- }
- if err := mount.Mount(m.Source, dest, "bind", opts); err != nil {
- return err
- }
- }
- return nil
- }
- func (container *Container) copyImagePathContent(v volume.Volume, destination string) error {
- rootfs, err := symlink.FollowSymlinkInScope(filepath.Join(container.basefs, destination), container.basefs)
- if err != nil {
- return err
- }
- if _, err = ioutil.ReadDir(rootfs); err != nil {
- if os.IsNotExist(err) {
- return nil
- }
- return err
- }
- path, err := v.Mount()
- if err != nil {
- return err
- }
- if err := copyExistingContents(rootfs, path); err != nil {
- return err
- }
- return v.Unmount()
- }
- func (container *Container) stopSignal() int {
- var stopSignal syscall.Signal
- if container.Config.StopSignal != "" {
- stopSignal, _ = signal.ParseSignal(container.Config.StopSignal)
- }
- if int(stopSignal) == 0 {
- stopSignal, _ = signal.ParseSignal(signal.DefaultStopSignal)
- }
- return int(stopSignal)
- }
|