Fix leak in logging and proc pipes

Signed-off-by: Michael Crosby <crosbymichael@gmail.com>

delete.go

@@ -14,8 +14,10 @@ func (h *DeleteEvent) Handle(e *Event) error {
 		if err := h.deleteContainer(i.container); err != nil {
 			logrus.WithField("error", err).Error("containerd: deleting container")
 		}
-		if err := i.logger.Close(); err != nil {
-			logrus.WithField("error", err).Error("containerd: close container logger")
+		if i.logger != nil {
+			if err := i.logger.Close(); err != nil {
+				logrus.WithField("error", err).Error("containerd: close container logger")
+			}
 		}
 		h.s.notifySubscribers(&Event{
 			Type:   ExitEventType,

linux/linux.go

@@ -5,6 +5,7 @@ package linux
 import (
 	"encoding/json"
 	"fmt"
+	"io"
 	"io/ioutil"
 	"os"
 	"path/filepath"
@@ -184,6 +185,15 @@ func (p *libcontainerProcess) Signal(s os.Signal) error {
 	return p.process.Signal(s)
 }
 
+func (p *libcontainerProcess) Close() error {
+	// in close we always need to call wait to close/flush any pipes
+	_, err := p.process.Wait()
+	p.process.Stdin.(io.Closer).Close()
+	p.process.Stdout.(io.Closer).Close()
+	p.process.Stderr.(io.Closer).Close()
+	return err
+}
+
 type libcontainerContainer struct {
 	c                   libcontainer.Container
 	initProcess         *libcontainerProcess
@@ -305,6 +315,7 @@ func (c *libcontainerContainer) SetExited(status int) {
 	c.exitStatus = status
 	// meh
 	c.exited = true
+	c.initProcess.Close()
 }
 
 func (c *libcontainerContainer) Stats() (*runtime.Stat, error) {
@@ -334,11 +345,13 @@ func (c *libcontainerContainer) Processes() ([]runtime.Process, error) {
 }
 
 func (c *libcontainerContainer) RemoveProcess(pid int) error {
-	if _, ok := c.additionalProcesses[pid]; !ok {
+	proc, ok := c.additionalProcesses[pid]
+	if !ok {
 		return runtime.ErrNotChildProcess
 	}
+	err := proc.Close()
 	delete(c.additionalProcesses, pid)
-	return nil
+	return err
 }
 
 func NewRuntime(stateDir string) (runtime.Runtime, error) {

runtime/container.go

@@ -9,6 +9,7 @@ import (
 )
 
 type Process interface {
+	io.Closer
 	Pid() (int, error)
 	Spec() specs.Process
 	Signal(os.Signal) error