diff --git a/daemon/attach.go b/daemon/attach.go index ad8649f4e1..2c65956a58 100644 --- a/daemon/attach.go +++ b/daemon/attach.go @@ -8,6 +8,7 @@ import ( "time" "github.com/docker/docker/engine" + "github.com/docker/docker/pkg/jsonlog" "github.com/docker/docker/utils" ) @@ -57,7 +58,7 @@ func (daemon *Daemon) ContainerAttach(job *engine.Job) engine.Status { } else { dec := json.NewDecoder(cLog) for { - l := &utils.JSONLog{} + l := &jsonlog.JSONLog{} if err := dec.Decode(l); err == io.EOF { break diff --git a/daemon/logs.go b/daemon/logs.go index edfffac4ff..f78a62d046 100644 --- a/daemon/logs.go +++ b/daemon/logs.go @@ -12,6 +12,7 @@ import ( "github.com/docker/docker/pkg/tailfile" "github.com/docker/docker/engine" + "github.com/docker/docker/pkg/jsonlog" "github.com/docker/docker/utils" ) @@ -89,7 +90,7 @@ func (daemon *Daemon) ContainerLogs(job *engine.Job) engine.Status { } dec := json.NewDecoder(cLog) for { - l := &utils.JSONLog{} + l := &jsonlog.JSONLog{} if err := dec.Decode(l); err == io.EOF { break @@ -115,13 +116,13 @@ func (daemon *Daemon) ContainerLogs(job *engine.Job) engine.Status { if stdout { stdoutPipe := container.StdoutLogPipe() go func() { - errors <- utils.WriteLog(stdoutPipe, job.Stdout, format) + errors <- jsonlog.WriteLog(stdoutPipe, job.Stdout, format) }() } if stderr { stderrPipe := container.StderrLogPipe() go func() { - errors <- utils.WriteLog(stderrPipe, job.Stderr, format) + errors <- jsonlog.WriteLog(stderrPipe, job.Stderr, format) }() } err := <-errors