mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
Add stderr log ouput if in debug
Docker-DCO-1.1-Signed-off-by: Michael Crosby <michael@crosbymichael.com> (github: crosbymichael)
This commit is contained in:
parent
7294392c72
commit
0e863a584a
4 changed files with 19 additions and 8 deletions
|
@ -9,6 +9,7 @@ import (
|
||||||
"github.com/dotcloud/docker/pkg/libcontainer/apparmor"
|
"github.com/dotcloud/docker/pkg/libcontainer/apparmor"
|
||||||
"github.com/dotcloud/docker/pkg/libcontainer/nsinit"
|
"github.com/dotcloud/docker/pkg/libcontainer/nsinit"
|
||||||
"github.com/dotcloud/docker/pkg/system"
|
"github.com/dotcloud/docker/pkg/system"
|
||||||
|
"io"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"log"
|
"log"
|
||||||
"os"
|
"os"
|
||||||
|
@ -28,8 +29,7 @@ func init() {
|
||||||
execdriver.RegisterInitFunc(DriverName, func(args *execdriver.InitArgs) error {
|
execdriver.RegisterInitFunc(DriverName, func(args *execdriver.InitArgs) error {
|
||||||
var (
|
var (
|
||||||
container *libcontainer.Container
|
container *libcontainer.Container
|
||||||
logger = log.New(ioutil.Discard, "[nsinit] ", log.LstdFlags)
|
ns = nsinit.NewNsInit(&nsinit.DefaultCommandFactory{}, &nsinit.DefaultStateWriter{args.Root}, createLogger(""))
|
||||||
ns = nsinit.NewNsInit(&nsinit.DefaultCommandFactory{}, &nsinit.DefaultStateWriter{args.Root}, logger)
|
|
||||||
)
|
)
|
||||||
f, err := os.Open(filepath.Join(args.Root, "container.json"))
|
f, err := os.Open(filepath.Join(args.Root, "container.json"))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -87,9 +87,8 @@ func (d *driver) Run(c *execdriver.Command, pipes *execdriver.Pipes, startCallba
|
||||||
c: c,
|
c: c,
|
||||||
dsw: &nsinit.DefaultStateWriter{filepath.Join(d.root, c.ID)},
|
dsw: &nsinit.DefaultStateWriter{filepath.Join(d.root, c.ID)},
|
||||||
}
|
}
|
||||||
logger = log.New(ioutil.Discard, "[nsinit] ", log.LstdFlags)
|
ns = nsinit.NewNsInit(factory, stateWriter, createLogger(os.Getenv("DEBUG")))
|
||||||
ns = nsinit.NewNsInit(factory, stateWriter, logger)
|
args = append([]string{c.Entrypoint}, c.Arguments...)
|
||||||
args = append([]string{c.Entrypoint}, c.Arguments...)
|
|
||||||
)
|
)
|
||||||
if err := d.createContainerRoot(c.ID); err != nil {
|
if err := d.createContainerRoot(c.ID); err != nil {
|
||||||
return -1, err
|
return -1, err
|
||||||
|
@ -254,3 +253,14 @@ func (d *dockerStateWriter) WritePid(pid int) error {
|
||||||
func (d *dockerStateWriter) DeletePid() error {
|
func (d *dockerStateWriter) DeletePid() error {
|
||||||
return d.dsw.DeletePid()
|
return d.dsw.DeletePid()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func createLogger(debug string) *log.Logger {
|
||||||
|
var w io.Writer
|
||||||
|
// if we are in debug mode set the logger to stderr
|
||||||
|
if debug != "" {
|
||||||
|
w = os.Stderr
|
||||||
|
} else {
|
||||||
|
w = ioutil.Discard
|
||||||
|
}
|
||||||
|
return log.New(w, "[libcontainer] ", log.LstdFlags)
|
||||||
|
}
|
||||||
|
|
|
@ -1,7 +1,6 @@
|
||||||
package nsinit
|
package nsinit
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"github.com/dotcloud/docker/pkg/libcontainer"
|
"github.com/dotcloud/docker/pkg/libcontainer"
|
||||||
"github.com/dotcloud/docker/pkg/system"
|
"github.com/dotcloud/docker/pkg/system"
|
||||||
"os"
|
"os"
|
||||||
|
@ -26,7 +25,7 @@ func (c *DefaultCommandFactory) Create(container *libcontainer.Container, consol
|
||||||
// get our binary name from arg0 so we can always reexec ourself
|
// get our binary name from arg0 so we can always reexec ourself
|
||||||
command := exec.Command(os.Args[0], append([]string{
|
command := exec.Command(os.Args[0], append([]string{
|
||||||
"-console", console,
|
"-console", console,
|
||||||
"-pipe", fmt.Sprint(pipe.Fd()),
|
"-pipe", "3",
|
||||||
"-root", c.Root,
|
"-root", c.Root,
|
||||||
"init"}, args...)...)
|
"init"}, args...)...)
|
||||||
|
|
||||||
|
|
|
@ -26,6 +26,7 @@ func (ns *linuxNs) Exec(container *libcontainer.Container, term Terminal, args [
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return -1, err
|
return -1, err
|
||||||
}
|
}
|
||||||
|
ns.logger.Printf("created sync pipe parent fd %d child fd %d\n", syncPipe.parent.Fd(), syncPipe.child.Fd())
|
||||||
|
|
||||||
if container.Tty {
|
if container.Tty {
|
||||||
ns.logger.Println("creating master and console")
|
ns.logger.Println("creating master and console")
|
||||||
|
|
|
@ -24,6 +24,7 @@ func (ns *linuxNs) Init(container *libcontainer.Container, uncleanRootfs, consol
|
||||||
}
|
}
|
||||||
|
|
||||||
// We always read this as it is a way to sync with the parent as well
|
// We always read this as it is a way to sync with the parent as well
|
||||||
|
ns.logger.Printf("reading from sync pipe fd %d\n", syncPipe.child.Fd())
|
||||||
context, err := syncPipe.ReadFromParent()
|
context, err := syncPipe.ReadFromParent()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
syncPipe.Close()
|
syncPipe.Close()
|
||||||
|
@ -68,7 +69,7 @@ func (ns *linuxNs) Init(container *libcontainer.Container, uncleanRootfs, consol
|
||||||
}
|
}
|
||||||
|
|
||||||
if profile := container.Context["apparmor_profile"]; profile != "" {
|
if profile := container.Context["apparmor_profile"]; profile != "" {
|
||||||
ns.logger.Printf("setting apparmor prifile %s\n", profile)
|
ns.logger.Printf("setting apparmor profile %s\n", profile)
|
||||||
if err := apparmor.ApplyProfile(os.Getpid(), profile); err != nil {
|
if err := apparmor.ApplyProfile(os.Getpid(), profile); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Reference in a new issue