fdad41f5 |
package daemon
import ( |
4352da78 |
"encoding/json" |
38e34cf6 |
"fmt" |
aa2cc187 |
"io" |
38e34cf6 |
"runtime" |
4352da78 |
"strings"
"time" |
38e34cf6 |
|
93e02efa |
"github.com/docker/docker/api/types/backend" |
91e197d6 |
containertypes "github.com/docker/docker/api/types/container" |
93e02efa |
"github.com/docker/docker/builder/dockerfile" |
6bb0d181 |
"github.com/docker/docker/container" |
4352da78 |
"github.com/docker/docker/dockerversion" |
9001ea26 |
"github.com/docker/docker/image" |
4352da78 |
"github.com/docker/docker/layer" |
581380cc |
"github.com/docker/docker/pkg/ioutils" |
2655954c |
"github.com/docker/docker/reference" |
fdad41f5 |
)
|
eb4ae8e2 |
// merge merges two Config, the image container configuration (defaults values),
// and the user container configuration, either passed by the API or generated
// by the cli.
// It will mutate the specified user configuration (userConf) with the image
// configuration where the user configuration is incomplete.
func merge(userConf, imageConf *containertypes.Config) error {
if userConf.User == "" {
userConf.User = imageConf.User
}
if len(userConf.ExposedPorts) == 0 {
userConf.ExposedPorts = imageConf.ExposedPorts
} else if imageConf.ExposedPorts != nil {
for port := range imageConf.ExposedPorts {
if _, exists := userConf.ExposedPorts[port]; !exists {
userConf.ExposedPorts[port] = struct{}{}
}
}
}
if len(userConf.Env) == 0 {
userConf.Env = imageConf.Env
} else {
for _, imageEnv := range imageConf.Env {
found := false
imageEnvKey := strings.Split(imageEnv, "=")[0]
for _, userEnv := range userConf.Env {
userEnvKey := strings.Split(userEnv, "=")[0] |
68cfaf21 |
if runtime.GOOS == "windows" {
// Case insensitive environment variables on Windows
imageEnvKey = strings.ToUpper(imageEnvKey)
userEnvKey = strings.ToUpper(userEnvKey)
} |
eb4ae8e2 |
if imageEnvKey == userEnvKey {
found = true
break
}
}
if !found {
userConf.Env = append(userConf.Env, imageEnv)
}
}
}
if userConf.Labels == nil {
userConf.Labels = map[string]string{}
}
if imageConf.Labels != nil {
for l := range userConf.Labels {
imageConf.Labels[l] = userConf.Labels[l]
}
userConf.Labels = imageConf.Labels
}
|
53b0d626 |
if len(userConf.Entrypoint) == 0 {
if len(userConf.Cmd) == 0 { |
eb4ae8e2 |
userConf.Cmd = imageConf.Cmd |
d05d0211 |
userConf.ArgsEscaped = imageConf.ArgsEscaped |
eb4ae8e2 |
}
if userConf.Entrypoint == nil {
userConf.Entrypoint = imageConf.Entrypoint
}
} |
b6c7becb |
if imageConf.Healthcheck != nil {
if userConf.Healthcheck == nil {
userConf.Healthcheck = imageConf.Healthcheck
} else {
if len(userConf.Healthcheck.Test) == 0 {
userConf.Healthcheck.Test = imageConf.Healthcheck.Test
}
if userConf.Healthcheck.Interval == 0 {
userConf.Healthcheck.Interval = imageConf.Healthcheck.Interval
}
if userConf.Healthcheck.Timeout == 0 {
userConf.Healthcheck.Timeout = imageConf.Healthcheck.Timeout
}
if userConf.Healthcheck.Retries == 0 {
userConf.Healthcheck.Retries = imageConf.Healthcheck.Retries
}
}
}
|
eb4ae8e2 |
if userConf.WorkingDir == "" {
userConf.WorkingDir = imageConf.WorkingDir
}
if len(userConf.Volumes) == 0 {
userConf.Volumes = imageConf.Volumes
} else {
for k, v := range imageConf.Volumes {
userConf.Volumes[k] = v
}
} |
a252516e |
if userConf.StopSignal == "" {
userConf.StopSignal = imageConf.StopSignal
} |
eb4ae8e2 |
return nil
}
|
fdad41f5 |
// Commit creates a new filesystem image from the current state of a container. |
abd72d40 |
// The image can optionally be tagged into a repository. |
93e02efa |
func (daemon *Daemon) Commit(name string, c *backend.ContainerCommitConfig) (string, error) { |
3343d234 |
start := time.Now() |
d7d512bb |
container, err := daemon.GetContainer(name) |
38e34cf6 |
if err != nil { |
4352da78 |
return "", err |
38e34cf6 |
}
|
934328d8 |
// It is not possible to commit a running container on Windows and on Solaris.
if (runtime.GOOS == "windows" || runtime.GOOS == "solaris") && container.IsRunning() {
return "", fmt.Errorf("%+v does not support commit of a running container", runtime.GOOS) |
38e34cf6 |
}
|
6bb0d181 |
if c.Pause && !container.IsPaused() { |
9f79cfdb |
daemon.containerPause(container)
defer daemon.containerUnpause(container) |
fdad41f5 |
}
|
93e02efa |
newConfig, err := dockerfile.BuildFromConfig(c.Config, c.Changes)
if err != nil {
return "", err
}
|
38e34cf6 |
if c.MergeConfigs { |
93e02efa |
if err := merge(newConfig, container.Config); err != nil { |
4352da78 |
return "", err |
38e34cf6 |
}
}
|
581380cc |
rwTar, err := daemon.exportContainerRw(container) |
fdad41f5 |
if err != nil { |
4352da78 |
return "", err |
fdad41f5 |
} |
f9c7772b |
defer func() {
if rwTar != nil {
rwTar.Close()
}
}() |
fdad41f5 |
|
4352da78 |
var history []image.History
rootFS := image.NewRootFS() |
194eaa5c |
osVersion := ""
var osFeatures []string |
4352da78 |
if container.ImageID != "" {
img, err := daemon.imageStore.Get(container.ImageID)
if err != nil {
return "", err
}
history = img.History
rootFS = img.RootFS |
194eaa5c |
osVersion = img.OSVersion
osFeatures = img.OSFeatures |
4352da78 |
}
l, err := daemon.layerStore.Register(rwTar, rootFS.ChainID()) |
fdad41f5 |
if err != nil { |
4352da78 |
return "", err
}
defer layer.ReleaseAndLog(daemon.layerStore, l)
h := image.History{
Author: c.Author,
Created: time.Now().UTC(), |
53b0d626 |
CreatedBy: strings.Join(container.Config.Cmd, " "), |
4352da78 |
Comment: c.Comment,
EmptyLayer: true,
}
if diffID := l.DiffID(); layer.DigestSHA256EmptyTar != diffID {
h.EmptyLayer = false
rootFS.Append(diffID)
}
history = append(history, h)
config, err := json.Marshal(&image.Image{
V1Image: image.V1Image{
DockerVersion: dockerversion.Version, |
93e02efa |
Config: newConfig, |
4352da78 |
Architecture: runtime.GOARCH,
OS: runtime.GOOS,
Container: container.ID,
ContainerConfig: *container.Config,
Author: c.Author,
Created: h.Created,
}, |
194eaa5c |
RootFS: rootFS,
History: history,
OSFeatures: osFeatures,
OSVersion: osVersion, |
4352da78 |
})
if err != nil {
return "", err
}
id, err := daemon.imageStore.Create(config)
if err != nil {
return "", err
}
if container.ImageID != "" {
if err := daemon.imageStore.SetParent(id, container.ImageID); err != nil {
return "", err
} |
fdad41f5 |
}
|
e60ae538 |
imageRef := "" |
7046651b |
if c.Repo != "" { |
4352da78 |
newTag, err := reference.WithName(c.Repo) // todo: should move this to API layer
if err != nil {
return "", err
}
if c.Tag != "" {
if newTag, err = reference.WithTag(newTag, c.Tag); err != nil {
return "", err
}
} |
47afe6bd |
if err := daemon.TagImageWithReference(id, newTag); err != nil { |
4352da78 |
return "", err |
fdad41f5 |
} |
e60ae538 |
imageRef = newTag.String() |
fdad41f5 |
} |
ca5ede2d |
|
1d8ccc6a |
attributes := map[string]string{ |
e3c24caf |
"comment": c.Comment,
"imageID": id.String(), |
e60ae538 |
"imageRef": imageRef, |
1d8ccc6a |
}
daemon.LogContainerEventWithAttributes(container, "commit", attributes) |
3343d234 |
containerActions.WithValues("commit").UpdateSince(start) |
4352da78 |
return id.String(), nil |
fdad41f5 |
} |
581380cc |
|
aa2cc187 |
func (daemon *Daemon) exportContainerRw(container *container.Container) (io.ReadCloser, error) { |
4352da78 |
if err := daemon.Mount(container); err != nil {
return nil, err
}
|
6bb0d181 |
archive, err := container.RWLayer.TarStream() |
581380cc |
if err != nil { |
65d79e3e |
daemon.Unmount(container) // logging is already handled in the `Unmount` function |
581380cc |
return nil, err
}
return ioutils.NewReadCloserWrapper(archive, func() error { |
21278efa |
archive.Close() |
d04fa49a |
return container.RWLayer.Unmount() |
581380cc |
}),
nil
} |