commit.go 5.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238
  1. package daemon
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "runtime"
  6. "strings"
  7. "time"
  8. "github.com/docker/docker/api/types/backend"
  9. "github.com/docker/docker/builder/dockerfile"
  10. "github.com/docker/docker/container"
  11. "github.com/docker/docker/dockerversion"
  12. "github.com/docker/docker/image"
  13. "github.com/docker/docker/layer"
  14. "github.com/docker/docker/pkg/archive"
  15. "github.com/docker/docker/pkg/ioutils"
  16. "github.com/docker/docker/reference"
  17. containertypes "github.com/docker/engine-api/types/container"
  18. "github.com/docker/go-connections/nat"
  19. )
  20. // merge merges two Config, the image container configuration (defaults values),
  21. // and the user container configuration, either passed by the API or generated
  22. // by the cli.
  23. // It will mutate the specified user configuration (userConf) with the image
  24. // configuration where the user configuration is incomplete.
  25. func merge(userConf, imageConf *containertypes.Config) error {
  26. if userConf.User == "" {
  27. userConf.User = imageConf.User
  28. }
  29. if len(userConf.ExposedPorts) == 0 {
  30. userConf.ExposedPorts = imageConf.ExposedPorts
  31. } else if imageConf.ExposedPorts != nil {
  32. if userConf.ExposedPorts == nil {
  33. userConf.ExposedPorts = make(nat.PortSet)
  34. }
  35. for port := range imageConf.ExposedPorts {
  36. if _, exists := userConf.ExposedPorts[port]; !exists {
  37. userConf.ExposedPorts[port] = struct{}{}
  38. }
  39. }
  40. }
  41. if len(userConf.Env) == 0 {
  42. userConf.Env = imageConf.Env
  43. } else {
  44. for _, imageEnv := range imageConf.Env {
  45. found := false
  46. imageEnvKey := strings.Split(imageEnv, "=")[0]
  47. for _, userEnv := range userConf.Env {
  48. userEnvKey := strings.Split(userEnv, "=")[0]
  49. if imageEnvKey == userEnvKey {
  50. found = true
  51. break
  52. }
  53. }
  54. if !found {
  55. userConf.Env = append(userConf.Env, imageEnv)
  56. }
  57. }
  58. }
  59. if userConf.Labels == nil {
  60. userConf.Labels = map[string]string{}
  61. }
  62. if imageConf.Labels != nil {
  63. for l := range userConf.Labels {
  64. imageConf.Labels[l] = userConf.Labels[l]
  65. }
  66. userConf.Labels = imageConf.Labels
  67. }
  68. if len(userConf.Entrypoint) == 0 {
  69. if len(userConf.Cmd) == 0 {
  70. userConf.Cmd = imageConf.Cmd
  71. }
  72. if userConf.Entrypoint == nil {
  73. userConf.Entrypoint = imageConf.Entrypoint
  74. }
  75. }
  76. if userConf.WorkingDir == "" {
  77. userConf.WorkingDir = imageConf.WorkingDir
  78. }
  79. if len(userConf.Volumes) == 0 {
  80. userConf.Volumes = imageConf.Volumes
  81. } else {
  82. for k, v := range imageConf.Volumes {
  83. userConf.Volumes[k] = v
  84. }
  85. }
  86. if userConf.StopSignal == "" {
  87. userConf.StopSignal = imageConf.StopSignal
  88. }
  89. return nil
  90. }
  91. // Commit creates a new filesystem image from the current state of a container.
  92. // The image can optionally be tagged into a repository.
  93. func (daemon *Daemon) Commit(name string, c *backend.ContainerCommitConfig) (string, error) {
  94. container, err := daemon.GetContainer(name)
  95. if err != nil {
  96. return "", err
  97. }
  98. // It is not possible to commit a running container on Windows
  99. if runtime.GOOS == "windows" && container.IsRunning() {
  100. return "", fmt.Errorf("Windows does not support commit of a running container")
  101. }
  102. if c.Pause && !container.IsPaused() {
  103. daemon.containerPause(container)
  104. defer daemon.containerUnpause(container)
  105. }
  106. newConfig, err := dockerfile.BuildFromConfig(c.Config, c.Changes)
  107. if err != nil {
  108. return "", err
  109. }
  110. if c.MergeConfigs {
  111. if err := merge(newConfig, container.Config); err != nil {
  112. return "", err
  113. }
  114. }
  115. rwTar, err := daemon.exportContainerRw(container)
  116. if err != nil {
  117. return "", err
  118. }
  119. defer func() {
  120. if rwTar != nil {
  121. rwTar.Close()
  122. }
  123. }()
  124. var history []image.History
  125. rootFS := image.NewRootFS()
  126. if container.ImageID != "" {
  127. img, err := daemon.imageStore.Get(container.ImageID)
  128. if err != nil {
  129. return "", err
  130. }
  131. history = img.History
  132. rootFS = img.RootFS
  133. }
  134. l, err := daemon.layerStore.Register(rwTar, rootFS.ChainID())
  135. if err != nil {
  136. return "", err
  137. }
  138. defer layer.ReleaseAndLog(daemon.layerStore, l)
  139. h := image.History{
  140. Author: c.Author,
  141. Created: time.Now().UTC(),
  142. CreatedBy: strings.Join(container.Config.Cmd, " "),
  143. Comment: c.Comment,
  144. EmptyLayer: true,
  145. }
  146. if diffID := l.DiffID(); layer.DigestSHA256EmptyTar != diffID {
  147. h.EmptyLayer = false
  148. rootFS.Append(diffID)
  149. }
  150. history = append(history, h)
  151. config, err := json.Marshal(&image.Image{
  152. V1Image: image.V1Image{
  153. DockerVersion: dockerversion.Version,
  154. Config: newConfig,
  155. Architecture: runtime.GOARCH,
  156. OS: runtime.GOOS,
  157. Container: container.ID,
  158. ContainerConfig: *container.Config,
  159. Author: c.Author,
  160. Created: h.Created,
  161. },
  162. RootFS: rootFS,
  163. History: history,
  164. })
  165. if err != nil {
  166. return "", err
  167. }
  168. id, err := daemon.imageStore.Create(config)
  169. if err != nil {
  170. return "", err
  171. }
  172. if container.ImageID != "" {
  173. if err := daemon.imageStore.SetParent(id, container.ImageID); err != nil {
  174. return "", err
  175. }
  176. }
  177. if c.Repo != "" {
  178. newTag, err := reference.WithName(c.Repo) // todo: should move this to API layer
  179. if err != nil {
  180. return "", err
  181. }
  182. if c.Tag != "" {
  183. if newTag, err = reference.WithTag(newTag, c.Tag); err != nil {
  184. return "", err
  185. }
  186. }
  187. if err := daemon.TagImage(newTag, id.String()); err != nil {
  188. return "", err
  189. }
  190. }
  191. attributes := map[string]string{
  192. "comment": c.Comment,
  193. }
  194. daemon.LogContainerEventWithAttributes(container, "commit", attributes)
  195. return id.String(), nil
  196. }
  197. func (daemon *Daemon) exportContainerRw(container *container.Container) (archive.Archive, error) {
  198. if err := daemon.Mount(container); err != nil {
  199. return nil, err
  200. }
  201. archive, err := container.RWLayer.TarStream()
  202. if err != nil {
  203. return nil, err
  204. }
  205. return ioutils.NewReadCloserWrapper(archive, func() error {
  206. archive.Close()
  207. return container.RWLayer.Unmount()
  208. }),
  209. nil
  210. }