Blame SOURCES/remove_waitgroup_misuse_tests.patch

6c08f9
diff --git a/src/sync/waitgroup_test.go b/src/sync/waitgroup_test.go
6c08f9
index c569e0faa2eb..4ded218d2d8d 100644
6c08f9
--- a/src/sync/waitgroup_test.go
6c08f9
+++ b/src/sync/waitgroup_test.go
6c08f9
@@ -5,8 +5,6 @@
6c08f9
 package sync_test
6c08f9
 
6c08f9
 import (
6c08f9
-	"internal/race"
6c08f9
-	"runtime"
6c08f9
 	. "sync"
6c08f9
 	"sync/atomic"
6c08f9
 	"testing"
6c08f9
@@ -48,12 +46,6 @@ func TestWaitGroup(t *testing.T) {
6c08f9
 	}
6c08f9
 }
6c08f9
 
6c08f9
-func knownRacy(t *testing.T) {
6c08f9
-	if race.Enabled {
6c08f9
-		t.Skip("skipping known-racy test under the race detector")
6c08f9
-	}
6c08f9
-}
6c08f9
-
6c08f9
 func TestWaitGroupMisuse(t *testing.T) {
6c08f9
 	defer func() {
6c08f9
 		err := recover()
6c08f9
@@ -68,124 +60,6 @@ func TestWaitGroupMisuse(t *testing.T) {
6c08f9
 	t.Fatal("Should panic")
6c08f9
 }
6c08f9
 
6c08f9
-// pollUntilEqual blocks until v, loaded atomically, is
6c08f9
-// equal to the target.
6c08f9
-func pollUntilEqual(v *uint32, target uint32) {
6c08f9
-	for {
6c08f9
-		for i := 0; i < 1e3; i++ {
6c08f9
-			if atomic.LoadUint32(v) == target {
6c08f9
-				return
6c08f9
-			}
6c08f9
-		}
6c08f9
-		// yield to avoid deadlock with the garbage collector
6c08f9
-		// see issue #20072
6c08f9
-		runtime.Gosched()
6c08f9
-	}
6c08f9
-}
6c08f9
-
6c08f9
-func TestWaitGroupMisuse2(t *testing.T) {
6c08f9
-	knownRacy(t)
6c08f9
-	if runtime.NumCPU() <= 4 {
6c08f9
-		t.Skip("NumCPU<=4, skipping: this test requires parallelism")
6c08f9
-	}
6c08f9
-	defer func() {
6c08f9
-		err := recover()
6c08f9
-		if err != "sync: negative WaitGroup counter" &&
6c08f9
-			err != "sync: WaitGroup misuse: Add called concurrently with Wait" &&
6c08f9
-			err != "sync: WaitGroup is reused before previous Wait has returned" {
6c08f9
-			t.Fatalf("Unexpected panic: %#v", err)
6c08f9
-		}
6c08f9
-	}()
6c08f9
-	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(4))
6c08f9
-	done := make(chan interface{}, 2)
6c08f9
-	// The detection is opportunistic, so we want it to panic
6c08f9
-	// at least in one run out of a million.
6c08f9
-	for i := 0; i < 1e6; i++ {
6c08f9
-		var wg WaitGroup
6c08f9
-		var here uint32
6c08f9
-		wg.Add(1)
6c08f9
-		go func() {
6c08f9
-			defer func() {
6c08f9
-				done <- recover()
6c08f9
-			}()
6c08f9
-			atomic.AddUint32(&here, 1)
6c08f9
-			pollUntilEqual(&here, 3)
6c08f9
-			wg.Wait()
6c08f9
-		}()
6c08f9
-		go func() {
6c08f9
-			defer func() {
6c08f9
-				done <- recover()
6c08f9
-			}()
6c08f9
-			atomic.AddUint32(&here, 1)
6c08f9
-			pollUntilEqual(&here, 3)
6c08f9
-			wg.Add(1) // This is the bad guy.
6c08f9
-			wg.Done()
6c08f9
-		}()
6c08f9
-		atomic.AddUint32(&here, 1)
6c08f9
-		pollUntilEqual(&here, 3)
6c08f9
-		wg.Done()
6c08f9
-		for j := 0; j < 2; j++ {
6c08f9
-			if err := <-done; err != nil {
6c08f9
-				panic(err)
6c08f9
-			}
6c08f9
-		}
6c08f9
-	}
6c08f9
-	t.Fatal("Should panic")
6c08f9
-}
6c08f9
-
6c08f9
-func TestWaitGroupMisuse3(t *testing.T) {
6c08f9
-	knownRacy(t)
6c08f9
-	if runtime.NumCPU() <= 1 {
6c08f9
-		t.Skip("NumCPU==1, skipping: this test requires parallelism")
6c08f9
-	}
6c08f9
-	defer func() {
6c08f9
-		err := recover()
6c08f9
-		if err != "sync: negative WaitGroup counter" &&
6c08f9
-			err != "sync: WaitGroup misuse: Add called concurrently with Wait" &&
6c08f9
-			err != "sync: WaitGroup is reused before previous Wait has returned" {
6c08f9
-			t.Fatalf("Unexpected panic: %#v", err)
6c08f9
-		}
6c08f9
-	}()
6c08f9
-	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(4))
6c08f9
-	done := make(chan interface{}, 3)
6c08f9
-	// The detection is opportunistically, so we want it to panic
6c08f9
-	// at least in one run out of a million.
6c08f9
-	for i := 0; i < 1e6; i++ {
6c08f9
-		var wg WaitGroup
6c08f9
-		wg.Add(1)
6c08f9
-		go func() {
6c08f9
-			defer func() {
6c08f9
-				done <- recover()
6c08f9
-			}()
6c08f9
-			wg.Done()
6c08f9
-		}()
6c08f9
-		go func() {
6c08f9
-			defer func() {
6c08f9
-				done <- recover()
6c08f9
-			}()
6c08f9
-			wg.Wait()
6c08f9
-			// Start reusing the wg before waiting for the Wait below to return.
6c08f9
-			wg.Add(1)
6c08f9
-			go func() {
6c08f9
-				wg.Done()
6c08f9
-			}()
6c08f9
-			wg.Wait()
6c08f9
-		}()
6c08f9
-		go func() {
6c08f9
-			defer func() {
6c08f9
-				done <- recover()
6c08f9
-			}()
6c08f9
-			wg.Wait()
6c08f9
-		}()
6c08f9
-		for j := 0; j < 3; j++ {
6c08f9
-			if err := <-done; err != nil {
6c08f9
-				panic(err)
6c08f9
-			}
6c08f9
-		}
6c08f9
-	}
6c08f9
-	t.Fatal("Should panic")
6c08f9
-}
6c08f9
-
6c08f9
 func TestWaitGroupRace(t *testing.T) {
6c08f9
 	// Run this test for about 1ms.
6c08f9
 	for i := 0; i < 1000; i++ {