2014-09-25 06:46:57 +04:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
2014-10-19 06:47:48 +04:00
|
|
|
"fmt"
|
2014-09-25 06:46:57 +04:00
|
|
|
"os/exec"
|
2014-10-19 06:47:48 +04:00
|
|
|
"strings"
|
2014-09-25 06:46:57 +04:00
|
|
|
"testing"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
|
|
|
|
// Regression test for https://github.com/docker/docker/issues/7843
|
|
|
|
func TestStartAttachReturnsOnError(t *testing.T) {
|
|
|
|
defer deleteAllContainers()
|
|
|
|
|
2014-11-24 18:32:38 +03:00
|
|
|
dockerCmd(t, "run", "-d", "--name", "test", "busybox")
|
2014-11-28 21:48:50 +03:00
|
|
|
dockerCmd(t, "wait", "test")
|
2014-09-25 06:46:57 +04:00
|
|
|
|
|
|
|
// Expect this to fail because the above container is stopped, this is what we want
|
|
|
|
if _, err := runCommand(exec.Command(dockerBinary, "run", "-d", "--name", "test2", "--link", "test:test", "busybox")); err == nil {
|
|
|
|
t.Fatal("Expected error but got none")
|
|
|
|
}
|
|
|
|
|
|
|
|
ch := make(chan struct{})
|
|
|
|
go func() {
|
|
|
|
// Attempt to start attached to the container that won't start
|
|
|
|
// This should return an error immediately since the container can't be started
|
|
|
|
if _, err := runCommand(exec.Command(dockerBinary, "start", "-a", "test2")); err == nil {
|
|
|
|
t.Fatal("Expected error but got none")
|
|
|
|
}
|
|
|
|
close(ch)
|
|
|
|
}()
|
|
|
|
|
|
|
|
select {
|
|
|
|
case <-ch:
|
|
|
|
case <-time.After(time.Second):
|
|
|
|
t.Fatalf("Attach did not exit properly")
|
|
|
|
}
|
|
|
|
|
|
|
|
logDone("start - error on start with attach exits")
|
|
|
|
}
|
2014-10-19 06:47:48 +04:00
|
|
|
|
|
|
|
// gh#8555: Exit code should be passed through when using start -a
|
|
|
|
func TestStartAttachCorrectExitCode(t *testing.T) {
|
|
|
|
defer deleteAllContainers()
|
|
|
|
|
|
|
|
runCmd := exec.Command(dockerBinary, "run", "-d", "busybox", "sh", "-c", "sleep 2; exit 1")
|
|
|
|
out, _, _, err := runCommandWithStdoutStderr(runCmd)
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("failed to run container: %v, output: %q", err, out)
|
|
|
|
}
|
|
|
|
|
|
|
|
out = stripTrailingCharacters(out)
|
|
|
|
|
|
|
|
// make sure the container has exited before trying the "start -a"
|
|
|
|
waitCmd := exec.Command(dockerBinary, "wait", out)
|
|
|
|
if out, _, err = runCommandWithOutput(waitCmd); err != nil {
|
|
|
|
t.Fatal(out, err)
|
|
|
|
}
|
|
|
|
|
|
|
|
startCmd := exec.Command(dockerBinary, "start", "-a", out)
|
|
|
|
startOut, exitCode, err := runCommandWithOutput(startCmd)
|
|
|
|
if err != nil && !strings.Contains("exit status 1", fmt.Sprintf("%s", err)) {
|
|
|
|
t.Fatalf("start command failed unexpectedly with error: %v, output: %q", err, startOut)
|
|
|
|
}
|
|
|
|
if exitCode != 1 {
|
|
|
|
t.Fatalf("start -a did not respond with proper exit code: expected 1, got %d", exitCode)
|
|
|
|
}
|
|
|
|
|
|
|
|
logDone("start - correct exit code returned with -a")
|
|
|
|
}
|
2014-09-30 12:30:58 +04:00
|
|
|
|
|
|
|
func TestStartRecordError(t *testing.T) {
|
|
|
|
defer deleteAllContainers()
|
|
|
|
|
|
|
|
// when container runs successfully, we should not have state.Error
|
2014-11-24 18:32:38 +03:00
|
|
|
dockerCmd(t, "run", "-d", "-p", "9999:9999", "--name", "test", "busybox", "top")
|
2014-09-30 12:30:58 +04:00
|
|
|
stateErr, err := inspectField("test", "State.Error")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("Failed to inspect %q state's error, got error %q", "test", err)
|
|
|
|
}
|
|
|
|
if stateErr != "" {
|
|
|
|
t.Fatalf("Expected to not have state error but got state.Error(%q)", stateErr)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Expect this to fail and records error because of ports conflict
|
|
|
|
out, _, err := runCommandWithOutput(exec.Command(dockerBinary, "run", "-d", "--name", "test2", "-p", "9999:9999", "busybox", "top"))
|
|
|
|
if err == nil {
|
|
|
|
t.Fatalf("Expected error but got none, output %q", out)
|
|
|
|
}
|
|
|
|
stateErr, err = inspectField("test2", "State.Error")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("Failed to inspect %q state's error, got error %q", "test2", err)
|
|
|
|
}
|
|
|
|
expected := "port is already allocated"
|
|
|
|
if stateErr == "" || !strings.Contains(stateErr, expected) {
|
|
|
|
t.Fatalf("State.Error(%q) does not include %q", stateErr, expected)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Expect the conflict to be resolved when we stop the initial container
|
2014-11-24 18:32:38 +03:00
|
|
|
dockerCmd(t, "stop", "test")
|
|
|
|
dockerCmd(t, "start", "test2")
|
2014-09-30 12:30:58 +04:00
|
|
|
stateErr, err = inspectField("test2", "State.Error")
|
|
|
|
if err != nil {
|
|
|
|
t.Fatalf("Failed to inspect %q state's error, got error %q", "test", err)
|
|
|
|
}
|
|
|
|
if stateErr != "" {
|
|
|
|
t.Fatalf("Expected to not have state error but got state.Error(%q)", stateErr)
|
|
|
|
}
|
|
|
|
|
|
|
|
logDone("start - set state error when start fails")
|
|
|
|
}
|
2014-10-23 16:50:06 +04:00
|
|
|
|
|
|
|
// gh#8726: a failed Start() breaks --volumes-from on subsequent Start()'s
|
|
|
|
func TestStartVolumesFromFailsCleanly(t *testing.T) {
|
|
|
|
defer deleteAllContainers()
|
|
|
|
|
|
|
|
// Create the first data volume
|
2014-11-24 18:32:38 +03:00
|
|
|
dockerCmd(t, "run", "-d", "--name", "data_before", "-v", "/foo", "busybox")
|
2014-10-23 16:50:06 +04:00
|
|
|
|
|
|
|
// Expect this to fail because the data test after contaienr doesn't exist yet
|
|
|
|
if _, err := runCommand(exec.Command(dockerBinary, "run", "-d", "--name", "consumer", "--volumes-from", "data_before", "--volumes-from", "data_after", "busybox")); err == nil {
|
|
|
|
t.Fatal("Expected error but got none")
|
|
|
|
}
|
|
|
|
|
|
|
|
// Create the second data volume
|
2014-11-24 18:32:38 +03:00
|
|
|
dockerCmd(t, "run", "-d", "--name", "data_after", "-v", "/bar", "busybox")
|
2014-10-23 16:50:06 +04:00
|
|
|
|
|
|
|
// Now, all the volumes should be there
|
2014-11-24 18:32:38 +03:00
|
|
|
dockerCmd(t, "start", "consumer")
|
2014-10-23 16:50:06 +04:00
|
|
|
|
|
|
|
// Check that we have the volumes we want
|
2014-11-24 18:32:38 +03:00
|
|
|
out, _, _ := dockerCmd(t, "inspect", "--format='{{ len .Volumes }}'", "consumer")
|
2014-10-23 16:50:06 +04:00
|
|
|
n_volumes := strings.Trim(out, " \r\n'")
|
|
|
|
if n_volumes != "2" {
|
|
|
|
t.Fatalf("Missing volumes: expected 2, got %s", n_volumes)
|
|
|
|
}
|
|
|
|
|
|
|
|
logDone("start - missing containers in --volumes-from did not affect subsequent runs")
|
|
|
|
}
|