2013-01-18 19:13:39 -05:00
|
|
|
package docker
|
|
|
|
|
|
|
|
import (
|
|
|
|
"encoding/json"
|
2013-08-15 14:38:17 -04:00
|
|
|
"errors"
|
2013-03-21 03:25:00 -04:00
|
|
|
"fmt"
|
2013-10-31 19:57:45 -04:00
|
|
|
"github.com/dotcloud/docker/archive"
|
2014-01-16 17:00:18 -05:00
|
|
|
"github.com/dotcloud/docker/engine"
|
2014-01-09 19:03:22 -05:00
|
|
|
"github.com/dotcloud/docker/execdriver"
|
2013-11-19 04:36:54 -05:00
|
|
|
"github.com/dotcloud/docker/graphdriver"
|
2014-01-23 04:31:38 -05:00
|
|
|
"github.com/dotcloud/docker/networkdriver/ipallocator"
|
2014-01-20 13:52:26 -05:00
|
|
|
"github.com/dotcloud/docker/pkg/mount"
|
2013-12-23 18:42:37 -05:00
|
|
|
"github.com/dotcloud/docker/pkg/term"
|
2013-05-14 18:37:35 -04:00
|
|
|
"github.com/dotcloud/docker/utils"
|
2013-01-29 16:50:27 -05:00
|
|
|
"github.com/kr/pty"
|
2013-01-18 19:13:39 -05:00
|
|
|
"io"
|
|
|
|
"io/ioutil"
|
2013-01-21 21:03:23 -05:00
|
|
|
"log"
|
2013-08-29 18:21:32 -04:00
|
|
|
"net"
|
2013-01-18 19:13:39 -05:00
|
|
|
"os"
|
|
|
|
"path"
|
2014-01-11 05:31:01 -05:00
|
|
|
"path/filepath"
|
2013-04-19 22:29:13 -04:00
|
|
|
"strings"
|
2013-11-21 15:21:03 -05:00
|
|
|
"sync"
|
2013-01-18 19:13:39 -05:00
|
|
|
"syscall"
|
2013-01-21 21:03:23 -05:00
|
|
|
"time"
|
2013-01-18 19:13:39 -05:00
|
|
|
)
|
|
|
|
|
2013-11-29 10:40:44 -05:00
|
|
|
var (
|
|
|
|
ErrNotATTY = errors.New("The PTY is not a file")
|
|
|
|
ErrNoTTY = errors.New("No PTY found")
|
|
|
|
)
|
|
|
|
|
2013-01-18 19:13:39 -05:00
|
|
|
type Container struct {
|
2013-11-21 15:21:03 -05:00
|
|
|
sync.Mutex
|
2013-11-07 18:58:03 -05:00
|
|
|
root string // Path to the "home" of the container, including metadata.
|
|
|
|
rootfs string // Path to the root filesystem of the container.
|
2013-03-21 03:25:00 -04:00
|
|
|
|
2013-06-04 14:00:22 -04:00
|
|
|
ID string
|
2013-01-22 14:13:22 -05:00
|
|
|
|
|
|
|
Created time.Time
|
|
|
|
|
2013-01-18 19:13:39 -05:00
|
|
|
Path string
|
|
|
|
Args []string
|
|
|
|
|
2013-03-21 03:25:00 -04:00
|
|
|
Config *Config
|
|
|
|
State State
|
|
|
|
Image string
|
2013-01-18 19:13:39 -05:00
|
|
|
|
2013-02-28 14:51:14 -05:00
|
|
|
network *NetworkInterface
|
|
|
|
NetworkSettings *NetworkSettings
|
2013-01-18 19:13:39 -05:00
|
|
|
|
2013-04-10 21:23:34 -04:00
|
|
|
ResolvConfPath string
|
2013-09-09 14:57:25 -04:00
|
|
|
HostnamePath string
|
|
|
|
HostsPath string
|
2013-10-28 19:58:59 -04:00
|
|
|
Name string
|
2013-11-15 01:52:08 -05:00
|
|
|
Driver string
|
2013-04-10 21:23:34 -04:00
|
|
|
|
2014-01-20 19:05:07 -05:00
|
|
|
command *execdriver.Command
|
2013-05-14 18:37:35 -04:00
|
|
|
stdout *utils.WriteBroadcaster
|
|
|
|
stderr *utils.WriteBroadcaster
|
2013-04-10 21:23:34 -04:00
|
|
|
stdin io.ReadCloser
|
|
|
|
stdinPipe io.WriteCloser
|
2013-04-04 15:12:22 -04:00
|
|
|
ptyMaster io.Closer
|
2013-03-30 12:05:53 -04:00
|
|
|
|
2013-03-29 11:41:48 -04:00
|
|
|
runtime *Runtime
|
2013-04-09 10:57:59 -04:00
|
|
|
|
|
|
|
waitLock chan struct{}
|
2013-04-10 19:10:53 -04:00
|
|
|
Volumes map[string]string
|
2013-07-26 04:10:42 -04:00
|
|
|
// Store rw/ro in a separate structure to preserve reverse-compatibility on-disk.
|
2013-06-25 02:30:48 -04:00
|
|
|
// Easier than migrating older container configs :)
|
2013-10-31 17:58:43 -04:00
|
|
|
VolumesRW map[string]bool
|
|
|
|
hostConfig *HostConfig
|
2013-10-04 22:25:15 -04:00
|
|
|
|
|
|
|
activeLinks map[string]*Link
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
|
|
|
|
2013-10-31 17:58:43 -04:00
|
|
|
// Note: the Config structure should hold only portable information about the container.
|
|
|
|
// Here, "portable" means "independent from the host we are running on".
|
|
|
|
// Non-portable information *should* appear in HostConfig.
|
2013-01-18 19:13:39 -05:00
|
|
|
type Config struct {
|
2013-07-22 22:00:35 -04:00
|
|
|
Hostname string
|
2013-08-29 18:21:32 -04:00
|
|
|
Domainname string
|
2013-07-22 22:00:35 -04:00
|
|
|
User string
|
|
|
|
Memory int64 // Memory limit (in bytes)
|
|
|
|
MemorySwap int64 // Total memory usage (memory + swap); set `-1' to disable swap
|
|
|
|
CpuShares int64 // CPU shares (relative weight vs. other containers)
|
|
|
|
AttachStdin bool
|
|
|
|
AttachStdout bool
|
|
|
|
AttachStderr bool
|
2013-10-04 22:25:15 -04:00
|
|
|
PortSpecs []string // Deprecated - Can be in the format of 8080/tcp
|
|
|
|
ExposedPorts map[Port]struct{}
|
2013-07-22 22:00:35 -04:00
|
|
|
Tty bool // Attach standard streams to a tty, including stdin if it is not closed.
|
|
|
|
OpenStdin bool // Open stdin
|
|
|
|
StdinOnce bool // If true, close stdin after the 1 attached client disconnects.
|
|
|
|
Env []string
|
|
|
|
Cmd []string
|
|
|
|
Dns []string
|
|
|
|
Image string // Name of the image as it was passed by the operator (eg. could be symbolic)
|
|
|
|
Volumes map[string]struct{}
|
|
|
|
VolumesFrom string
|
2013-08-15 14:38:17 -04:00
|
|
|
WorkingDir string
|
2013-07-22 22:00:35 -04:00
|
|
|
Entrypoint []string
|
|
|
|
NetworkDisabled bool
|
2013-03-23 15:16:58 -04:00
|
|
|
}
|
|
|
|
|
2013-05-13 19:39:54 -04:00
|
|
|
type HostConfig struct {
|
2013-07-08 04:01:16 -04:00
|
|
|
Binds []string
|
|
|
|
ContainerIDFile string
|
2013-08-15 19:35:03 -04:00
|
|
|
LxcConf []KeyValuePair
|
2013-10-31 17:58:43 -04:00
|
|
|
Privileged bool
|
2013-10-04 22:25:15 -04:00
|
|
|
PortBindings map[Port][]PortBinding
|
|
|
|
Links []string
|
2013-10-31 14:10:25 -04:00
|
|
|
PublishAllPorts bool
|
2013-05-13 19:39:54 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
type BindMap struct {
|
|
|
|
SrcPath string
|
|
|
|
DstPath string
|
|
|
|
Mode string
|
|
|
|
}
|
|
|
|
|
2013-08-15 14:38:17 -04:00
|
|
|
var (
|
2014-01-08 00:15:53 -05:00
|
|
|
ErrContainerStart = errors.New("The container failed to start. Unknown error")
|
2013-10-08 21:42:53 -04:00
|
|
|
ErrContainerStartTimeout = errors.New("The container failed to start due to timed out.")
|
2013-10-08 15:15:29 -04:00
|
|
|
ErrInvalidWorikingDirectory = errors.New("The working directory is invalid. It needs to be an absolute path.")
|
|
|
|
ErrConflictAttachDetach = errors.New("Conflicting options: -a and -d")
|
|
|
|
ErrConflictDetachAutoRemove = errors.New("Conflicting options: -rm and -d")
|
2013-08-15 14:38:17 -04:00
|
|
|
)
|
|
|
|
|
2013-08-15 19:35:03 -04:00
|
|
|
type KeyValuePair struct {
|
|
|
|
Key string
|
|
|
|
Value string
|
|
|
|
}
|
|
|
|
|
2013-10-04 22:25:15 -04:00
|
|
|
type PortBinding struct {
|
|
|
|
HostIp string
|
|
|
|
HostPort string
|
|
|
|
}
|
|
|
|
|
|
|
|
// 80/tcp
|
|
|
|
type Port string
|
|
|
|
|
|
|
|
func (p Port) Proto() string {
|
2013-11-07 21:54:00 -05:00
|
|
|
parts := strings.Split(string(p), "/")
|
|
|
|
if len(parts) == 1 {
|
|
|
|
return "tcp"
|
|
|
|
}
|
|
|
|
return parts[1]
|
2013-10-04 22:25:15 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
func (p Port) Port() string {
|
|
|
|
return strings.Split(string(p), "/")[0]
|
|
|
|
}
|
|
|
|
|
|
|
|
func (p Port) Int() int {
|
|
|
|
i, err := parsePort(p.Port())
|
|
|
|
if err != nil {
|
|
|
|
panic(err)
|
|
|
|
}
|
|
|
|
return i
|
|
|
|
}
|
|
|
|
|
|
|
|
func NewPort(proto, port string) Port {
|
|
|
|
return Port(fmt.Sprintf("%s/%s", port, proto))
|
|
|
|
}
|
|
|
|
|
|
|
|
type PortMapping map[string]string // Deprecated
|
2013-06-11 18:46:23 -04:00
|
|
|
|
2013-02-28 14:51:14 -05:00
|
|
|
type NetworkSettings struct {
|
2013-06-04 14:00:22 -04:00
|
|
|
IPAddress string
|
|
|
|
IPPrefixLen int
|
2013-02-28 14:51:14 -05:00
|
|
|
Gateway string
|
2013-04-03 18:05:03 -04:00
|
|
|
Bridge string
|
2013-10-04 22:25:15 -04:00
|
|
|
PortMapping map[string]PortMapping // Deprecated
|
|
|
|
Ports map[Port][]PortBinding
|
2013-02-25 17:06:22 -05:00
|
|
|
}
|
|
|
|
|
2014-01-16 17:00:18 -05:00
|
|
|
func (settings *NetworkSettings) PortMappingAPI() *engine.Table {
|
|
|
|
var outs = engine.NewTable("", 0)
|
2013-10-04 22:25:15 -04:00
|
|
|
for port, bindings := range settings.Ports {
|
|
|
|
p, _ := parsePort(port.Port())
|
|
|
|
if len(bindings) == 0 {
|
2014-01-16 17:00:18 -05:00
|
|
|
out := &engine.Env{}
|
|
|
|
out.SetInt("PublicPort", p)
|
|
|
|
out.Set("Type", port.Proto())
|
|
|
|
outs.Add(out)
|
2013-10-04 22:25:15 -04:00
|
|
|
continue
|
|
|
|
}
|
|
|
|
for _, binding := range bindings {
|
2014-01-16 17:00:18 -05:00
|
|
|
out := &engine.Env{}
|
2013-10-04 22:25:15 -04:00
|
|
|
h, _ := parsePort(binding.HostPort)
|
2014-01-16 17:00:18 -05:00
|
|
|
out.SetInt("PrivatePort", p)
|
|
|
|
out.SetInt("PublicPort", h)
|
|
|
|
out.Set("Type", port.Proto())
|
|
|
|
out.Set("IP", binding.HostIp)
|
|
|
|
outs.Add(out)
|
2013-10-04 22:25:15 -04:00
|
|
|
}
|
2013-06-11 18:46:23 -04:00
|
|
|
}
|
2014-01-16 17:00:18 -05:00
|
|
|
return outs
|
2013-04-19 22:29:13 -04:00
|
|
|
}
|
|
|
|
|
2013-04-24 16:37:00 -04:00
|
|
|
// Inject the io.Reader at the given path. Note: do not close the reader
|
|
|
|
func (container *Container) Inject(file io.Reader, pth string) error {
|
2013-12-06 06:15:14 -05:00
|
|
|
if err := container.Mount(); err != nil {
|
2013-11-07 15:30:56 -05:00
|
|
|
return fmt.Errorf("inject: error mounting container %s: %s", container.ID, err)
|
2013-04-24 16:51:28 -04:00
|
|
|
}
|
2013-12-05 16:18:02 -05:00
|
|
|
defer container.Unmount()
|
2013-11-07 18:26:52 -05:00
|
|
|
|
2013-11-06 00:44:52 -05:00
|
|
|
// Return error if path exists
|
2013-11-08 15:06:15 -05:00
|
|
|
destPath := path.Join(container.RootfsPath(), pth)
|
|
|
|
if _, err := os.Stat(destPath); err == nil {
|
2013-11-06 00:44:52 -05:00
|
|
|
// Since err is nil, the path could be stat'd and it exists
|
|
|
|
return fmt.Errorf("%s exists", pth)
|
2013-11-07 15:19:24 -05:00
|
|
|
} else if !os.IsNotExist(err) {
|
2013-11-06 00:44:52 -05:00
|
|
|
// Expect err might be that the file doesn't exist, so
|
2013-11-07 15:19:24 -05:00
|
|
|
// if it's some other error, return that.
|
2013-11-06 00:44:52 -05:00
|
|
|
|
|
|
|
return err
|
|
|
|
}
|
2013-11-08 15:06:15 -05:00
|
|
|
|
|
|
|
// Make sure the directory exists
|
|
|
|
if err := os.MkdirAll(path.Join(container.RootfsPath(), path.Dir(pth)), 0755); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
dest, err := os.Create(destPath)
|
2013-04-24 16:37:00 -04:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2013-11-08 15:06:15 -05:00
|
|
|
defer dest.Close()
|
|
|
|
|
2013-04-24 16:37:00 -04:00
|
|
|
if _, err := io.Copy(dest, file); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2013-01-29 06:24:31 -05:00
|
|
|
func (container *Container) When() time.Time {
|
|
|
|
return container.Created
|
|
|
|
}
|
|
|
|
|
2013-03-21 03:25:00 -04:00
|
|
|
func (container *Container) FromDisk() error {
|
|
|
|
data, err := ioutil.ReadFile(container.jsonPath())
|
2013-01-25 17:39:02 -05:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2013-03-21 03:25:00 -04:00
|
|
|
// Load container settings
|
2013-07-29 12:40:35 -04:00
|
|
|
// udp broke compat of docker.PortMapping, but it's not used when loading a container, we can skip it
|
|
|
|
if err := json.Unmarshal(data, container); err != nil && !strings.Contains(err.Error(), "docker.PortMapping") {
|
2013-01-25 17:39:02 -05:00
|
|
|
return err
|
|
|
|
}
|
2013-10-31 17:58:43 -04:00
|
|
|
return container.readHostConfig()
|
2013-01-25 17:39:02 -05:00
|
|
|
}
|
|
|
|
|
2013-03-21 03:25:00 -04:00
|
|
|
func (container *Container) ToDisk() (err error) {
|
2013-01-22 14:13:22 -05:00
|
|
|
data, err := json.Marshal(container)
|
2013-01-18 19:13:39 -05:00
|
|
|
if err != nil {
|
2013-01-22 14:13:22 -05:00
|
|
|
return
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
2013-10-31 17:58:43 -04:00
|
|
|
err = ioutil.WriteFile(container.jsonPath(), data, 0666)
|
|
|
|
if err != nil {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
return container.writeHostConfig()
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
|
|
|
|
2013-10-31 17:58:43 -04:00
|
|
|
func (container *Container) readHostConfig() error {
|
|
|
|
container.hostConfig = &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.)
|
|
|
|
_, err := os.Stat(container.hostConfigPath())
|
|
|
|
if os.IsNotExist(err) {
|
|
|
|
return nil
|
|
|
|
}
|
2013-07-02 08:19:25 -04:00
|
|
|
data, err := ioutil.ReadFile(container.hostConfigPath())
|
|
|
|
if err != nil {
|
2013-10-31 17:58:43 -04:00
|
|
|
return err
|
2013-07-02 08:19:25 -04:00
|
|
|
}
|
2013-10-31 17:58:43 -04:00
|
|
|
return json.Unmarshal(data, container.hostConfig)
|
2013-07-02 08:19:25 -04:00
|
|
|
}
|
|
|
|
|
2013-10-31 17:58:43 -04:00
|
|
|
func (container *Container) writeHostConfig() (err error) {
|
|
|
|
data, err := json.Marshal(container.hostConfig)
|
2013-07-02 08:19:25 -04:00
|
|
|
if err != nil {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
return ioutil.WriteFile(container.hostConfigPath(), data, 0666)
|
|
|
|
}
|
|
|
|
|
2013-08-13 18:40:23 -04:00
|
|
|
func (container *Container) generateEnvConfig(env []string) error {
|
2013-08-14 20:14:30 -04:00
|
|
|
data, err := json.Marshal(env)
|
2013-08-13 18:40:23 -04:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2013-12-17 17:04:37 -05:00
|
|
|
p, err := container.EnvConfigPath()
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
ioutil.WriteFile(p, data, 0600)
|
2013-08-13 18:40:23 -04:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2014-01-13 18:37:17 -05:00
|
|
|
func (container *Container) setupPty() error {
|
2013-04-04 15:12:22 -04:00
|
|
|
ptyMaster, ptySlave, err := pty.Open()
|
2013-01-29 18:17:20 -05:00
|
|
|
if err != nil {
|
2014-01-13 18:37:17 -05:00
|
|
|
return err
|
2013-01-29 18:17:20 -05:00
|
|
|
}
|
2013-04-04 15:12:22 -04:00
|
|
|
container.ptyMaster = ptyMaster
|
2014-01-20 19:05:07 -05:00
|
|
|
container.command.Stdout = ptySlave
|
|
|
|
container.command.Stderr = ptySlave
|
2013-01-29 18:17:20 -05:00
|
|
|
|
|
|
|
// Copy the PTYs to our broadcasters
|
|
|
|
go func() {
|
2013-04-02 04:45:17 -04:00
|
|
|
defer container.stdout.CloseWriters()
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("startPty: begin of stdout pipe")
|
2013-04-04 15:12:22 -04:00
|
|
|
io.Copy(container.stdout, ptyMaster)
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("startPty: end of stdout pipe")
|
2013-01-29 18:17:20 -05:00
|
|
|
}()
|
|
|
|
|
|
|
|
// stdin
|
|
|
|
if container.Config.OpenStdin {
|
2014-01-20 19:05:07 -05:00
|
|
|
container.command.Stdin = ptySlave
|
|
|
|
container.command.SysProcAttr.Setctty = true
|
2013-01-29 18:17:20 -05:00
|
|
|
go func() {
|
|
|
|
defer container.stdin.Close()
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("startPty: begin of stdin pipe")
|
2013-04-04 15:12:22 -04:00
|
|
|
io.Copy(ptyMaster, container.stdin)
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("startPty: end of stdin pipe")
|
2013-01-29 18:17:20 -05:00
|
|
|
}()
|
|
|
|
}
|
2014-01-13 18:37:17 -05:00
|
|
|
return nil
|
2013-01-29 18:17:20 -05:00
|
|
|
}
|
|
|
|
|
2014-01-13 18:37:17 -05:00
|
|
|
func (container *Container) setupStd() error {
|
2014-01-20 19:05:07 -05:00
|
|
|
container.command.Stdout = container.stdout
|
|
|
|
container.command.Stderr = container.stderr
|
2013-01-29 18:17:20 -05:00
|
|
|
if container.Config.OpenStdin {
|
2014-01-20 19:05:07 -05:00
|
|
|
stdin, err := container.command.StdinPipe()
|
2013-01-29 18:17:20 -05:00
|
|
|
if err != nil {
|
2014-01-13 18:37:17 -05:00
|
|
|
return err
|
2013-01-29 18:17:20 -05:00
|
|
|
}
|
|
|
|
go func() {
|
|
|
|
defer stdin.Close()
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("start: begin of stdin pipe")
|
2013-01-29 18:17:20 -05:00
|
|
|
io.Copy(stdin, container.stdin)
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("start: end of stdin pipe")
|
2013-01-29 18:17:20 -05:00
|
|
|
}()
|
|
|
|
}
|
2014-01-13 18:37:17 -05:00
|
|
|
return nil
|
2013-01-29 18:17:20 -05:00
|
|
|
}
|
|
|
|
|
2013-04-02 15:18:20 -04:00
|
|
|
func (container *Container) Attach(stdin io.ReadCloser, stdinCloser io.Closer, stdout io.Writer, stderr io.Writer) chan error {
|
|
|
|
var cStdout, cStderr io.ReadCloser
|
|
|
|
|
2013-04-02 02:52:20 -04:00
|
|
|
var nJobs int
|
|
|
|
errors := make(chan error, 3)
|
|
|
|
if stdin != nil && container.Config.OpenStdin {
|
|
|
|
nJobs += 1
|
|
|
|
if cStdin, err := container.StdinPipe(); err != nil {
|
|
|
|
errors <- err
|
|
|
|
} else {
|
|
|
|
go func() {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("attach: stdin: begin")
|
|
|
|
defer utils.Debugf("attach: stdin: end")
|
2013-04-02 15:19:01 -04:00
|
|
|
// No matter what, when stdin is closed (io.Copy unblock), close stdout and stderr
|
2013-04-09 11:18:16 -04:00
|
|
|
if container.Config.StdinOnce && !container.Config.Tty {
|
2013-04-02 02:52:20 -04:00
|
|
|
defer cStdin.Close()
|
2013-07-24 18:48:18 -04:00
|
|
|
} else {
|
2014-01-10 19:18:15 -05:00
|
|
|
defer func() {
|
|
|
|
if cStdout != nil {
|
|
|
|
cStdout.Close()
|
|
|
|
}
|
|
|
|
if cStderr != nil {
|
|
|
|
cStderr.Close()
|
|
|
|
}
|
|
|
|
}()
|
2013-04-02 02:52:20 -04:00
|
|
|
}
|
2013-04-04 15:57:45 -04:00
|
|
|
if container.Config.Tty {
|
2013-05-14 18:37:35 -04:00
|
|
|
_, err = utils.CopyEscapable(cStdin, stdin)
|
2013-04-04 15:57:45 -04:00
|
|
|
} else {
|
|
|
|
_, err = io.Copy(cStdin, stdin)
|
|
|
|
}
|
2013-10-24 16:00:51 -04:00
|
|
|
if err == io.ErrClosedPipe {
|
|
|
|
err = nil
|
|
|
|
}
|
2013-04-02 02:52:20 -04:00
|
|
|
if err != nil {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Errorf("attach: stdin: %s", err)
|
2013-04-02 02:52:20 -04:00
|
|
|
}
|
2013-10-24 16:00:51 -04:00
|
|
|
errors <- err
|
2013-04-02 02:52:20 -04:00
|
|
|
}()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if stdout != nil {
|
|
|
|
nJobs += 1
|
|
|
|
if p, err := container.StdoutPipe(); err != nil {
|
|
|
|
errors <- err
|
|
|
|
} else {
|
|
|
|
cStdout = p
|
|
|
|
go func() {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("attach: stdout: begin")
|
|
|
|
defer utils.Debugf("attach: stdout: end")
|
2013-04-02 15:18:20 -04:00
|
|
|
// If we are in StdinOnce mode, then close stdin
|
2013-09-23 20:53:02 -04:00
|
|
|
if container.Config.StdinOnce && stdin != nil {
|
|
|
|
defer stdin.Close()
|
|
|
|
}
|
|
|
|
if stdinCloser != nil {
|
|
|
|
defer stdinCloser.Close()
|
2013-04-02 15:18:20 -04:00
|
|
|
}
|
2013-04-02 02:52:20 -04:00
|
|
|
_, err := io.Copy(stdout, cStdout)
|
2013-10-16 13:41:36 -04:00
|
|
|
if err == io.ErrClosedPipe {
|
|
|
|
err = nil
|
|
|
|
}
|
2013-04-02 02:52:20 -04:00
|
|
|
if err != nil {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Errorf("attach: stdout: %s", err)
|
2013-04-02 02:52:20 -04:00
|
|
|
}
|
|
|
|
errors <- err
|
|
|
|
}()
|
|
|
|
}
|
2013-06-03 20:39:29 -04:00
|
|
|
} else {
|
|
|
|
go func() {
|
2013-06-04 17:35:32 -04:00
|
|
|
if stdinCloser != nil {
|
|
|
|
defer stdinCloser.Close()
|
|
|
|
}
|
|
|
|
if cStdout, err := container.StdoutPipe(); err != nil {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Errorf("attach: stdout pipe: %s", err)
|
2013-06-04 17:35:32 -04:00
|
|
|
} else {
|
|
|
|
io.Copy(&utils.NopWriter{}, cStdout)
|
2013-06-03 20:39:29 -04:00
|
|
|
}
|
|
|
|
}()
|
2013-04-02 02:52:20 -04:00
|
|
|
}
|
|
|
|
if stderr != nil {
|
|
|
|
nJobs += 1
|
|
|
|
if p, err := container.StderrPipe(); err != nil {
|
|
|
|
errors <- err
|
|
|
|
} else {
|
|
|
|
cStderr = p
|
|
|
|
go func() {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("attach: stderr: begin")
|
|
|
|
defer utils.Debugf("attach: stderr: end")
|
2013-04-02 15:18:20 -04:00
|
|
|
// If we are in StdinOnce mode, then close stdin
|
2013-09-23 20:53:02 -04:00
|
|
|
if container.Config.StdinOnce && stdin != nil {
|
|
|
|
defer stdin.Close()
|
|
|
|
}
|
|
|
|
if stdinCloser != nil {
|
|
|
|
defer stdinCloser.Close()
|
2013-04-02 15:18:20 -04:00
|
|
|
}
|
2013-04-02 02:52:20 -04:00
|
|
|
_, err := io.Copy(stderr, cStderr)
|
2013-10-16 13:41:36 -04:00
|
|
|
if err == io.ErrClosedPipe {
|
|
|
|
err = nil
|
|
|
|
}
|
2013-04-02 02:52:20 -04:00
|
|
|
if err != nil {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Errorf("attach: stderr: %s", err)
|
2013-04-02 02:52:20 -04:00
|
|
|
}
|
|
|
|
errors <- err
|
|
|
|
}()
|
|
|
|
}
|
2013-06-03 20:39:29 -04:00
|
|
|
} else {
|
|
|
|
go func() {
|
2013-06-04 17:35:32 -04:00
|
|
|
if stdinCloser != nil {
|
|
|
|
defer stdinCloser.Close()
|
|
|
|
}
|
2013-06-03 20:39:29 -04:00
|
|
|
|
2013-06-10 14:08:40 -04:00
|
|
|
if cStderr, err := container.StderrPipe(); err != nil {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Errorf("attach: stdout pipe: %s", err)
|
2013-06-04 17:35:32 -04:00
|
|
|
} else {
|
|
|
|
io.Copy(&utils.NopWriter{}, cStderr)
|
2013-06-03 20:39:29 -04:00
|
|
|
}
|
|
|
|
}()
|
2013-04-02 02:52:20 -04:00
|
|
|
}
|
2013-06-03 20:39:29 -04:00
|
|
|
|
2013-05-14 18:37:35 -04:00
|
|
|
return utils.Go(func() error {
|
2014-01-10 19:18:15 -05:00
|
|
|
defer func() {
|
|
|
|
if cStdout != nil {
|
|
|
|
cStdout.Close()
|
|
|
|
}
|
|
|
|
if cStderr != nil {
|
|
|
|
cStderr.Close()
|
|
|
|
}
|
|
|
|
}()
|
|
|
|
|
2013-10-16 13:41:36 -04:00
|
|
|
// FIXME: how to clean up the stdin goroutine without the unwanted side effect
|
2013-04-02 02:52:20 -04:00
|
|
|
// of closing the passed stdin? Add an intermediary io.Pipe?
|
|
|
|
for i := 0; i < nJobs; i += 1 {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("attach: waiting for job %d/%d", i+1, nJobs)
|
2013-04-02 02:52:20 -04:00
|
|
|
if err := <-errors; err != nil {
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Errorf("attach: job %d returned error %s, aborting all jobs", i+1, err)
|
2013-04-02 02:52:20 -04:00
|
|
|
return err
|
|
|
|
}
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("attach: job %d completed successfully", i+1)
|
2013-04-02 02:52:20 -04:00
|
|
|
}
|
2013-10-16 13:41:36 -04:00
|
|
|
utils.Debugf("attach: all jobs completed successfully")
|
2013-04-02 02:52:20 -04:00
|
|
|
return nil
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
2014-01-20 21:07:18 -05:00
|
|
|
func populateCommand(c *Container) {
|
|
|
|
var (
|
|
|
|
en *execdriver.Network
|
|
|
|
driverConfig []string
|
|
|
|
)
|
|
|
|
if !c.Config.NetworkDisabled {
|
|
|
|
network := c.NetworkSettings
|
|
|
|
en = &execdriver.Network{
|
|
|
|
Gateway: network.Gateway,
|
|
|
|
Bridge: network.Bridge,
|
|
|
|
IPAddress: network.IPAddress,
|
|
|
|
IPPrefixLen: network.IPPrefixLen,
|
|
|
|
Mtu: c.runtime.config.Mtu,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if lxcConf := c.hostConfig.LxcConf; lxcConf != nil {
|
|
|
|
for _, pair := range lxcConf {
|
|
|
|
driverConfig = append(driverConfig, fmt.Sprintf("%s = %s", pair.Key, pair.Value))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
resources := &execdriver.Resources{
|
|
|
|
Memory: c.Config.Memory,
|
|
|
|
MemorySwap: c.Config.MemorySwap,
|
|
|
|
CpuShares: c.Config.CpuShares,
|
|
|
|
}
|
|
|
|
c.command = &execdriver.Command{
|
|
|
|
ID: c.ID,
|
|
|
|
Privileged: c.hostConfig.Privileged,
|
|
|
|
Rootfs: c.RootfsPath(),
|
|
|
|
InitPath: "/.dockerinit",
|
|
|
|
Entrypoint: c.Path,
|
|
|
|
Arguments: c.Args,
|
|
|
|
WorkingDir: c.Config.WorkingDir,
|
|
|
|
Network: en,
|
|
|
|
Tty: c.Config.Tty,
|
|
|
|
User: c.Config.User,
|
|
|
|
Config: driverConfig,
|
|
|
|
Resources: resources,
|
|
|
|
}
|
|
|
|
c.command.SysProcAttr = &syscall.SysProcAttr{Setsid: true}
|
|
|
|
}
|
|
|
|
|
2013-10-31 17:58:43 -04:00
|
|
|
func (container *Container) Start() (err error) {
|
2013-11-21 15:21:03 -05:00
|
|
|
container.Lock()
|
|
|
|
defer container.Unlock()
|
|
|
|
|
|
|
|
if container.State.IsRunning() {
|
2013-11-11 21:15:38 -05:00
|
|
|
return fmt.Errorf("The container %s is already running.", container.ID)
|
|
|
|
}
|
2013-10-16 16:12:56 -04:00
|
|
|
defer func() {
|
|
|
|
if err != nil {
|
|
|
|
container.cleanup()
|
2013-10-16 15:01:55 -04:00
|
|
|
}
|
2013-10-16 16:12:56 -04:00
|
|
|
}()
|
2013-12-06 06:15:14 -05:00
|
|
|
if err := container.Mount(); err != nil {
|
2013-10-16 16:12:56 -04:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
if container.runtime.networkManager.disabled {
|
|
|
|
container.Config.NetworkDisabled = true
|
2013-10-10 12:44:48 -04:00
|
|
|
container.buildHostnameAndHostsFiles("127.0.1.1")
|
2013-10-16 16:12:56 -04:00
|
|
|
} else {
|
2013-10-31 17:58:43 -04:00
|
|
|
if err := container.allocateNetwork(); err != nil {
|
2013-07-21 20:49:09 -04:00
|
|
|
return err
|
|
|
|
}
|
2013-10-08 17:29:22 -04:00
|
|
|
container.buildHostnameAndHostsFiles(container.NetworkSettings.IPAddress)
|
2013-10-16 16:12:56 -04:00
|
|
|
}
|
2013-04-11 15:58:23 -04:00
|
|
|
|
2013-10-16 16:12:56 -04:00
|
|
|
// Make sure the config is compatible with the current kernel
|
2014-01-15 17:36:13 -05:00
|
|
|
if container.Config.Memory > 0 && !container.runtime.sysInfo.MemoryLimit {
|
2013-10-16 16:12:56 -04:00
|
|
|
log.Printf("WARNING: Your kernel does not support memory limit capabilities. Limitation discarded.\n")
|
|
|
|
container.Config.Memory = 0
|
|
|
|
}
|
2014-01-15 17:36:13 -05:00
|
|
|
if container.Config.Memory > 0 && !container.runtime.sysInfo.SwapLimit {
|
2013-10-16 16:12:56 -04:00
|
|
|
log.Printf("WARNING: Your kernel does not support swap limit capabilities. Limitation discarded.\n")
|
|
|
|
container.Config.MemorySwap = -1
|
|
|
|
}
|
2013-04-11 15:58:23 -04:00
|
|
|
|
2014-01-15 17:36:13 -05:00
|
|
|
if container.runtime.sysInfo.IPv4ForwardingDisabled {
|
2013-10-16 16:12:56 -04:00
|
|
|
log.Printf("WARNING: IPv4 forwarding is disabled. Networking will not work")
|
|
|
|
}
|
2013-08-03 18:06:58 -04:00
|
|
|
|
2013-10-16 16:12:56 -04:00
|
|
|
if container.Volumes == nil || len(container.Volumes) == 0 {
|
|
|
|
container.Volumes = make(map[string]string)
|
|
|
|
container.VolumesRW = make(map[string]bool)
|
|
|
|
}
|
2013-08-10 00:55:23 -04:00
|
|
|
|
2013-10-16 16:12:56 -04:00
|
|
|
// Apply volumes from another container if requested
|
2013-12-03 17:47:49 -05:00
|
|
|
if err := container.applyExternalVolumes(); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2013-09-19 16:09:19 -04:00
|
|
|
|
2013-12-03 17:47:49 -05:00
|
|
|
if err := container.createVolumes(); err != nil {
|
|
|
|
return err
|
2013-10-16 16:12:56 -04:00
|
|
|
}
|
2013-04-09 21:19:55 -04:00
|
|
|
|
2013-08-13 18:40:23 -04:00
|
|
|
// Setup environment
|
|
|
|
env := []string{
|
|
|
|
"HOME=/",
|
|
|
|
"PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin",
|
|
|
|
"HOSTNAME=" + container.Config.Hostname,
|
2013-10-16 16:12:56 -04:00
|
|
|
}
|
2013-04-16 03:25:55 -04:00
|
|
|
|
2013-08-13 18:40:23 -04:00
|
|
|
if container.Config.Tty {
|
|
|
|
env = append(env, "TERM=xterm")
|
|
|
|
}
|
2013-10-04 22:25:15 -04:00
|
|
|
|
|
|
|
// Init any links between the parent and children
|
|
|
|
runtime := container.runtime
|
|
|
|
|
2013-10-28 19:58:59 -04:00
|
|
|
children, err := runtime.Children(container.Name)
|
2013-10-04 22:25:15 -04:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
if len(children) > 0 {
|
|
|
|
container.activeLinks = make(map[string]*Link, len(children))
|
|
|
|
|
|
|
|
// If we encounter an error make sure that we rollback any network
|
|
|
|
// config and ip table changes
|
|
|
|
rollback := func() {
|
|
|
|
for _, link := range container.activeLinks {
|
|
|
|
link.Disable()
|
|
|
|
}
|
|
|
|
container.activeLinks = nil
|
|
|
|
}
|
|
|
|
|
|
|
|
for p, child := range children {
|
|
|
|
link, err := NewLink(container, child, p, runtime.networkManager.bridgeIface)
|
|
|
|
if err != nil {
|
|
|
|
rollback()
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
container.activeLinks[link.Alias()] = link
|
|
|
|
if err := link.Enable(); err != nil {
|
|
|
|
rollback()
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
for _, envVar := range link.ToEnv() {
|
2013-08-13 18:40:23 -04:00
|
|
|
env = append(env, envVar)
|
2013-10-04 22:25:15 -04:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2013-08-13 18:40:23 -04:00
|
|
|
for _, elem := range container.Config.Env {
|
|
|
|
env = append(env, elem)
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := container.generateEnvConfig(env); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2014-01-20 21:07:18 -05:00
|
|
|
root := container.RootfsPath()
|
|
|
|
|
2013-10-16 16:12:56 -04:00
|
|
|
if container.Config.WorkingDir != "" {
|
2014-01-20 21:07:18 -05:00
|
|
|
container.Config.WorkingDir = path.Clean(container.Config.WorkingDir)
|
|
|
|
if err := os.MkdirAll(path.Join(root, container.Config.WorkingDir), 0755); err != nil {
|
2013-10-16 16:12:56 -04:00
|
|
|
return nil
|
2013-10-16 15:01:55 -04:00
|
|
|
}
|
2013-10-16 16:12:56 -04:00
|
|
|
}
|
2013-03-29 11:46:06 -04:00
|
|
|
|
2013-12-18 19:42:49 -05:00
|
|
|
envPath, err := container.EnvConfigPath()
|
2013-12-17 17:04:37 -05:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2013-12-18 19:42:49 -05:00
|
|
|
// Mount docker specific files into the containers root fs
|
|
|
|
if err := mount.Mount(runtime.sysInitPath, path.Join(root, "/.dockerinit"), "none", "bind,ro"); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
if err := mount.Mount(envPath, path.Join(root, "/.dockerenv"), "none", "bind,ro"); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
if err := mount.Mount(container.ResolvConfPath, path.Join(root, "/etc/resolv.conf"), "none", "bind,ro"); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
if container.HostnamePath != "" && container.HostsPath != "" {
|
|
|
|
if err := mount.Mount(container.HostnamePath, path.Join(root, "/etc/hostname"), "none", "bind,ro"); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
if err := mount.Mount(container.HostsPath, path.Join(root, "/etc/hosts"), "none", "bind,ro"); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// Mount user specified volumes
|
|
|
|
for r, v := range container.Volumes {
|
|
|
|
mountAs := "ro"
|
2014-01-14 17:28:19 -05:00
|
|
|
if container.VolumesRW[r] {
|
2013-12-18 19:42:49 -05:00
|
|
|
mountAs = "rw"
|
|
|
|
}
|
|
|
|
|
2014-01-11 05:31:01 -05:00
|
|
|
r = path.Join(root, r)
|
|
|
|
if p, err := utils.FollowSymlinkInScope(r, root); err != nil {
|
|
|
|
return err
|
|
|
|
} else {
|
|
|
|
r = p
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := mount.Mount(v, r, "none", fmt.Sprintf("bind,%s", mountAs)); err != nil {
|
2013-12-17 17:04:37 -05:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2014-01-20 21:07:18 -05:00
|
|
|
populateCommand(container)
|
2013-10-29 11:16:51 -04:00
|
|
|
|
2013-10-16 16:12:56 -04:00
|
|
|
// Setup logging of stdout and stderr to disk
|
|
|
|
if err := container.runtime.LogToDisk(container.stdout, container.logPath("json"), "stdout"); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
if err := container.runtime.LogToDisk(container.stderr, container.logPath("json"), "stderr"); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2014-01-10 18:34:03 -05:00
|
|
|
container.waitLock = make(chan struct{})
|
2014-01-13 18:37:17 -05:00
|
|
|
|
2014-01-15 14:46:25 -05:00
|
|
|
// Setuping pipes and/or Pty
|
|
|
|
var setup func() error
|
2014-01-13 18:37:17 -05:00
|
|
|
if container.Config.Tty {
|
2014-01-15 14:46:25 -05:00
|
|
|
setup = container.setupPty
|
2014-01-13 18:37:17 -05:00
|
|
|
} else {
|
2014-01-15 14:46:25 -05:00
|
|
|
setup = container.setupStd
|
2014-01-13 18:37:17 -05:00
|
|
|
}
|
2014-01-15 14:46:25 -05:00
|
|
|
if err := setup(); err != nil {
|
2014-01-13 18:37:17 -05:00
|
|
|
return err
|
|
|
|
}
|
2014-01-10 17:26:29 -05:00
|
|
|
|
2014-01-15 14:46:25 -05:00
|
|
|
callbackLock := make(chan struct{})
|
2014-01-20 19:05:07 -05:00
|
|
|
callback := func(command *execdriver.Command) {
|
|
|
|
container.State.SetRunning(command.Pid())
|
|
|
|
if command.Tty {
|
2014-01-13 18:37:17 -05:00
|
|
|
// The callback is called after the process Start()
|
|
|
|
// so we are in the parent process. In TTY mode, stdin/out/err is the PtySlace
|
|
|
|
// which we close here.
|
2014-01-20 19:05:07 -05:00
|
|
|
if c, ok := command.Stdout.(io.Closer); ok {
|
2014-01-13 18:02:12 -05:00
|
|
|
c.Close()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if err := container.ToDisk(); err != nil {
|
|
|
|
utils.Debugf("%s", err)
|
|
|
|
}
|
2014-01-15 14:46:25 -05:00
|
|
|
close(callbackLock)
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
2013-10-16 16:12:56 -04:00
|
|
|
|
2014-01-13 19:10:23 -05:00
|
|
|
// We use a callback here instead of a goroutine and an chan for
|
|
|
|
// syncronization purposes
|
2014-01-13 19:41:35 -05:00
|
|
|
cErr := utils.Go(func() error { return container.monitor(callback) })
|
2014-01-13 18:02:12 -05:00
|
|
|
|
|
|
|
// Start should not return until the process is actually running
|
2014-01-13 19:41:35 -05:00
|
|
|
select {
|
2014-01-15 14:46:25 -05:00
|
|
|
case <-callbackLock:
|
2014-01-13 19:41:35 -05:00
|
|
|
case err := <-cErr:
|
|
|
|
return err
|
|
|
|
}
|
2014-01-09 19:03:22 -05:00
|
|
|
return nil
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
|
|
|
|
2013-12-03 17:47:49 -05:00
|
|
|
func (container *Container) getBindMap() (map[string]BindMap, error) {
|
|
|
|
// Create the requested bind mounts
|
|
|
|
binds := make(map[string]BindMap)
|
|
|
|
// Define illegal container destinations
|
|
|
|
illegalDsts := []string{"/", "."}
|
|
|
|
|
|
|
|
for _, bind := range container.hostConfig.Binds {
|
|
|
|
// FIXME: factorize bind parsing in parseBind
|
|
|
|
var src, dst, mode string
|
|
|
|
arr := strings.Split(bind, ":")
|
|
|
|
if len(arr) == 2 {
|
|
|
|
src = arr[0]
|
|
|
|
dst = arr[1]
|
|
|
|
mode = "rw"
|
|
|
|
} else if len(arr) == 3 {
|
|
|
|
src = arr[0]
|
|
|
|
dst = arr[1]
|
|
|
|
mode = arr[2]
|
|
|
|
} else {
|
|
|
|
return nil, fmt.Errorf("Invalid bind specification: %s", bind)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Bail if trying to mount to an illegal destination
|
|
|
|
for _, illegal := range illegalDsts {
|
|
|
|
if dst == illegal {
|
|
|
|
return nil, fmt.Errorf("Illegal bind destination: %s", dst)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
bindMap := BindMap{
|
|
|
|
SrcPath: src,
|
|
|
|
DstPath: dst,
|
|
|
|
Mode: mode,
|
|
|
|
}
|
|
|
|
binds[path.Clean(dst)] = bindMap
|
|
|
|
}
|
2013-12-11 19:31:02 -05:00
|
|
|
return binds, nil
|
2013-12-03 17:47:49 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) createVolumes() error {
|
2013-12-11 19:31:02 -05:00
|
|
|
binds, err := container.getBindMap()
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2013-12-03 17:47:49 -05:00
|
|
|
volumesDriver := container.runtime.volumes.driver
|
|
|
|
// Create the requested volumes if they don't exist
|
|
|
|
for volPath := range container.Config.Volumes {
|
|
|
|
volPath = path.Clean(volPath)
|
|
|
|
volIsDir := true
|
|
|
|
// Skip existing volumes
|
|
|
|
if _, exists := container.Volumes[volPath]; exists {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
var srcPath string
|
|
|
|
var isBindMount bool
|
|
|
|
srcRW := false
|
|
|
|
// If an external bind is defined for this volume, use that as a source
|
|
|
|
if bindMap, exists := binds[volPath]; exists {
|
|
|
|
isBindMount = true
|
|
|
|
srcPath = bindMap.SrcPath
|
|
|
|
if strings.ToLower(bindMap.Mode) == "rw" {
|
|
|
|
srcRW = true
|
|
|
|
}
|
2014-01-11 05:31:01 -05:00
|
|
|
if stat, err := os.Stat(bindMap.SrcPath); err != nil {
|
2013-12-03 17:47:49 -05:00
|
|
|
return err
|
|
|
|
} else {
|
2013-12-10 13:49:53 -05:00
|
|
|
volIsDir = stat.IsDir()
|
2013-12-03 17:47:49 -05:00
|
|
|
}
|
|
|
|
// Otherwise create an directory in $ROOT/volumes/ and use that
|
|
|
|
} else {
|
|
|
|
|
|
|
|
// Do not pass a container as the parameter for the volume creation.
|
|
|
|
// The graph driver using the container's information ( Image ) to
|
|
|
|
// create the parent.
|
|
|
|
c, err := container.runtime.volumes.Create(nil, nil, "", "", nil)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
srcPath, err = volumesDriver.Get(c.ID)
|
|
|
|
if err != nil {
|
|
|
|
return fmt.Errorf("Driver %s failed to get volume rootfs %s: %s", volumesDriver, c.ID, err)
|
|
|
|
}
|
|
|
|
srcRW = true // RW by default
|
|
|
|
}
|
2014-01-11 05:31:01 -05:00
|
|
|
|
|
|
|
if p, err := filepath.EvalSymlinks(srcPath); err != nil {
|
|
|
|
return err
|
|
|
|
} else {
|
|
|
|
srcPath = p
|
|
|
|
}
|
|
|
|
|
2013-12-03 17:47:49 -05:00
|
|
|
container.Volumes[volPath] = srcPath
|
|
|
|
container.VolumesRW[volPath] = srcRW
|
2013-12-11 19:31:02 -05:00
|
|
|
|
2013-12-03 17:47:49 -05:00
|
|
|
// Create the mountpoint
|
2013-12-11 19:31:02 -05:00
|
|
|
volPath = path.Join(container.RootfsPath(), volPath)
|
2013-12-11 20:12:53 -05:00
|
|
|
rootVolPath, err := utils.FollowSymlinkInScope(volPath, container.RootfsPath())
|
2013-12-11 19:31:02 -05:00
|
|
|
if err != nil {
|
2013-12-18 14:40:00 -05:00
|
|
|
return err
|
2013-12-03 17:47:49 -05:00
|
|
|
}
|
|
|
|
|
2013-12-11 19:31:02 -05:00
|
|
|
if _, err := os.Stat(rootVolPath); err != nil {
|
2013-12-03 17:47:49 -05:00
|
|
|
if os.IsNotExist(err) {
|
|
|
|
if volIsDir {
|
2013-12-11 19:31:02 -05:00
|
|
|
if err := os.MkdirAll(rootVolPath, 0755); err != nil {
|
2013-12-03 17:47:49 -05:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
} else {
|
2013-12-11 19:31:02 -05:00
|
|
|
if err := os.MkdirAll(path.Dir(rootVolPath), 0755); err != nil {
|
2013-12-03 17:47:49 -05:00
|
|
|
return err
|
|
|
|
}
|
2013-12-11 19:31:02 -05:00
|
|
|
if f, err := os.OpenFile(rootVolPath, os.O_CREATE, 0755); err != nil {
|
2013-12-03 17:47:49 -05:00
|
|
|
return err
|
|
|
|
} else {
|
|
|
|
f.Close()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// Do not copy or change permissions if we are mounting from the host
|
|
|
|
if srcRW && !isBindMount {
|
|
|
|
volList, err := ioutil.ReadDir(rootVolPath)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
if len(volList) > 0 {
|
|
|
|
srcList, err := ioutil.ReadDir(srcPath)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
if len(srcList) == 0 {
|
|
|
|
// If the source volume is empty copy files from the root into the volume
|
|
|
|
if err := archive.CopyWithTar(rootVolPath, srcPath); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
var stat syscall.Stat_t
|
|
|
|
if err := syscall.Stat(rootVolPath, &stat); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
var srcStat syscall.Stat_t
|
|
|
|
if err := syscall.Stat(srcPath, &srcStat); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
// Change the source volume's ownership if it differs from the root
|
2014-01-23 16:41:18 -05:00
|
|
|
// files that were just copied
|
2013-12-03 17:47:49 -05:00
|
|
|
if stat.Uid != srcStat.Uid || stat.Gid != srcStat.Gid {
|
|
|
|
if err := os.Chown(srcPath, int(stat.Uid), int(stat.Gid)); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) applyExternalVolumes() error {
|
2013-12-03 17:35:54 -05:00
|
|
|
if container.Config.VolumesFrom != "" {
|
|
|
|
containerSpecs := strings.Split(container.Config.VolumesFrom, ",")
|
|
|
|
for _, containerSpec := range containerSpecs {
|
|
|
|
mountRW := true
|
|
|
|
specParts := strings.SplitN(containerSpec, ":", 2)
|
|
|
|
switch len(specParts) {
|
|
|
|
case 0:
|
|
|
|
return fmt.Errorf("Malformed volumes-from specification: %s", container.Config.VolumesFrom)
|
|
|
|
case 2:
|
|
|
|
switch specParts[1] {
|
|
|
|
case "ro":
|
|
|
|
mountRW = false
|
|
|
|
case "rw": // mountRW is already true
|
|
|
|
default:
|
2014-01-23 16:41:18 -05:00
|
|
|
return fmt.Errorf("Malformed volumes-from specification: %s", containerSpec)
|
2013-12-03 17:35:54 -05:00
|
|
|
}
|
|
|
|
}
|
|
|
|
c := container.runtime.Get(specParts[0])
|
|
|
|
if c == nil {
|
|
|
|
return fmt.Errorf("Container %s not found. Impossible to mount its volumes", container.ID)
|
|
|
|
}
|
|
|
|
for volPath, id := range c.Volumes {
|
|
|
|
if _, exists := container.Volumes[volPath]; exists {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
if err := os.MkdirAll(path.Join(container.RootfsPath(), volPath), 0755); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
container.Volumes[volPath] = id
|
|
|
|
if isRW, exists := c.VolumesRW[volPath]; exists {
|
|
|
|
container.VolumesRW[volPath] = isRW && mountRW
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
2013-12-03 17:47:49 -05:00
|
|
|
return nil
|
2013-12-03 17:35:54 -05:00
|
|
|
}
|
|
|
|
|
2013-01-18 19:13:39 -05:00
|
|
|
func (container *Container) Run() error {
|
2013-10-31 17:58:43 -04:00
|
|
|
if err := container.Start(); err != nil {
|
2013-01-18 19:13:39 -05:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
container.Wait()
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) Output() (output []byte, err error) {
|
|
|
|
pipe, err := container.StdoutPipe()
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
defer pipe.Close()
|
2013-10-31 17:58:43 -04:00
|
|
|
if err := container.Start(); err != nil {
|
2013-01-18 19:13:39 -05:00
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
output, err = ioutil.ReadAll(pipe)
|
|
|
|
container.Wait()
|
|
|
|
return output, err
|
|
|
|
}
|
|
|
|
|
2013-10-16 13:41:36 -04:00
|
|
|
// Container.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".
|
|
|
|
|
2013-01-28 20:50:12 -05:00
|
|
|
func (container *Container) StdinPipe() (io.WriteCloser, error) {
|
|
|
|
return container.stdinPipe, nil
|
|
|
|
}
|
|
|
|
|
2013-01-18 19:13:39 -05:00
|
|
|
func (container *Container) StdoutPipe() (io.ReadCloser, error) {
|
|
|
|
reader, writer := io.Pipe()
|
2013-07-11 13:18:28 -04:00
|
|
|
container.stdout.AddWriter(writer, "")
|
2013-05-14 18:37:35 -04:00
|
|
|
return utils.NewBufReader(reader), nil
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) StderrPipe() (io.ReadCloser, error) {
|
|
|
|
reader, writer := io.Pipe()
|
2013-07-11 13:18:28 -04:00
|
|
|
container.stderr.AddWriter(writer, "")
|
2013-05-14 18:37:35 -04:00
|
|
|
return utils.NewBufReader(reader), nil
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
|
|
|
|
2013-10-08 17:29:22 -04:00
|
|
|
func (container *Container) buildHostnameAndHostsFiles(IP string) {
|
|
|
|
container.HostnamePath = path.Join(container.root, "hostname")
|
|
|
|
ioutil.WriteFile(container.HostnamePath, []byte(container.Config.Hostname+"\n"), 0644)
|
|
|
|
|
|
|
|
hostsContent := []byte(`
|
|
|
|
127.0.0.1 localhost
|
|
|
|
::1 localhost ip6-localhost ip6-loopback
|
|
|
|
fe00::0 ip6-localnet
|
|
|
|
ff00::0 ip6-mcastprefix
|
|
|
|
ff02::1 ip6-allnodes
|
|
|
|
ff02::2 ip6-allrouters
|
|
|
|
`)
|
|
|
|
|
|
|
|
container.HostsPath = path.Join(container.root, "hosts")
|
|
|
|
|
|
|
|
if container.Config.Domainname != "" {
|
|
|
|
hostsContent = append([]byte(fmt.Sprintf("%s\t%s.%s %s\n", IP, container.Config.Hostname, container.Config.Domainname, container.Config.Hostname)), hostsContent...)
|
2014-01-08 19:57:56 -05:00
|
|
|
} else if !container.Config.NetworkDisabled {
|
2013-10-08 17:29:22 -04:00
|
|
|
hostsContent = append([]byte(fmt.Sprintf("%s\t%s\n", IP, container.Config.Hostname)), hostsContent...)
|
|
|
|
}
|
|
|
|
|
|
|
|
ioutil.WriteFile(container.HostsPath, hostsContent, 0644)
|
|
|
|
}
|
|
|
|
|
2013-10-31 17:58:43 -04:00
|
|
|
func (container *Container) allocateNetwork() error {
|
2013-07-22 22:00:35 -04:00
|
|
|
if container.Config.NetworkDisabled {
|
2013-07-21 20:11:47 -04:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2013-11-21 15:21:03 -05:00
|
|
|
var (
|
|
|
|
iface *NetworkInterface
|
|
|
|
err error
|
|
|
|
)
|
|
|
|
if container.State.IsGhost() {
|
|
|
|
if manager := container.runtime.networkManager; manager.disabled {
|
2013-08-21 10:37:58 -04:00
|
|
|
iface = &NetworkInterface{disabled: true}
|
|
|
|
} else {
|
|
|
|
iface = &NetworkInterface{
|
2013-08-29 18:21:32 -04:00
|
|
|
IPNet: net.IPNet{IP: net.ParseIP(container.NetworkSettings.IPAddress), Mask: manager.bridgeNetwork.Mask},
|
2013-08-21 10:37:58 -04:00
|
|
|
Gateway: manager.bridgeNetwork.IP,
|
|
|
|
manager: manager,
|
2013-08-29 18:21:32 -04:00
|
|
|
}
|
2013-11-07 15:19:24 -05:00
|
|
|
if iface != nil && iface.IPNet.IP != nil {
|
2014-01-23 04:31:38 -05:00
|
|
|
if _, err := ipallocator.RequestIP(manager.bridgeNetwork, &iface.IPNet.IP); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2013-10-27 09:04:57 -04:00
|
|
|
} else {
|
|
|
|
iface, err = container.runtime.networkManager.Allocate()
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
iface, err = container.runtime.networkManager.Allocate()
|
|
|
|
if err != nil {
|
|
|
|
return err
|
2013-08-21 10:37:58 -04:00
|
|
|
}
|
2013-02-25 17:06:22 -05:00
|
|
|
}
|
2013-08-21 10:37:58 -04:00
|
|
|
|
2013-10-04 22:25:15 -04:00
|
|
|
if container.Config.PortSpecs != nil {
|
|
|
|
utils.Debugf("Migrating port mappings for container: %s", strings.Join(container.Config.PortSpecs, ", "))
|
2013-10-31 17:58:43 -04:00
|
|
|
if err := migratePortMappings(container.Config, container.hostConfig); err != nil {
|
2013-10-04 22:25:15 -04:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
container.Config.PortSpecs = nil
|
2013-10-31 17:58:43 -04:00
|
|
|
if err := container.writeHostConfig(); err != nil {
|
2013-10-30 11:15:12 -04:00
|
|
|
return err
|
|
|
|
}
|
2013-10-04 22:25:15 -04:00
|
|
|
}
|
|
|
|
|
2013-11-21 15:21:03 -05:00
|
|
|
var (
|
|
|
|
portSpecs = make(map[Port]struct{})
|
|
|
|
bindings = make(map[Port][]PortBinding)
|
|
|
|
)
|
2013-10-04 22:25:15 -04:00
|
|
|
|
2013-11-21 15:21:03 -05:00
|
|
|
if !container.State.IsGhost() {
|
2013-10-04 22:25:15 -04:00
|
|
|
if container.Config.ExposedPorts != nil {
|
|
|
|
portSpecs = container.Config.ExposedPorts
|
2013-08-27 15:14:21 -04:00
|
|
|
}
|
2013-10-31 17:58:43 -04:00
|
|
|
if container.hostConfig.PortBindings != nil {
|
|
|
|
bindings = container.hostConfig.PortBindings
|
2013-10-04 22:25:15 -04:00
|
|
|
}
|
|
|
|
} else {
|
|
|
|
if container.NetworkSettings.Ports != nil {
|
|
|
|
for port, binding := range container.NetworkSettings.Ports {
|
|
|
|
portSpecs[port] = struct{}{}
|
|
|
|
bindings[port] = binding
|
|
|
|
}
|
2013-08-27 15:14:21 -04:00
|
|
|
}
|
2013-02-25 17:06:22 -05:00
|
|
|
}
|
2013-08-27 15:14:21 -04:00
|
|
|
|
2013-10-04 22:25:15 -04:00
|
|
|
container.NetworkSettings.PortMapping = nil
|
|
|
|
|
|
|
|
for port := range portSpecs {
|
|
|
|
binding := bindings[port]
|
2013-11-01 17:01:32 -04:00
|
|
|
if container.hostConfig.PublishAllPorts && len(binding) == 0 {
|
2013-10-31 14:10:25 -04:00
|
|
|
binding = append(binding, PortBinding{})
|
|
|
|
}
|
2013-10-04 22:25:15 -04:00
|
|
|
for i := 0; i < len(binding); i++ {
|
|
|
|
b := binding[i]
|
|
|
|
nat, err := iface.AllocatePort(port, b)
|
|
|
|
if err != nil {
|
|
|
|
iface.Release()
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
utils.Debugf("Allocate port: %s:%s->%s", nat.Binding.HostIp, port, nat.Binding.HostPort)
|
|
|
|
binding[i] = nat.Binding
|
2013-02-28 14:51:14 -05:00
|
|
|
}
|
2013-10-04 22:25:15 -04:00
|
|
|
bindings[port] = binding
|
2013-02-28 14:51:14 -05:00
|
|
|
}
|
2013-10-31 17:58:43 -04:00
|
|
|
container.writeHostConfig()
|
2013-10-04 22:25:15 -04:00
|
|
|
|
|
|
|
container.NetworkSettings.Ports = bindings
|
2013-02-25 17:06:22 -05:00
|
|
|
container.network = iface
|
2013-10-04 22:25:15 -04:00
|
|
|
|
2013-04-03 18:05:03 -04:00
|
|
|
container.NetworkSettings.Bridge = container.runtime.networkManager.bridgeIface
|
2013-06-04 14:00:22 -04:00
|
|
|
container.NetworkSettings.IPAddress = iface.IPNet.IP.String()
|
|
|
|
container.NetworkSettings.IPPrefixLen, _ = iface.IPNet.Mask.Size()
|
2013-02-28 14:51:14 -05:00
|
|
|
container.NetworkSettings.Gateway = iface.Gateway.String()
|
2013-10-04 22:25:15 -04:00
|
|
|
|
2013-02-25 17:06:22 -05:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2013-04-01 01:04:59 -04:00
|
|
|
func (container *Container) releaseNetwork() {
|
2013-10-16 17:39:03 -04:00
|
|
|
if container.Config.NetworkDisabled || container.network == nil {
|
2013-07-21 20:11:47 -04:00
|
|
|
return
|
|
|
|
}
|
2013-03-30 18:32:10 -04:00
|
|
|
container.network.Release()
|
2013-02-25 17:06:22 -05:00
|
|
|
container.network = nil
|
2013-02-28 14:51:14 -05:00
|
|
|
container.NetworkSettings = &NetworkSettings{}
|
2013-01-26 18:56:42 -05:00
|
|
|
}
|
|
|
|
|
2014-01-13 19:41:35 -05:00
|
|
|
func (container *Container) monitor(callback execdriver.StartCallback) error {
|
2014-01-13 18:02:12 -05:00
|
|
|
var (
|
|
|
|
err error
|
|
|
|
exitCode int
|
|
|
|
)
|
|
|
|
|
2014-01-20 19:05:07 -05:00
|
|
|
if container.command == nil {
|
2014-01-13 18:02:12 -05:00
|
|
|
// This happends when you have a GHOST container with lxc
|
2014-01-20 21:43:54 -05:00
|
|
|
populateCommand(container)
|
|
|
|
err = container.runtime.RestoreCommand(container)
|
2014-01-10 18:06:16 -05:00
|
|
|
} else {
|
2014-01-13 18:37:17 -05:00
|
|
|
exitCode, err = container.runtime.Run(container, callback)
|
2014-01-10 18:06:16 -05:00
|
|
|
}
|
|
|
|
|
2014-01-13 19:41:35 -05:00
|
|
|
if err != nil {
|
2014-01-21 19:18:57 -05:00
|
|
|
utils.Errorf("Error running container: %s", err)
|
2013-09-20 16:36:19 -04:00
|
|
|
}
|
|
|
|
|
2013-01-22 18:03:40 -05:00
|
|
|
// Cleanup
|
2013-10-16 15:01:55 -04:00
|
|
|
container.cleanup()
|
|
|
|
|
|
|
|
// Re-create a brand new stdin pipe once the container exited
|
|
|
|
if container.Config.OpenStdin {
|
|
|
|
container.stdin, container.stdinPipe = io.Pipe()
|
|
|
|
}
|
|
|
|
|
2014-01-09 21:48:34 -05:00
|
|
|
container.State.SetStopped(exitCode)
|
|
|
|
|
2014-01-21 19:18:57 -05:00
|
|
|
if container.runtime != nil && container.runtime.srv != nil {
|
|
|
|
container.runtime.srv.LogEvent("die", container.ID, container.runtime.repositories.ImageName(container.Image))
|
|
|
|
}
|
|
|
|
|
2014-01-10 20:25:32 -05:00
|
|
|
close(container.waitLock)
|
|
|
|
|
2014-01-13 19:41:35 -05:00
|
|
|
// FIXME: there is a race condition here which causes this to fail during the unit tests.
|
|
|
|
// If another goroutine was waiting for Wait() to return before removing the container's root
|
|
|
|
// from the filesystem... At this point it may already have done so.
|
|
|
|
// This is because State.setStopped() has already been called, and has caused Wait()
|
|
|
|
// to return.
|
|
|
|
// FIXME: why are we serializing running state to disk in the first place?
|
|
|
|
//log.Printf("%s: Failed to dump configuration to the disk: %s", container.ID, err)
|
|
|
|
container.ToDisk()
|
|
|
|
|
|
|
|
return err
|
2013-10-16 15:01:55 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) cleanup() {
|
2013-03-30 18:32:10 -04:00
|
|
|
container.releaseNetwork()
|
2013-10-04 22:25:15 -04:00
|
|
|
|
|
|
|
// Disable all active links
|
|
|
|
if container.activeLinks != nil {
|
|
|
|
for _, link := range container.activeLinks {
|
|
|
|
link.Disable()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2013-03-30 12:08:53 -04:00
|
|
|
if container.Config.OpenStdin {
|
|
|
|
if err := container.stdin.Close(); err != nil {
|
2013-10-08 03:54:47 -04:00
|
|
|
utils.Errorf("%s: Error close stdin: %s", container.ID, err)
|
2013-03-30 12:08:53 -04:00
|
|
|
}
|
|
|
|
}
|
2013-04-02 04:45:17 -04:00
|
|
|
if err := container.stdout.CloseWriters(); err != nil {
|
2013-10-08 03:54:47 -04:00
|
|
|
utils.Errorf("%s: Error close stdout: %s", container.ID, err)
|
2013-03-29 11:29:59 -04:00
|
|
|
}
|
2013-04-02 04:45:17 -04:00
|
|
|
if err := container.stderr.CloseWriters(); err != nil {
|
2013-10-08 03:54:47 -04:00
|
|
|
utils.Errorf("%s: Error close stderr: %s", container.ID, err)
|
2013-03-29 11:29:59 -04:00
|
|
|
}
|
2013-03-30 12:05:53 -04:00
|
|
|
|
2013-04-04 15:12:22 -04:00
|
|
|
if container.ptyMaster != nil {
|
|
|
|
if err := container.ptyMaster.Close(); err != nil {
|
2013-10-08 03:54:47 -04:00
|
|
|
utils.Errorf("%s: Error closing Pty master: %s", container.ID, err)
|
2013-03-30 12:05:53 -04:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2013-03-21 03:25:00 -04:00
|
|
|
if err := container.Unmount(); err != nil {
|
2013-06-04 14:00:22 -04:00
|
|
|
log.Printf("%v: Failed to umount filesystem: %v", container.ID, err)
|
2013-01-21 21:03:23 -05:00
|
|
|
}
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
|
|
|
|
2013-09-12 02:50:26 -04:00
|
|
|
func (container *Container) kill(sig int) error {
|
2013-11-21 15:21:03 -05:00
|
|
|
container.Lock()
|
|
|
|
defer container.Unlock()
|
2013-10-08 15:15:29 -04:00
|
|
|
|
2013-11-21 15:21:03 -05:00
|
|
|
if !container.State.IsRunning() {
|
2013-03-23 22:51:35 -04:00
|
|
|
return nil
|
|
|
|
}
|
2014-01-10 17:26:29 -05:00
|
|
|
return container.runtime.Kill(container, sig)
|
2013-10-08 15:15:29 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) Kill() error {
|
2013-11-21 15:21:03 -05:00
|
|
|
if !container.State.IsRunning() {
|
2013-10-08 15:15:29 -04:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// 1. Send SIGKILL
|
|
|
|
if err := container.kill(9); err != nil {
|
|
|
|
return err
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
2013-04-11 12:02:34 -04:00
|
|
|
|
|
|
|
// 2. Wait for the process to die, in last resort, try to kill the process directly
|
|
|
|
if err := container.WaitTimeout(10 * time.Second); err != nil {
|
2014-01-20 19:05:07 -05:00
|
|
|
if container.command == nil {
|
2013-10-24 21:59:59 -04:00
|
|
|
return fmt.Errorf("lxc-kill failed, impossible to kill the container %s", utils.TruncateID(container.ID))
|
2013-04-19 15:12:30 -04:00
|
|
|
}
|
2013-10-24 21:59:59 -04:00
|
|
|
log.Printf("Container %s failed to exit within 10 seconds of lxc-kill %s - trying direct SIGKILL", "SIGKILL", utils.TruncateID(container.ID))
|
2014-01-10 17:26:29 -05:00
|
|
|
if err := container.runtime.Kill(container, 9); err != nil {
|
2013-04-11 12:02:34 -04:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2013-01-22 20:30:09 -05:00
|
|
|
container.Wait()
|
2013-01-21 21:03:23 -05:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2013-04-16 12:43:44 -04:00
|
|
|
func (container *Container) Stop(seconds int) error {
|
2013-11-21 15:21:03 -05:00
|
|
|
if !container.State.IsRunning() {
|
2013-01-18 19:13:39 -05:00
|
|
|
return nil
|
|
|
|
}
|
2013-01-21 21:03:23 -05:00
|
|
|
|
|
|
|
// 1. Send a SIGTERM
|
2013-10-08 15:15:29 -04:00
|
|
|
if err := container.kill(15); err != nil {
|
|
|
|
utils.Debugf("Error sending kill SIGTERM: %s", err)
|
2013-03-30 03:23:12 -04:00
|
|
|
log.Print("Failed to send SIGTERM to the process, force killing")
|
2013-09-12 02:50:26 -04:00
|
|
|
if err := container.kill(9); err != nil {
|
2013-01-25 18:36:47 -05:00
|
|
|
return err
|
|
|
|
}
|
2013-01-21 21:03:23 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
// 2. Wait for the process to exit on its own
|
2013-04-16 12:43:44 -04:00
|
|
|
if err := container.WaitTimeout(time.Duration(seconds) * time.Second); err != nil {
|
2013-06-04 14:00:22 -04:00
|
|
|
log.Printf("Container %v failed to exit within %d seconds of SIGTERM - using the force", container.ID, seconds)
|
2013-10-08 15:15:29 -04:00
|
|
|
// 3. If it doesn't, then send SIGKILL
|
|
|
|
if err := container.Kill(); err != nil {
|
2013-01-25 18:36:47 -05:00
|
|
|
return err
|
|
|
|
}
|
2013-01-21 21:03:23 -05:00
|
|
|
}
|
2013-01-18 19:13:39 -05:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2013-04-16 12:43:44 -04:00
|
|
|
func (container *Container) Restart(seconds int) error {
|
|
|
|
if err := container.Stop(seconds); err != nil {
|
2013-01-22 18:03:40 -05:00
|
|
|
return err
|
|
|
|
}
|
2013-10-31 17:58:43 -04:00
|
|
|
return container.Start()
|
2013-01-22 18:03:40 -05:00
|
|
|
}
|
|
|
|
|
2013-02-26 14:43:54 -05:00
|
|
|
// Wait blocks until the container stops running, then returns its exit code.
|
|
|
|
func (container *Container) Wait() int {
|
2014-01-10 18:34:03 -05:00
|
|
|
<-container.waitLock
|
|
|
|
return container.State.GetExitCode()
|
2013-01-18 19:13:39 -05:00
|
|
|
}
|
2013-01-21 21:03:23 -05:00
|
|
|
|
2013-05-23 22:33:28 -04:00
|
|
|
func (container *Container) Resize(h, w int) error {
|
2013-05-24 17:44:16 -04:00
|
|
|
pty, ok := container.ptyMaster.(*os.File)
|
|
|
|
if !ok {
|
|
|
|
return fmt.Errorf("ptyMaster does not have Fd() method")
|
|
|
|
}
|
|
|
|
return term.SetWinsize(pty.Fd(), &term.Winsize{Height: uint16(h), Width: uint16(w)})
|
2013-05-23 22:33:28 -04:00
|
|
|
}
|
|
|
|
|
2013-10-31 19:57:45 -04:00
|
|
|
func (container *Container) ExportRw() (archive.Archive, error) {
|
2013-12-06 06:15:14 -05:00
|
|
|
if err := container.Mount(); err != nil {
|
2013-11-07 21:48:52 -05:00
|
|
|
return nil, err
|
|
|
|
}
|
2013-11-07 15:34:01 -05:00
|
|
|
if container.runtime == nil {
|
|
|
|
return nil, fmt.Errorf("Can't load storage driver for unregistered container %s", container.ID)
|
2013-04-19 11:25:55 -04:00
|
|
|
}
|
2013-12-05 16:18:02 -05:00
|
|
|
defer container.Unmount()
|
2013-11-11 10:47:36 -05:00
|
|
|
|
|
|
|
return container.runtime.Diff(container)
|
2013-04-19 11:25:55 -04:00
|
|
|
}
|
|
|
|
|
2013-10-31 19:57:45 -04:00
|
|
|
func (container *Container) Export() (archive.Archive, error) {
|
2013-12-06 06:15:14 -05:00
|
|
|
if err := container.Mount(); err != nil {
|
2013-03-21 03:25:00 -04:00
|
|
|
return nil, err
|
|
|
|
}
|
2013-12-05 16:18:02 -05:00
|
|
|
|
|
|
|
archive, err := archive.Tar(container.RootfsPath(), archive.Uncompressed)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
return EofReader(archive, func() { container.Unmount() }), nil
|
2013-03-21 03:25:00 -04:00
|
|
|
}
|
|
|
|
|
2013-01-21 21:03:23 -05:00
|
|
|
func (container *Container) WaitTimeout(timeout time.Duration) error {
|
|
|
|
done := make(chan bool)
|
|
|
|
go func() {
|
|
|
|
container.Wait()
|
|
|
|
done <- true
|
|
|
|
}()
|
|
|
|
|
|
|
|
select {
|
|
|
|
case <-time.After(timeout):
|
2013-03-29 11:19:42 -04:00
|
|
|
return fmt.Errorf("Timed Out")
|
2013-01-21 21:03:23 -05:00
|
|
|
case <-done:
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
}
|
2013-03-21 03:25:00 -04:00
|
|
|
|
|
|
|
func (container *Container) Mount() error {
|
2013-10-31 21:07:54 -04:00
|
|
|
return container.runtime.Mount(container)
|
2013-03-21 03:25:00 -04:00
|
|
|
}
|
|
|
|
|
2013-11-07 19:35:26 -05:00
|
|
|
func (container *Container) Changes() ([]archive.Change, error) {
|
2013-10-31 21:07:54 -04:00
|
|
|
return container.runtime.Changes(container)
|
2013-03-21 03:25:00 -04:00
|
|
|
}
|
|
|
|
|
2013-03-21 20:47:23 -04:00
|
|
|
func (container *Container) GetImage() (*Image, error) {
|
2013-03-21 03:25:00 -04:00
|
|
|
if container.runtime == nil {
|
|
|
|
return nil, fmt.Errorf("Can't get image of unregistered container")
|
|
|
|
}
|
|
|
|
return container.runtime.graph.Get(container.Image)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) Unmount() error {
|
2013-12-18 19:42:49 -05:00
|
|
|
var (
|
|
|
|
err error
|
|
|
|
root = container.RootfsPath()
|
|
|
|
mounts = []string{
|
|
|
|
path.Join(root, "/.dockerinit"),
|
|
|
|
path.Join(root, "/.dockerenv"),
|
|
|
|
path.Join(root, "/etc/resolv.conf"),
|
|
|
|
}
|
|
|
|
)
|
|
|
|
|
|
|
|
if container.HostnamePath != "" && container.HostsPath != "" {
|
|
|
|
mounts = append(mounts, path.Join(root, "/etc/hostname"), path.Join(root, "/etc/hosts"))
|
2013-12-17 17:04:37 -05:00
|
|
|
}
|
2013-12-18 19:42:49 -05:00
|
|
|
|
|
|
|
for r := range container.Volumes {
|
|
|
|
mounts = append(mounts, path.Join(root, r))
|
|
|
|
}
|
|
|
|
|
2014-01-27 12:19:38 -05:00
|
|
|
for i := len(mounts) - 1; i >= 0; i-- {
|
|
|
|
if lastError := mount.Unmount(mounts[i]); lastError != nil {
|
|
|
|
err = fmt.Errorf("Failed to umount %v: %v", mounts[i], lastError)
|
2013-12-17 17:04:37 -05:00
|
|
|
}
|
|
|
|
}
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2013-10-31 21:07:54 -04:00
|
|
|
return container.runtime.Unmount(container)
|
2013-03-21 03:25:00 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) logPath(name string) string {
|
2013-06-04 14:00:22 -04:00
|
|
|
return path.Join(container.root, fmt.Sprintf("%s-%s.log", container.ID, name))
|
2013-03-21 03:25:00 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
func (container *Container) ReadLog(name string) (io.Reader, error) {
|
|
|
|
return os.Open(container.logPath(name))
|
|
|
|
}
|
|
|
|
|
2013-07-02 08:19:25 -04:00
|
|
|
func (container *Container) hostConfigPath() string {
|
2013-07-02 13:02:42 -04:00
|
|
|
return path.Join(container.root, "hostconfig.json")
|
2013-07-02 08:19:25 -04:00
|
|
|
}
|
|
|
|
|
2013-03-21 03:25:00 -04:00
|
|
|
func (container *Container) jsonPath() string {
|
|
|
|
return path.Join(container.root, "config.json")
|
|
|
|
}
|
|
|
|
|
2013-12-17 17:04:37 -05:00
|
|
|
func (container *Container) EnvConfigPath() (string, error) {
|
|
|
|
p := path.Join(container.root, "config.env")
|
|
|
|
if _, err := os.Stat(p); err != nil {
|
|
|
|
if os.IsNotExist(err) {
|
|
|
|
f, err := os.Create(p)
|
|
|
|
if err != nil {
|
|
|
|
return "", err
|
|
|
|
}
|
|
|
|
f.Close()
|
|
|
|
} else {
|
|
|
|
return "", err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return p, nil
|
2013-08-13 18:40:23 -04:00
|
|
|
}
|
|
|
|
|
2013-03-21 03:25:00 -04:00
|
|
|
// This method must be exported to be used from the lxc template
|
|
|
|
func (container *Container) RootfsPath() string {
|
2013-11-07 15:34:01 -05:00
|
|
|
return container.rootfs
|
2013-03-21 03:25:00 -04:00
|
|
|
}
|
|
|
|
|
2013-06-04 14:00:22 -04:00
|
|
|
func validateID(id string) error {
|
2013-03-21 03:25:00 -04:00
|
|
|
if id == "" {
|
|
|
|
return fmt.Errorf("Invalid empty id")
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|
2013-05-13 09:10:26 -04:00
|
|
|
|
|
|
|
// GetSize, return real size, virtual size
|
|
|
|
func (container *Container) GetSize() (int64, int64) {
|
2013-11-11 15:09:26 -05:00
|
|
|
var (
|
|
|
|
sizeRw, sizeRootfs int64
|
|
|
|
err error
|
|
|
|
driver = container.runtime.driver
|
|
|
|
)
|
2013-05-13 09:10:26 -04:00
|
|
|
|
2013-12-06 06:15:14 -05:00
|
|
|
if err := container.Mount(); err != nil {
|
2013-11-07 15:30:56 -05:00
|
|
|
utils.Errorf("Warning: failed to compute size of container rootfs %s: %s", container.ID, err)
|
|
|
|
return sizeRw, sizeRootfs
|
|
|
|
}
|
2013-12-05 16:18:02 -05:00
|
|
|
defer container.Unmount()
|
2013-11-19 04:36:54 -05:00
|
|
|
|
|
|
|
if differ, ok := container.runtime.driver.(graphdriver.Differ); ok {
|
|
|
|
sizeRw, err = differ.DiffSize(container.ID)
|
|
|
|
if err != nil {
|
|
|
|
utils.Errorf("Warning: driver %s couldn't return diff size of container %s: %s", driver, container.ID, err)
|
|
|
|
// FIXME: GetSize should return an error. Not changing it now in case
|
|
|
|
// there is a side-effect.
|
|
|
|
sizeRw = -1
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
changes, _ := container.Changes()
|
|
|
|
if changes != nil {
|
|
|
|
sizeRw = archive.ChangesSize(container.RootfsPath(), changes)
|
|
|
|
} else {
|
|
|
|
sizeRw = -1
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2013-11-20 17:51:04 -05:00
|
|
|
if _, err = os.Stat(container.RootfsPath()); err != nil {
|
2013-11-21 20:18:41 -05:00
|
|
|
if sizeRootfs, err = utils.TreeSize(container.RootfsPath()); err != nil {
|
|
|
|
sizeRootfs = -1
|
2013-05-13 09:10:26 -04:00
|
|
|
}
|
|
|
|
}
|
|
|
|
return sizeRw, sizeRootfs
|
|
|
|
}
|
2013-07-17 00:07:41 -04:00
|
|
|
|
2013-10-31 19:57:45 -04:00
|
|
|
func (container *Container) Copy(resource string) (archive.Archive, error) {
|
2013-12-06 06:15:14 -05:00
|
|
|
if err := container.Mount(); err != nil {
|
2013-07-17 00:07:41 -04:00
|
|
|
return nil, err
|
|
|
|
}
|
2013-07-17 10:25:49 -04:00
|
|
|
var filter []string
|
|
|
|
basePath := path.Join(container.RootfsPath(), resource)
|
|
|
|
stat, err := os.Stat(basePath)
|
|
|
|
if err != nil {
|
2013-12-05 16:18:02 -05:00
|
|
|
container.Unmount()
|
2013-07-17 10:25:49 -04:00
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
if !stat.IsDir() {
|
|
|
|
d, f := path.Split(basePath)
|
|
|
|
basePath = d
|
|
|
|
filter = []string{f}
|
|
|
|
} else {
|
|
|
|
filter = []string{path.Base(basePath)}
|
|
|
|
basePath = path.Dir(basePath)
|
|
|
|
}
|
2013-12-05 16:18:02 -05:00
|
|
|
|
|
|
|
archive, err := archive.TarFilter(basePath, &archive.TarOptions{
|
2013-11-11 17:30:38 -05:00
|
|
|
Compression: archive.Uncompressed,
|
|
|
|
Includes: filter,
|
|
|
|
})
|
2013-12-05 16:18:02 -05:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
return EofReader(archive, func() { container.Unmount() }), nil
|
2013-07-17 00:07:41 -04:00
|
|
|
}
|
2013-10-04 22:25:15 -04:00
|
|
|
|
|
|
|
// Returns true if the container exposes a certain port
|
|
|
|
func (container *Container) Exposes(p Port) bool {
|
|
|
|
_, exists := container.Config.ExposedPorts[p]
|
|
|
|
return exists
|
|
|
|
}
|
2013-11-29 10:40:44 -05:00
|
|
|
|
|
|
|
func (container *Container) GetPtyMaster() (*os.File, error) {
|
|
|
|
if container.ptyMaster == nil {
|
|
|
|
return nil, ErrNoTTY
|
|
|
|
}
|
|
|
|
if pty, ok := container.ptyMaster.(*os.File); ok {
|
|
|
|
return pty, nil
|
|
|
|
}
|
|
|
|
return nil, ErrNotATTY
|
|
|
|
}
|