Skip to content

Commit

Permalink
Merge pull request #11473 from pradeepchhetri/docker-wait-cli-integra…
Browse files Browse the repository at this point in the history
…tion-test

Added basic integration tests for docker wait command
  • Loading branch information
Jessie Frazelle committed Mar 31, 2015
2 parents b875e12 + 1401b8f commit a381a1b
Showing 1 changed file with 121 additions and 0 deletions.
121 changes: 121 additions & 0 deletions integration-cli/docker_cli_wait_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,121 @@
package main

import (
"os/exec"
"testing"
"time"
)

// non-blocking wait with 0 exit code
func TestWaitNonBlockedExitZero(t *testing.T) {
defer deleteAllContainers()

runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "sh", "-c", "true")
out, _, err := runCommandWithOutput(runCmd)
if err != nil {
t.Fatal(out, err)
}
containerID := stripTrailingCharacters(out)

status := "true"
for i := 0; status != "false"; i++ {
runCmd = exec.Command(dockerBinary, "inspect", "--format='{{.State.Running}}'", containerID)
status, _, err = runCommandWithOutput(runCmd)
if err != nil {
t.Fatal(status, err)
}
status = stripTrailingCharacters(status)

time.Sleep(time.Second)
if i >= 60 {
t.Fatal("Container should have stopped by now")
}
}

runCmd = exec.Command(dockerBinary, "wait", containerID)
out, _, err = runCommandWithOutput(runCmd)

if err != nil || stripTrailingCharacters(out) != "0" {
t.Fatal("failed to set up container", out, err)
}

logDone("wait - non-blocking wait with 0 exit code")
}

// blocking wait with 0 exit code
func TestWaitBlockedExitZero(t *testing.T) {
defer deleteAllContainers()

runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "sh", "-c", "sleep 10")
out, _, err := runCommandWithOutput(runCmd)
if err != nil {
t.Fatal(out, err)
}
containerID := stripTrailingCharacters(out)

runCmd = exec.Command(dockerBinary, "wait", containerID)
out, _, err = runCommandWithOutput(runCmd)

if err != nil || stripTrailingCharacters(out) != "0" {
t.Fatal("failed to set up container", out, err)
}

logDone("wait - blocking wait with 0 exit code")
}

// non-blocking wait with random exit code
func TestWaitNonBlockedExitRandom(t *testing.T) {
defer deleteAllContainers()

runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "sh", "-c", "exit 99")
out, _, err := runCommandWithOutput(runCmd)
if err != nil {
t.Fatal(out, err)
}
containerID := stripTrailingCharacters(out)

status := "true"
for i := 0; status != "false"; i++ {
runCmd = exec.Command(dockerBinary, "inspect", "--format='{{.State.Running}}'", containerID)
status, _, err = runCommandWithOutput(runCmd)
if err != nil {
t.Fatal(status, err)
}
status = stripTrailingCharacters(status)

time.Sleep(time.Second)
if i >= 60 {
t.Fatal("Container should have stopped by now")
}
}

runCmd = exec.Command(dockerBinary, "wait", containerID)
out, _, err = runCommandWithOutput(runCmd)

if err != nil || stripTrailingCharacters(out) != "99" {
t.Fatal("failed to set up container", out, err)
}

logDone("wait - non-blocking wait with random exit code")
}

// blocking wait with random exit code
func TestWaitBlockedExitRandom(t *testing.T) {
defer deleteAllContainers()

runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "sh", "-c", "sleep 10; exit 99")
out, _, err := runCommandWithOutput(runCmd)
if err != nil {
t.Fatal(out, err)
}
containerID := stripTrailingCharacters(out)

runCmd = exec.Command(dockerBinary, "wait", containerID)
out, _, err = runCommandWithOutput(runCmd)

if err != nil || stripTrailingCharacters(out) != "99" {
t.Fatal("failed to set up container", out, err)
}

logDone("wait - blocking wait with random exit code")
}

0 comments on commit a381a1b

Please sign in to comment.