Merge pull request #10200 from cpuguy83/fix_racey_TestAttachAfterDetach

Fix racey TestAttachAfterDetach

integration-cli/docker_cli_attach_unix_test.go

@@ -97,29 +97,40 @@ func TestAttachAfterDetach(t *testing.T) {
 	cmd.Stdout = tty
 	cmd.Stderr = tty
 
+	if err := cmd.Start(); err != nil {
+		t.Fatal(err)
+	}
+
+	bytes := make([]byte, 10)
+	var nBytes int
+	readErr := make(chan error, 1)
+
 	go func() {
-		if err := cmd.Run(); err != nil {
+		time.Sleep(500 * time.Millisecond)
-			t.Fatalf("attach returned error %s", err)
+		cpty.Write([]byte("\n"))
-		}
+		time.Sleep(500 * time.Millisecond)
-		cpty.Close() // unblocks the reader in case of a failure
+
+		nBytes, err = cpty.Read(bytes)
+		cpty.Close()
+		readErr <- err
 	}()
 
-	time.Sleep(500 * time.Millisecond)
+	select {
-	cpty.Write([]byte("\n"))
+	case err := <-readErr:
-	time.Sleep(500 * time.Millisecond)
+		if err != nil {
-	bytes := make([]byte, 10)
+			t.Fatal(err)
-
+		}
-	n, err := cpty.Read(bytes)
+	case <-time.After(2 * time.Second):
-
+		t.Fatal("timeout waiting for attach read")
-	if err != nil {
-		t.Fatalf("prompt read failed: %v", err)
 	}
 
-	if !strings.Contains(string(bytes[:n]), "/ #") {
+	if err := cmd.Wait(); err != nil {
-		t.Fatalf("failed to get a new prompt. got %s", string(bytes[:n]))
+		t.Fatal(err)
 	}
 
-	cpty.Write([]byte("exit\n"))
+	if !strings.Contains(string(bytes[:nBytes]), "/ #") {
+		t.Fatalf("failed to get a new prompt. got %s", string(bytes[:nBytes]))
+	}
 
 	logDone("attach - reconnect after detaching")
 }