91bfed60 |
package main
import ( |
9e0ffae8 |
"bufio" |
e8d9a61f |
"bytes" |
91bfed60 |
"fmt" |
e8d9a61f |
"io"
"io/ioutil" |
91bfed60 |
"net/http" |
e8d9a61f |
"strconv" |
9e0ffae8 |
"strings"
"time" |
dc944ea7 |
|
0fd5a654 |
"github.com/docker/docker/api/types"
"github.com/docker/docker/client" |
33968e6c |
"github.com/docker/docker/integration-cli/checker" |
d69d4799 |
"github.com/docker/docker/integration-cli/request" |
e8d9a61f |
"github.com/docker/docker/pkg/stdcopy" |
dc944ea7 |
"github.com/go-check/check" |
0fd5a654 |
"golang.org/x/net/context" |
91bfed60 |
)
|
7fb7a477 |
func (s *DockerSuite) TestLogsAPIWithStdout(c *check.C) { |
9e0ffae8 |
out, _ := dockerCmd(c, "run", "-d", "-t", "busybox", "/bin/sh", "-c", "while true; do echo hello; sleep 1; done")
id := strings.TrimSpace(out) |
7aab43e8 |
c.Assert(waitRun(id), checker.IsNil) |
91bfed60 |
|
9e0ffae8 |
type logOut struct { |
bb1c576e |
out string
err error |
9e0ffae8 |
} |
960b8d92 |
|
9e0ffae8 |
chLog := make(chan logOut) |
960b8d92 |
res, body, err := request.Get(fmt.Sprintf("/containers/%s/logs?follow=1&stdout=1×tamps=1", id))
c.Assert(err, checker.IsNil)
c.Assert(res.StatusCode, checker.Equals, http.StatusOK) |
9e0ffae8 |
go func() { |
18faf6f9 |
defer body.Close()
out, err := bufio.NewReader(body).ReadString('\n')
if err != nil { |
960b8d92 |
chLog <- logOut{"", err} |
18faf6f9 |
return
} |
960b8d92 |
chLog <- logOut{strings.TrimSpace(out), err} |
9e0ffae8 |
}()
select {
case l := <-chLog: |
7aab43e8 |
c.Assert(l.err, checker.IsNil) |
9e0ffae8 |
if !strings.HasSuffix(l.out, "hello") {
c.Fatalf("expected log output to container 'hello', but it does not")
} |
960b8d92 |
case <-time.After(30 * time.Second): |
9e0ffae8 |
c.Fatal("timeout waiting for logs to exit") |
91bfed60 |
}
}
|
7fb7a477 |
func (s *DockerSuite) TestLogsAPINoStdoutNorStderr(c *check.C) { |
91bfed60 |
name := "logs_test" |
5c295460 |
dockerCmd(c, "run", "-d", "-t", "--name", name, "busybox", "/bin/sh") |
0fd5a654 |
cli, err := client.NewEnvClient() |
7aab43e8 |
c.Assert(err, checker.IsNil) |
0fd5a654 |
defer cli.Close() |
91bfed60 |
|
0fd5a654 |
_, err = cli.ContainerLogs(context.Background(), name, types.ContainerLogsOptions{}) |
91bfed60 |
expected := "Bad parameters: you must choose at least one stream" |
0fd5a654 |
c.Assert(err.Error(), checker.Contains, expected) |
91bfed60 |
} |
589de356 |
// Regression test for #12704 |
7fb7a477 |
func (s *DockerSuite) TestLogsAPIFollowEmptyOutput(c *check.C) { |
589de356 |
name := "logs_test"
t0 := time.Now() |
5c295460 |
dockerCmd(c, "run", "-d", "-t", "--name", name, "busybox", "sleep", "10") |
589de356 |
|
b11ba123 |
_, body, err := request.Get(fmt.Sprintf("/containers/%s/logs?follow=1&stdout=1&stderr=1&tail=all", name)) |
589de356 |
t1 := time.Now() |
7aab43e8 |
c.Assert(err, checker.IsNil) |
589de356 |
body.Close()
elapsed := t1.Sub(t0).Seconds() |
00f65ae8 |
if elapsed > 20.0 { |
589de356 |
c.Fatalf("HTTP response was not immediate (elapsed %.1fs)", elapsed)
}
} |
1eecc1e7 |
|
7fb7a477 |
func (s *DockerSuite) TestLogsAPIContainerNotFound(c *check.C) { |
1eecc1e7 |
name := "nonExistentContainer" |
b11ba123 |
resp, _, err := request.Get(fmt.Sprintf("/containers/%s/logs?follow=1&stdout=1&stderr=1&tail=all", name)) |
7aab43e8 |
c.Assert(err, checker.IsNil)
c.Assert(resp.StatusCode, checker.Equals, http.StatusNotFound) |
1eecc1e7 |
} |
e8d9a61f |
func (s *DockerSuite) TestLogsAPIUntilFutureFollow(c *check.C) {
testRequires(c, DaemonIsLinux)
name := "logsuntilfuturefollow"
dockerCmd(c, "run", "-d", "--name", name, "busybox", "/bin/sh", "-c", "while true; do date +%s; sleep 1; done")
c.Assert(waitRun(name), checker.IsNil)
untilSecs := 5
untilDur, err := time.ParseDuration(fmt.Sprintf("%ds", untilSecs))
c.Assert(err, checker.IsNil)
until := daemonTime(c).Add(untilDur)
client, err := request.NewClient()
if err != nil {
c.Fatal(err)
}
cfg := types.ContainerLogsOptions{Until: until.Format(time.RFC3339Nano), Follow: true, ShowStdout: true, Timestamps: true}
reader, err := client.ContainerLogs(context.Background(), name, cfg)
c.Assert(err, checker.IsNil)
type logOut struct {
out string
err error
}
chLog := make(chan logOut)
go func() {
bufReader := bufio.NewReader(reader)
defer reader.Close()
for i := 0; i < untilSecs; i++ {
out, _, err := bufReader.ReadLine()
if err != nil {
if err == io.EOF {
return
}
chLog <- logOut{"", err}
return
}
chLog <- logOut{strings.TrimSpace(string(out)), err}
}
}()
for i := 0; i < untilSecs; i++ {
select {
case l := <-chLog:
c.Assert(l.err, checker.IsNil)
i, err := strconv.ParseInt(strings.Split(l.out, " ")[1], 10, 64)
c.Assert(err, checker.IsNil)
c.Assert(time.Unix(i, 0).UnixNano(), checker.LessOrEqualThan, until.UnixNano())
case <-time.After(20 * time.Second):
c.Fatal("timeout waiting for logs to exit")
}
}
}
func (s *DockerSuite) TestLogsAPIUntil(c *check.C) {
name := "logsuntil" |
1360f0dc |
dockerCmd(c, "run", "--name", name, "busybox", "/bin/sh", "-c", "for i in $(seq 1 3); do echo log$i; sleep 1; done") |
e8d9a61f |
client, err := request.NewClient()
if err != nil {
c.Fatal(err)
}
extractBody := func(c *check.C, cfg types.ContainerLogsOptions) []string {
reader, err := client.ContainerLogs(context.Background(), name, cfg)
c.Assert(err, checker.IsNil)
actualStdout := new(bytes.Buffer)
actualStderr := ioutil.Discard
_, err = stdcopy.StdCopy(actualStdout, actualStderr, reader)
c.Assert(err, checker.IsNil)
return strings.Split(actualStdout.String(), "\n")
}
// Get timestamp of second log line
allLogs := extractBody(c, types.ContainerLogsOptions{Timestamps: true, ShowStdout: true}) |
e77de785 |
c.Assert(len(allLogs), checker.GreaterOrEqualThan, 3)
|
e8d9a61f |
t, err := time.Parse(time.RFC3339Nano, strings.Split(allLogs[1], " ")[0])
c.Assert(err, checker.IsNil)
until := t.Format(time.RFC3339Nano)
// Get logs until the timestamp of second line, i.e. first two lines
logs := extractBody(c, types.ContainerLogsOptions{Timestamps: true, ShowStdout: true, Until: until})
// Ensure log lines after cut-off are excluded
logsString := strings.Join(logs, "\n")
c.Assert(logsString, checker.Not(checker.Contains), "log3", check.Commentf("unexpected log message returned, until=%v", until))
}
func (s *DockerSuite) TestLogsAPIUntilDefaultValue(c *check.C) {
name := "logsuntildefaultval"
dockerCmd(c, "run", "--name", name, "busybox", "/bin/sh", "-c", "for i in $(seq 1 3); do echo log$i; done")
client, err := request.NewClient()
if err != nil {
c.Fatal(err)
}
extractBody := func(c *check.C, cfg types.ContainerLogsOptions) []string {
reader, err := client.ContainerLogs(context.Background(), name, cfg)
c.Assert(err, checker.IsNil)
actualStdout := new(bytes.Buffer)
actualStderr := ioutil.Discard
_, err = stdcopy.StdCopy(actualStdout, actualStderr, reader)
c.Assert(err, checker.IsNil)
return strings.Split(actualStdout.String(), "\n")
}
// Get timestamp of second log line
allLogs := extractBody(c, types.ContainerLogsOptions{Timestamps: true, ShowStdout: true})
// Test with default value specified and parameter omitted
defaultLogs := extractBody(c, types.ContainerLogsOptions{Timestamps: true, ShowStdout: true, Until: "0"})
c.Assert(defaultLogs, checker.DeepEquals, allLogs)
} |