mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
645c020f5a
This patch include the following fixs: - fix image name error when docker ps - fix docker events test failure: use the exact image name for filter - fix docker build CI test failure due to "docker events" change Because of change of daemon log behavior. Now we record the exact Image name as you typed. So docker run -d busybux sh and docker run -d busybox:latest are not the same in the log. So it will affect the docker events. So change the related CI Signed-off-by: Liu Hua <sdu.liu@huawei.com>
513 lines
16 KiB
Go
513 lines
16 KiB
Go
package main
|
|
|
|
import (
|
|
"bufio"
|
|
"fmt"
|
|
"os/exec"
|
|
"regexp"
|
|
"strconv"
|
|
"strings"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestEventsUntag(t *testing.T) {
|
|
image := "busybox"
|
|
dockerCmd(t, "tag", image, "utest:tag1")
|
|
dockerCmd(t, "tag", image, "utest:tag2")
|
|
dockerCmd(t, "rmi", "utest:tag1")
|
|
dockerCmd(t, "rmi", "utest:tag2")
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since=1")
|
|
out, exitCode, _, err := runCommandWithOutputForDuration(eventsCmd, time.Duration(time.Millisecond*200))
|
|
if exitCode != 0 || err != nil {
|
|
t.Fatalf("Failed to get events - exit code %d: %s", exitCode, err)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
nEvents := len(events)
|
|
// The last element after the split above will be an empty string, so we
|
|
// get the two elements before the last, which are the untags we're
|
|
// looking for.
|
|
for _, v := range events[nEvents-3 : nEvents-1] {
|
|
if !strings.Contains(v, "untag") {
|
|
t.Fatalf("event should be untag, not %#v", v)
|
|
}
|
|
}
|
|
logDone("events - untags are logged")
|
|
}
|
|
|
|
func TestEventsContainerFailStartDie(t *testing.T) {
|
|
defer deleteAllContainers()
|
|
|
|
out, _, _ := dockerCmd(t, "images", "-q")
|
|
image := strings.Split(out, "\n")[0]
|
|
eventsCmd := exec.Command(dockerBinary, "run", "--name", "testeventdie", image, "blerg")
|
|
_, _, err := runCommandWithOutput(eventsCmd)
|
|
if err == nil {
|
|
t.Fatalf("Container run with command blerg should have failed, but it did not")
|
|
}
|
|
|
|
eventsCmd = exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", daemonTime(t).Unix()))
|
|
out, _, _ = runCommandWithOutput(eventsCmd)
|
|
events := strings.Split(out, "\n")
|
|
if len(events) <= 1 {
|
|
t.Fatalf("Missing expected event")
|
|
}
|
|
|
|
startEvent := strings.Fields(events[len(events)-3])
|
|
dieEvent := strings.Fields(events[len(events)-2])
|
|
|
|
if startEvent[len(startEvent)-1] != "start" {
|
|
t.Fatalf("event should be start, not %#v", startEvent)
|
|
}
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
|
|
logDone("events - container unwilling to start logs die")
|
|
}
|
|
|
|
func TestEventsLimit(t *testing.T) {
|
|
defer deleteAllContainers()
|
|
for i := 0; i < 30; i++ {
|
|
dockerCmd(t, "run", "busybox", "echo", strconv.Itoa(i))
|
|
}
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", daemonTime(t).Unix()))
|
|
out, _, _ := runCommandWithOutput(eventsCmd)
|
|
events := strings.Split(out, "\n")
|
|
nEvents := len(events) - 1
|
|
if nEvents != 64 {
|
|
t.Fatalf("events should be limited to 64, but received %d", nEvents)
|
|
}
|
|
logDone("events - limited to 64 entries")
|
|
}
|
|
|
|
func TestEventsContainerEvents(t *testing.T) {
|
|
dockerCmd(t, "run", "--rm", "busybox", "true")
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", daemonTime(t).Unix()))
|
|
out, exitCode, err := runCommandWithOutput(eventsCmd)
|
|
if exitCode != 0 || err != nil {
|
|
t.Fatalf("Failed to get events with exit code %d: %s", exitCode, err)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
events = events[:len(events)-1]
|
|
if len(events) < 4 {
|
|
t.Fatalf("Missing expected event")
|
|
}
|
|
createEvent := strings.Fields(events[len(events)-4])
|
|
startEvent := strings.Fields(events[len(events)-3])
|
|
dieEvent := strings.Fields(events[len(events)-2])
|
|
destroyEvent := strings.Fields(events[len(events)-1])
|
|
if createEvent[len(createEvent)-1] != "create" {
|
|
t.Fatalf("event should be create, not %#v", createEvent)
|
|
}
|
|
if startEvent[len(startEvent)-1] != "start" {
|
|
t.Fatalf("event should be start, not %#v", startEvent)
|
|
}
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
if destroyEvent[len(destroyEvent)-1] != "destroy" {
|
|
t.Fatalf("event should be destroy, not %#v", destroyEvent)
|
|
}
|
|
|
|
logDone("events - container create, start, die, destroy is logged")
|
|
}
|
|
|
|
func TestEventsContainerEventsSinceUnixEpoch(t *testing.T) {
|
|
dockerCmd(t, "run", "--rm", "busybox", "true")
|
|
timeBeginning := time.Unix(0, 0).Format(time.RFC3339Nano)
|
|
timeBeginning = strings.Replace(timeBeginning, "Z", ".000000000Z", -1)
|
|
eventsCmd := exec.Command(dockerBinary, "events", fmt.Sprintf("--since='%s'", timeBeginning),
|
|
fmt.Sprintf("--until=%d", daemonTime(t).Unix()))
|
|
out, exitCode, err := runCommandWithOutput(eventsCmd)
|
|
if exitCode != 0 || err != nil {
|
|
t.Fatalf("Failed to get events with exit code %d: %s", exitCode, err)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
events = events[:len(events)-1]
|
|
if len(events) < 4 {
|
|
t.Fatalf("Missing expected event")
|
|
}
|
|
createEvent := strings.Fields(events[len(events)-4])
|
|
startEvent := strings.Fields(events[len(events)-3])
|
|
dieEvent := strings.Fields(events[len(events)-2])
|
|
destroyEvent := strings.Fields(events[len(events)-1])
|
|
if createEvent[len(createEvent)-1] != "create" {
|
|
t.Fatalf("event should be create, not %#v", createEvent)
|
|
}
|
|
if startEvent[len(startEvent)-1] != "start" {
|
|
t.Fatalf("event should be start, not %#v", startEvent)
|
|
}
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
if destroyEvent[len(destroyEvent)-1] != "destroy" {
|
|
t.Fatalf("event should be destroy, not %#v", destroyEvent)
|
|
}
|
|
|
|
logDone("events - container create, start, die, destroy since Unix Epoch time")
|
|
}
|
|
|
|
func TestEventsImageUntagDelete(t *testing.T) {
|
|
name := "testimageevents"
|
|
defer deleteImages(name)
|
|
_, err := buildImage(name,
|
|
`FROM scratch
|
|
MAINTAINER "docker"`,
|
|
true)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if err := deleteImages(name); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", daemonTime(t).Unix()))
|
|
out, exitCode, err := runCommandWithOutput(eventsCmd)
|
|
if exitCode != 0 || err != nil {
|
|
t.Fatalf("Failed to get events with exit code %d: %s", exitCode, err)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
|
|
events = events[:len(events)-1]
|
|
if len(events) < 2 {
|
|
t.Fatalf("Missing expected event")
|
|
}
|
|
untagEvent := strings.Fields(events[len(events)-2])
|
|
deleteEvent := strings.Fields(events[len(events)-1])
|
|
if untagEvent[len(untagEvent)-1] != "untag" {
|
|
t.Fatalf("untag should be untag, not %#v", untagEvent)
|
|
}
|
|
if deleteEvent[len(deleteEvent)-1] != "delete" {
|
|
t.Fatalf("delete should be delete, not %#v", deleteEvent)
|
|
}
|
|
logDone("events - image untag, delete is logged")
|
|
}
|
|
|
|
func TestEventsImagePull(t *testing.T) {
|
|
since := daemonTime(t).Unix()
|
|
testRequires(t, Network)
|
|
|
|
defer deleteImages("hello-world")
|
|
|
|
pullCmd := exec.Command(dockerBinary, "pull", "hello-world")
|
|
if out, _, err := runCommandWithOutput(pullCmd); err != nil {
|
|
t.Fatalf("pulling the hello-world image from has failed: %s, %v", out, err)
|
|
}
|
|
|
|
eventsCmd := exec.Command(dockerBinary, "events",
|
|
fmt.Sprintf("--since=%d", since),
|
|
fmt.Sprintf("--until=%d", daemonTime(t).Unix()))
|
|
out, _, _ := runCommandWithOutput(eventsCmd)
|
|
|
|
events := strings.Split(strings.TrimSpace(out), "\n")
|
|
event := strings.TrimSpace(events[len(events)-1])
|
|
|
|
if !strings.HasSuffix(event, "hello-world:latest: pull") {
|
|
t.Fatalf("Missing pull event - got:%q", event)
|
|
}
|
|
|
|
logDone("events - image pull is logged")
|
|
}
|
|
|
|
func TestEventsImageImport(t *testing.T) {
|
|
defer deleteAllContainers()
|
|
since := daemonTime(t).Unix()
|
|
|
|
runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "true")
|
|
out, _, err := runCommandWithOutput(runCmd)
|
|
if err != nil {
|
|
t.Fatal("failed to create a container", out, err)
|
|
}
|
|
cleanedContainerID := strings.TrimSpace(out)
|
|
|
|
out, _, err = runCommandPipelineWithOutput(
|
|
exec.Command(dockerBinary, "export", cleanedContainerID),
|
|
exec.Command(dockerBinary, "import", "-"),
|
|
)
|
|
if err != nil {
|
|
t.Errorf("import failed with errors: %v, output: %q", err, out)
|
|
}
|
|
|
|
eventsCmd := exec.Command(dockerBinary, "events",
|
|
fmt.Sprintf("--since=%d", since),
|
|
fmt.Sprintf("--until=%d", daemonTime(t).Unix()))
|
|
out, _, _ = runCommandWithOutput(eventsCmd)
|
|
|
|
events := strings.Split(strings.TrimSpace(out), "\n")
|
|
event := strings.TrimSpace(events[len(events)-1])
|
|
|
|
if !strings.HasSuffix(event, ": import") {
|
|
t.Fatalf("Missing import event - got:%q", event)
|
|
}
|
|
|
|
logDone("events - image import is logged")
|
|
}
|
|
|
|
func TestEventsFilters(t *testing.T) {
|
|
parseEvents := func(out, match string) {
|
|
events := strings.Split(out, "\n")
|
|
events = events[:len(events)-1]
|
|
for _, event := range events {
|
|
eventFields := strings.Fields(event)
|
|
eventName := eventFields[len(eventFields)-1]
|
|
if ok, err := regexp.MatchString(match, eventName); err != nil || !ok {
|
|
t.Fatalf("event should match %s, got %#v, err: %v", match, eventFields, err)
|
|
}
|
|
}
|
|
}
|
|
|
|
since := daemonTime(t).Unix()
|
|
out, _, err := runCommandWithOutput(exec.Command(dockerBinary, "run", "--rm", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
out, _, err = runCommandWithOutput(exec.Command(dockerBinary, "run", "--rm", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
out, _, err = runCommandWithOutput(exec.Command(dockerBinary, "events", fmt.Sprintf("--since=%d", since), fmt.Sprintf("--until=%d", daemonTime(t).Unix()), "--filter", "event=die"))
|
|
if err != nil {
|
|
t.Fatalf("Failed to get events: %s", err)
|
|
}
|
|
parseEvents(out, "die")
|
|
|
|
out, _, err = runCommandWithOutput(exec.Command(dockerBinary, "events", fmt.Sprintf("--since=%d", since), fmt.Sprintf("--until=%d", daemonTime(t).Unix()), "--filter", "event=die", "--filter", "event=start"))
|
|
if err != nil {
|
|
t.Fatalf("Failed to get events: %s", err)
|
|
}
|
|
parseEvents(out, "((die)|(start))")
|
|
|
|
// make sure we at least got 2 start events
|
|
count := strings.Count(out, "start")
|
|
if count < 2 {
|
|
t.Fatalf("should have had 2 start events but had %d, out: %s", count, out)
|
|
}
|
|
|
|
logDone("events - filters")
|
|
}
|
|
|
|
func TestEventsFilterImageName(t *testing.T) {
|
|
since := daemonTime(t).Unix()
|
|
defer deleteAllContainers()
|
|
|
|
out, _, err := runCommandWithOutput(exec.Command(dockerBinary, "run", "--name", "container_1", "-d", "busybox:latest", "true"))
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
container1 := strings.TrimSpace(out)
|
|
|
|
out, _, err = runCommandWithOutput(exec.Command(dockerBinary, "run", "--name", "container_2", "-d", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
container2 := strings.TrimSpace(out)
|
|
|
|
s := "busybox"
|
|
eventsCmd := exec.Command(dockerBinary, "events", fmt.Sprintf("--since=%d", since), fmt.Sprintf("--until=%d", daemonTime(t).Unix()), "--filter", fmt.Sprintf("image=%s", s))
|
|
out, _, err = runCommandWithOutput(eventsCmd)
|
|
if err != nil {
|
|
t.Fatalf("Failed to get events, error: %s(%s)", err, out)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
events = events[:len(events)-1]
|
|
if len(events) == 0 {
|
|
t.Fatalf("Expected events but found none for the image busybox:latest")
|
|
}
|
|
count1 := 0
|
|
count2 := 0
|
|
|
|
for _, e := range events {
|
|
if strings.Contains(e, container1) {
|
|
count1++
|
|
} else if strings.Contains(e, container2) {
|
|
count2++
|
|
}
|
|
}
|
|
if count1 == 0 || count2 == 0 {
|
|
t.Fatalf("Expected events from each container but got %d from %s and %d from %s", count1, container1, count2, container2)
|
|
}
|
|
|
|
logDone("events - filters using image")
|
|
}
|
|
|
|
func TestEventsFilterContainerID(t *testing.T) {
|
|
since := daemonTime(t).Unix()
|
|
defer deleteAllContainers()
|
|
|
|
out, _, err := runCommandWithOutput(exec.Command(dockerBinary, "run", "-d", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
container1 := strings.TrimSpace(out)
|
|
|
|
out, _, err = runCommandWithOutput(exec.Command(dockerBinary, "run", "-d", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
container2 := strings.TrimSpace(out)
|
|
|
|
for _, s := range []string{container1, container2, container1[:12], container2[:12]} {
|
|
if err := waitInspect(s, "{{.State.Running}}", "false", 5); err != nil {
|
|
t.Fatalf("Failed to get container %s state, error: %s", s, err)
|
|
}
|
|
|
|
eventsCmd := exec.Command(dockerBinary, "events", fmt.Sprintf("--since=%d", since), fmt.Sprintf("--until=%d", daemonTime(t).Unix()), "--filter", fmt.Sprintf("container=%s", s))
|
|
out, _, err := runCommandWithOutput(eventsCmd)
|
|
if err != nil {
|
|
t.Fatalf("Failed to get events, error: %s(%s)", err, out)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
checkEvents(t, events[:len(events)-1])
|
|
}
|
|
|
|
logDone("events - filters using container id")
|
|
}
|
|
|
|
func TestEventsFilterContainerName(t *testing.T) {
|
|
since := daemonTime(t).Unix()
|
|
defer deleteAllContainers()
|
|
|
|
_, _, err := runCommandWithOutput(exec.Command(dockerBinary, "run", "--name", "container_1", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
_, _, err = runCommandWithOutput(exec.Command(dockerBinary, "run", "--name", "container_2", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
for _, s := range []string{"container_1", "container_2"} {
|
|
if err := waitInspect(s, "{{.State.Running}}", "false", 5); err != nil {
|
|
t.Fatalf("Failed to get container %s state, error: %s", s, err)
|
|
}
|
|
|
|
eventsCmd := exec.Command(dockerBinary, "events", fmt.Sprintf("--since=%d", since), fmt.Sprintf("--until=%d", daemonTime(t).Unix()), "--filter", fmt.Sprintf("container=%s", s))
|
|
out, _, err := runCommandWithOutput(eventsCmd)
|
|
if err != nil {
|
|
t.Fatalf("Failed to get events, error : %s(%s)", err, out)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
checkEvents(t, events[:len(events)-1])
|
|
}
|
|
|
|
logDone("events - filters using container name")
|
|
}
|
|
|
|
func checkEvents(t *testing.T, events []string) {
|
|
if len(events) != 3 {
|
|
t.Fatalf("Expected 3 events, got %d: %v", len(events), events)
|
|
}
|
|
createEvent := strings.Fields(events[0])
|
|
if createEvent[len(createEvent)-1] != "create" {
|
|
t.Fatalf("first event should be create, not %#v", createEvent)
|
|
}
|
|
startEvent := strings.Fields(events[1])
|
|
if startEvent[len(startEvent)-1] != "start" {
|
|
t.Fatalf("second event should be start, not %#v", startEvent)
|
|
}
|
|
dieEvent := strings.Fields(events[len(events)-1])
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
|
|
}
|
|
|
|
func TestEventsStreaming(t *testing.T) {
|
|
start := daemonTime(t).Unix()
|
|
|
|
finish := make(chan struct{})
|
|
defer close(finish)
|
|
id := make(chan string)
|
|
eventCreate := make(chan struct{})
|
|
eventStart := make(chan struct{})
|
|
eventDie := make(chan struct{})
|
|
eventDestroy := make(chan struct{})
|
|
|
|
go func() {
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since", strconv.FormatInt(start, 10))
|
|
stdout, err := eventsCmd.StdoutPipe()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
err = eventsCmd.Start()
|
|
if err != nil {
|
|
t.Fatalf("failed to start 'docker events': %s", err)
|
|
}
|
|
|
|
go func() {
|
|
<-finish
|
|
eventsCmd.Process.Kill()
|
|
}()
|
|
|
|
containerID := <-id
|
|
|
|
matchCreate := regexp.MustCompile(containerID + `: \(from busybox:latest\) create$`)
|
|
matchStart := regexp.MustCompile(containerID + `: \(from busybox:latest\) start$`)
|
|
matchDie := regexp.MustCompile(containerID + `: \(from busybox:latest\) die$`)
|
|
matchDestroy := regexp.MustCompile(containerID + `: \(from busybox:latest\) destroy$`)
|
|
|
|
scanner := bufio.NewScanner(stdout)
|
|
for scanner.Scan() {
|
|
switch {
|
|
case matchCreate.MatchString(scanner.Text()):
|
|
close(eventCreate)
|
|
case matchStart.MatchString(scanner.Text()):
|
|
close(eventStart)
|
|
case matchDie.MatchString(scanner.Text()):
|
|
close(eventDie)
|
|
case matchDestroy.MatchString(scanner.Text()):
|
|
close(eventDestroy)
|
|
}
|
|
}
|
|
|
|
err = eventsCmd.Wait()
|
|
if err != nil && !IsKilled(err) {
|
|
t.Fatalf("docker events had bad exit status: %s", err)
|
|
}
|
|
}()
|
|
|
|
runCmd := exec.Command(dockerBinary, "run", "-d", "busybox:latest", "true")
|
|
out, _, err := runCommandWithOutput(runCmd)
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
cleanedContainerID := strings.TrimSpace(out)
|
|
id <- cleanedContainerID
|
|
|
|
select {
|
|
case <-time.After(5 * time.Second):
|
|
t.Fatal("failed to observe container create in timely fashion")
|
|
case <-eventCreate:
|
|
// ignore, done
|
|
}
|
|
|
|
select {
|
|
case <-time.After(5 * time.Second):
|
|
t.Fatal("failed to observe container start in timely fashion")
|
|
case <-eventStart:
|
|
// ignore, done
|
|
}
|
|
|
|
select {
|
|
case <-time.After(5 * time.Second):
|
|
t.Fatal("failed to observe container die in timely fashion")
|
|
case <-eventDie:
|
|
// ignore, done
|
|
}
|
|
|
|
rmCmd := exec.Command(dockerBinary, "rm", cleanedContainerID)
|
|
out, _, err = runCommandWithOutput(rmCmd)
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
|
|
select {
|
|
case <-time.After(5 * time.Second):
|
|
t.Fatal("failed to observe container destroy in timely fashion")
|
|
case <-eventDestroy:
|
|
// ignore, done
|
|
}
|
|
|
|
logDone("events - streamed to stdout")
|
|
}
|