From 9da89dbbd14d2c7b4728b1702b89ef5a69315702 Mon Sep 17 00:00:00 2001
From: Ankush Agarwal <ankushagarwal11@gmail.com>
Date: Tue, 28 Jul 2015 11:17:25 -0700
Subject: [PATCH] Doc fixes in logger, update NewCopier method

Signed-off-by: Ankush Agarwal <ankushagarwal11@gmail.com>
Upstream-commit: 41d85c014defd96cda06abac73554d9f9d1de0d8
Component: engine
---
 components/engine/daemon/container.go          | 5 +----
 components/engine/daemon/logger/copier.go      | 8 ++++----
 components/engine/daemon/logger/copier_test.go | 5 +----
 3 files changed, 6 insertions(+), 12 deletions(-)

diff --git a/components/engine/daemon/container.go b/components/engine/daemon/container.go
index 855900f061..8ef250923a 100644
--- a/components/engine/daemon/container.go
+++ b/components/engine/daemon/container.go
@@ -735,10 +735,7 @@ func (container *Container) startLogging() error {
 		return fmt.Errorf("Failed to initialize logging driver: %v", err)
 	}
 
-	copier, err := logger.NewCopier(container.ID, map[string]io.Reader{"stdout": container.StdoutPipe(), "stderr": container.StderrPipe()}, l)
-	if err != nil {
-		return err
-	}
+	copier := logger.NewCopier(container.ID, map[string]io.Reader{"stdout": container.StdoutPipe(), "stderr": container.StderrPipe()}, l)
 	container.logCopier = copier
 	copier.Run()
 	container.logDriver = l
diff --git a/components/engine/daemon/logger/copier.go b/components/engine/daemon/logger/copier.go
index 6fe2b00755..95cd9eb355 100644
--- a/components/engine/daemon/logger/copier.go
+++ b/components/engine/daemon/logger/copier.go
@@ -14,7 +14,7 @@ import (
 // ContainerID and Timestamp.
 // Writes are concurrent, so you need implement some sync in your logger
 type Copier struct {
-	// cid is container id for which we copying logs
+	// cid is the container id for which we are copying logs
 	cid string
 	// srcs is map of name -> reader pairs, for example "stdout", "stderr"
 	srcs     map[string]io.Reader
@@ -22,13 +22,13 @@ type Copier struct {
 	copyJobs sync.WaitGroup
 }
 
-// NewCopier creates new Copier
-func NewCopier(cid string, srcs map[string]io.Reader, dst Logger) (*Copier, error) {
+// NewCopier creates a new Copier
+func NewCopier(cid string, srcs map[string]io.Reader, dst Logger) *Copier {
 	return &Copier{
 		cid:  cid,
 		srcs: srcs,
 		dst:  dst,
-	}, nil
+	}
 }
 
 // Run starts logs copying
diff --git a/components/engine/daemon/logger/copier_test.go b/components/engine/daemon/logger/copier_test.go
index 2db7b8e216..f8980b3615 100644
--- a/components/engine/daemon/logger/copier_test.go
+++ b/components/engine/daemon/logger/copier_test.go
@@ -50,15 +50,12 @@ func TestCopier(t *testing.T) {
 	jsonLog := &TestLoggerJSON{Encoder: json.NewEncoder(&jsonBuf)}
 
 	cid := "a7317399f3f857173c6179d44823594f8294678dea9999662e5c625b5a1c7657"
-	c, err := NewCopier(cid,
+	c := NewCopier(cid,
 		map[string]io.Reader{
 			"stdout": &stdout,
 			"stderr": &stderr,
 		},
 		jsonLog)
-	if err != nil {
-		t.Fatal(err)
-	}
 	c.Run()
 	wait := make(chan struct{})
 	go func() {