494e7dcbd4
This code only works for backends that directly spawn the child via the Command. It will not work for the libvirt backend. So we move this code into the individual backends that need it. Docker-DCO-1.1-Signed-off-by: Alexander Larsson <alexl@redhat.com> (github: alexlarsson) Upstream-commit: 9ad70528b723810d98e77368458408e85eebdfee Component: engine
98 lines
1.8 KiB
Go
98 lines
1.8 KiB
Go
package chroot
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/dotcloud/docker/execdriver"
|
|
"github.com/dotcloud/docker/pkg/mount"
|
|
"os"
|
|
"os/exec"
|
|
"syscall"
|
|
)
|
|
|
|
const (
|
|
DriverName = "chroot"
|
|
Version = "0.1"
|
|
)
|
|
|
|
func init() {
|
|
execdriver.RegisterInitFunc(DriverName, func(args *execdriver.InitArgs) error {
|
|
if err := mount.ForceMount("proc", "proc", "proc", ""); err != nil {
|
|
return err
|
|
}
|
|
defer mount.ForceUnmount("proc")
|
|
cmd := exec.Command(args.Args[0], args.Args[1:]...)
|
|
|
|
cmd.Stderr = os.Stderr
|
|
cmd.Stdout = os.Stdout
|
|
cmd.Stdin = os.Stdin
|
|
|
|
return cmd.Run()
|
|
})
|
|
}
|
|
|
|
type driver struct {
|
|
}
|
|
|
|
func NewDriver() (*driver, error) {
|
|
return &driver{}, nil
|
|
}
|
|
|
|
func (d *driver) Run(c *execdriver.Command, startCallback execdriver.StartCallback) (int, error) {
|
|
params := []string{
|
|
"chroot",
|
|
c.Rootfs,
|
|
"/.dockerinit",
|
|
"-driver",
|
|
DriverName,
|
|
}
|
|
params = append(params, c.Entrypoint)
|
|
params = append(params, c.Arguments...)
|
|
|
|
var (
|
|
name = params[0]
|
|
arg = params[1:]
|
|
)
|
|
aname, err := exec.LookPath(name)
|
|
if err != nil {
|
|
aname = name
|
|
}
|
|
c.Path = aname
|
|
c.Args = append([]string{name}, arg...)
|
|
|
|
if err := c.Start(); err != nil {
|
|
return -1, err
|
|
}
|
|
|
|
if startCallback != nil {
|
|
startCallback(c)
|
|
}
|
|
|
|
err = c.Wait()
|
|
return getExitCode(c), err
|
|
}
|
|
|
|
/// Return the exit code of the process
|
|
// if the process has not exited -1 will be returned
|
|
func getExitCode(c *execdriver.Command) int {
|
|
if c.ProcessState == nil {
|
|
return -1
|
|
}
|
|
return c.ProcessState.Sys().(syscall.WaitStatus).ExitStatus()
|
|
}
|
|
|
|
func (d *driver) Kill(p *execdriver.Command, sig int) error {
|
|
return p.Process.Kill()
|
|
}
|
|
|
|
func (d *driver) Restore(c *execdriver.Command) error {
|
|
panic("Not Implemented")
|
|
}
|
|
|
|
func (d *driver) Info(id string) execdriver.Info {
|
|
panic("Not implemented")
|
|
}
|
|
|
|
func (d *driver) Name() string {
|
|
return fmt.Sprintf("%s-%s", DriverName, Version)
|
|
}
|