123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213 |
- // +build windows
- package container
- import (
- "fmt"
- "os"
- "path/filepath"
- containertypes "github.com/docker/docker/api/types/container"
- "github.com/docker/docker/pkg/system"
- )
- const (
- containerSecretMountPath = `C:\ProgramData\Docker\secrets`
- containerInternalSecretMountPath = `C:\ProgramData\Docker\internal\secrets`
- containerInternalConfigsDirPath = `C:\ProgramData\Docker\internal\configs`
- )
- // Container holds fields specific to the Windows implementation. See
- // CommonContainer for standard fields common to all containers.
- type Container struct {
- CommonContainer
- // Fields below here are platform specific.
- NetworkSharedContainerID string
- }
- // ExitStatus provides exit reasons for a container.
- type ExitStatus struct {
- // The exit code with which the container exited.
- ExitCode int
- }
- // CreateDaemonEnvironment creates a new environment variable slice for this container.
- func (container *Container) CreateDaemonEnvironment(_ bool, linkedEnv []string) []string {
- // because the env on the container can override certain default values
- // we need to replace the 'env' keys where they match and append anything
- // else.
- return ReplaceOrAppendEnvValues(linkedEnv, container.Config.Env)
- }
- // UnmountIpcMounts unmounts Ipc related mounts.
- // This is a NOOP on windows.
- func (container *Container) UnmountIpcMounts(unmount func(pth string) error) {
- }
- // IpcMounts returns the list of Ipc related mounts.
- func (container *Container) IpcMounts() []Mount {
- return nil
- }
- // CreateSecretSymlinks creates symlinks to files in the secret mount.
- func (container *Container) CreateSecretSymlinks() error {
- for _, r := range container.SecretReferences {
- if r.File == nil {
- continue
- }
- resolvedPath, _, err := container.ResolvePath(getSecretTargetPath(r))
- if err != nil {
- return err
- }
- if err := system.MkdirAll(filepath.Dir(resolvedPath), 0); err != nil {
- return err
- }
- if err := os.Symlink(filepath.Join(containerInternalSecretMountPath, r.SecretID), resolvedPath); err != nil {
- return err
- }
- }
- return nil
- }
- // SecretMounts returns the mount for the secret path.
- // All secrets are stored in a single mount on Windows. Target symlinks are
- // created for each secret, pointing to the files in this mount.
- func (container *Container) SecretMounts() []Mount {
- var mounts []Mount
- if len(container.SecretReferences) > 0 {
- mounts = append(mounts, Mount{
- Source: container.SecretMountPath(),
- Destination: containerInternalSecretMountPath,
- Writable: false,
- })
- }
- return mounts
- }
- // UnmountSecrets unmounts the fs for secrets
- func (container *Container) UnmountSecrets() error {
- return os.RemoveAll(container.SecretMountPath())
- }
- // CreateConfigSymlinks creates symlinks to files in the config mount.
- func (container *Container) CreateConfigSymlinks() error {
- for _, configRef := range container.ConfigReferences {
- if configRef.File == nil {
- continue
- }
- resolvedPath, _, err := container.ResolvePath(configRef.File.Name)
- if err != nil {
- return err
- }
- if err := system.MkdirAll(filepath.Dir(resolvedPath), 0); err != nil {
- return err
- }
- if err := os.Symlink(filepath.Join(containerInternalConfigsDirPath, configRef.ConfigID), resolvedPath); err != nil {
- return err
- }
- }
- return nil
- }
- // ConfigMounts returns the mount for configs.
- // All configs are stored in a single mount on Windows. Target symlinks are
- // created for each config, pointing to the files in this mount.
- func (container *Container) ConfigMounts() []Mount {
- var mounts []Mount
- if len(container.ConfigReferences) > 0 {
- mounts = append(mounts, Mount{
- Source: container.ConfigsDirPath(),
- Destination: containerInternalConfigsDirPath,
- Writable: false,
- })
- }
- return mounts
- }
- // DetachAndUnmount unmounts all volumes.
- // On Windows it only delegates to `UnmountVolumes` since there is nothing to
- // force unmount.
- func (container *Container) DetachAndUnmount(volumeEventLog func(name, action string, attributes map[string]string)) error {
- return container.UnmountVolumes(volumeEventLog)
- }
- // TmpfsMounts returns the list of tmpfs mounts
- func (container *Container) TmpfsMounts() ([]Mount, error) {
- var mounts []Mount
- return mounts, nil
- }
- // UpdateContainer updates configuration of a container
- func (container *Container) UpdateContainer(hostConfig *containertypes.HostConfig) error {
- container.Lock()
- defer container.Unlock()
- resources := hostConfig.Resources
- if resources.CPUShares != 0 ||
- resources.Memory != 0 ||
- resources.NanoCPUs != 0 ||
- resources.CgroupParent != "" ||
- resources.BlkioWeight != 0 ||
- len(resources.BlkioWeightDevice) != 0 ||
- len(resources.BlkioDeviceReadBps) != 0 ||
- len(resources.BlkioDeviceWriteBps) != 0 ||
- len(resources.BlkioDeviceReadIOps) != 0 ||
- len(resources.BlkioDeviceWriteIOps) != 0 ||
- resources.CPUPeriod != 0 ||
- resources.CPUQuota != 0 ||
- resources.CPURealtimePeriod != 0 ||
- resources.CPURealtimeRuntime != 0 ||
- resources.CpusetCpus != "" ||
- resources.CpusetMems != "" ||
- len(resources.Devices) != 0 ||
- len(resources.DeviceCgroupRules) != 0 ||
- resources.DiskQuota != 0 ||
- resources.KernelMemory != 0 ||
- resources.MemoryReservation != 0 ||
- resources.MemorySwap != 0 ||
- resources.MemorySwappiness != nil ||
- resources.OomKillDisable != nil ||
- resources.PidsLimit != 0 ||
- len(resources.Ulimits) != 0 ||
- resources.CPUCount != 0 ||
- resources.CPUPercent != 0 ||
- resources.IOMaximumIOps != 0 ||
- resources.IOMaximumBandwidth != 0 {
- return fmt.Errorf("resource updating isn't supported on Windows")
- }
- // update HostConfig of container
- if hostConfig.RestartPolicy.Name != "" {
- if container.HostConfig.AutoRemove && !hostConfig.RestartPolicy.IsNone() {
- return fmt.Errorf("Restart policy cannot be updated because AutoRemove is enabled for the container")
- }
- container.HostConfig.RestartPolicy = hostConfig.RestartPolicy
- }
- return nil
- }
- // cleanResourcePath cleans a resource path by removing C:\ syntax, and prepares
- // to combine with a volume path
- func cleanResourcePath(path string) string {
- if len(path) >= 2 {
- c := path[0]
- if path[1] == ':' && ('a' <= c && c <= 'z' || 'A' <= c && c <= 'Z') {
- path = path[2:]
- }
- }
- return filepath.Join(string(os.PathSeparator), path)
- }
- // BuildHostnameFile writes the container's hostname file.
- func (container *Container) BuildHostnameFile() error {
- return nil
- }
- // EnableServiceDiscoveryOnDefaultNetwork Enable service discovery on default network
- func (container *Container) EnableServiceDiscoveryOnDefaultNetwork() bool {
- return true
- }
|