diff options
author | Cory Snider <csnider@mirantis.com> | 2022-07-25 17:51:33 -0400 |
---|---|---|
committer | Cory Snider <csnider@mirantis.com> | 2022-08-24 14:59:08 -0400 |
commit | 15b8e4a490afb7a4897e909b6f272f1e99445a6c (patch) | |
tree | 80d87e62918f6593ba6fe427b93be323c386e399 | |
parent | 18e322bc7c530d7b4393aca64e70dcad659621e3 (diff) |
integration: synchronize TestWaitConditions
Modifying the builtin Windows runtime to send the exited event
immediately upon the container's init process exiting, without first
waiting for the Compute System to shut down, perturbed the timings
enough to make TestWaitConditions flaky on that platform. Make
TestWaitConditions timing-independent by having the container wait
for input on STDIN before exiting.
Signed-off-by: Cory Snider <csnider@mirantis.com>
-rw-r--r-- | integration/container/wait_test.go | 66 |
1 files changed, 43 insertions, 23 deletions
diff --git a/integration/container/wait_test.go b/integration/container/wait_test.go index 12a9313caa..f8e64f0458 100644 --- a/integration/container/wait_test.go +++ b/integration/container/wait_test.go @@ -108,28 +108,25 @@ func TestWaitConditions(t *testing.T) { cli := request.NewAPIClient(t) testCases := []struct { - doc string - waitCond containertypes.WaitCondition - expectedCode int64 + doc string + waitCond containertypes.WaitCondition + runOpts []func(*container.TestContainerConfig) }{ { - doc: "default", - expectedCode: 99, + doc: "default", }, { - doc: "not-running", - expectedCode: 99, - waitCond: containertypes.WaitConditionNotRunning, + doc: "not-running", + waitCond: containertypes.WaitConditionNotRunning, }, { - doc: "next-exit", - expectedCode: 99, - waitCond: containertypes.WaitConditionNextExit, + doc: "next-exit", + waitCond: containertypes.WaitConditionNextExit, }, { - doc: "removed", - expectedCode: 99, - waitCond: containertypes.WaitConditionRemoved, + doc: "removed", + waitCond: containertypes.WaitConditionRemoved, + runOpts: []func(*container.TestContainerConfig){container.WithAutoRemove}, }, } @@ -138,21 +135,44 @@ func TestWaitConditions(t *testing.T) { t.Run(tc.doc, func(t *testing.T) { t.Parallel() ctx := context.Background() - opts := []func(*container.TestContainerConfig){ - container.WithCmd("sh", "-c", "sleep 1; exit 99"), - } - if tc.waitCond == containertypes.WaitConditionRemoved { - opts = append(opts, container.WithAutoRemove) - } - containerID := container.Run(ctx, t, cli, opts...) - poll.WaitOn(t, container.IsInState(ctx, cli, containerID, "running"), poll.WithTimeout(30*time.Second), poll.WithDelay(100*time.Millisecond)) + opts := append([]func(*container.TestContainerConfig){ + container.WithCmd("sh", "-c", "read -r; exit 99"), + func(tcc *container.TestContainerConfig) { + tcc.Config.AttachStdin = true + tcc.Config.OpenStdin = true + }, + }, tc.runOpts...) + containerID := container.Create(ctx, t, cli, opts...) + t.Logf("ContainerID = %v", containerID) + + streams, err := cli.ContainerAttach(ctx, containerID, types.ContainerAttachOptions{Stream: true, Stdin: true}) + assert.NilError(t, err) + defer streams.Close() + assert.NilError(t, cli.ContainerStart(ctx, containerID, types.ContainerStartOptions{})) waitResC, errC := cli.ContainerWait(ctx, containerID, tc.waitCond) select { case err := <-errC: + t.Fatalf("ContainerWait() err = %v", err) + case res := <-waitResC: + t.Fatalf("ContainerWait() sent exit code (%v) before ContainerStart()", res) + default: + } + + info, _ := cli.ContainerInspect(ctx, containerID) + assert.Equal(t, "running", info.State.Status) + + _, err = streams.Conn.Write([]byte("\n")) + assert.NilError(t, err) + + select { + case err := <-errC: assert.NilError(t, err) case waitRes := <-waitResC: - assert.Check(t, is.Equal(tc.expectedCode, waitRes.StatusCode)) + assert.Check(t, is.Equal(int64(99), waitRes.StatusCode)) + case <-time.After(15 * time.Second): + info, _ := cli.ContainerInspect(ctx, containerID) + t.Fatalf("Timed out waiting for container exit code (status = %q)", info.State.Status) } }) } |