diff options
| author | Russ Cox <rsc@golang.org> | 2017-01-18 00:05:32 -0500 |
|---|---|---|
| committer | Joe Tsai <thebrokentoaster@gmail.com> | 2017-01-18 07:44:24 +0000 |
| commit | d10eddcba3e2cc90a822d80e7162f74501141eb8 (patch) | |
| tree | 4127e56d95458ce44b2dcabb57c6f6603cd1b989 /src/testing/testing.go | |
| parent | 2c8b70eacfc3fd2d86bd8e4e4764f11a2e9b3deb (diff) | |
| download | go-d10eddcba3e2cc90a822d80e7162f74501141eb8.tar.xz | |
testing: make parallel t.Run safe again
Fixes #18603.
Change-Id: I5760c0a9f862200b7e943058a672eb559ac1b9d9
Reviewed-on: https://go-review.googlesource.com/35354
Run-TryBot: Russ Cox <rsc@golang.org>
TryBot-Result: Gobot Gobot <gobot@golang.org>
Reviewed-by: Joe Tsai <thebrokentoaster@gmail.com>
Reviewed-by: Brad Fitzpatrick <bradfitz@golang.org>
Diffstat (limited to 'src/testing/testing.go')
| -rw-r--r-- | src/testing/testing.go | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/testing/testing.go b/src/testing/testing.go index c972b2737f..ddbdc25bf1 100644 --- a/src/testing/testing.go +++ b/src/testing/testing.go @@ -216,6 +216,7 @@ import ( "strconv" "strings" "sync" + "sync/atomic" "time" ) @@ -267,8 +268,8 @@ type common struct { skipped bool // Test of benchmark has been skipped. finished bool // Test function has completed. done bool // Test is finished and all subtests have completed. - hasSub bool - raceErrors int // number of races detected during test + hasSub int32 // written atomically + raceErrors int // number of races detected during test parent *common level int // Nesting depth of test or benchmark. @@ -645,7 +646,7 @@ func tRunner(t *T, fn func(t *T)) { // Do not lock t.done to allow race detector to detect race in case // the user does not appropriately synchronizes a goroutine. t.done = true - if t.parent != nil && !t.hasSub { + if t.parent != nil && atomic.LoadInt32(&t.hasSub) == 0 { t.setRan() } t.signal <- true @@ -659,8 +660,11 @@ func tRunner(t *T, fn func(t *T)) { // Run runs f as a subtest of t called name. It reports whether f succeeded. // Run will block until all its parallel subtests have completed. +// +// Run may be called simultaneously from multiple goroutines, but all such +// calls must happen before the outer test function for t returns. func (t *T) Run(name string, f func(t *T)) bool { - t.hasSub = true + atomic.StoreInt32(&t.hasSub, 1) testName, ok := t.context.match.fullName(&t.common, name) if !ok { return true |
