123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121 |
- 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")
- }
|