|
@@ -379,7 +379,7 @@ func TestConcurrentRegistryAccess(t *testing.T) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// exercise race detector
|
|
// exercise race detector
|
|
|
-func TestRegisterAndRegisteredConcurrency(t *testing.T) {
|
|
|
|
|
|
|
+func TestRegisterAndRegisteredConcurrency(t *testing.T) {
|
|
|
r := NewRegistry()
|
|
r := NewRegistry()
|
|
|
wg := &sync.WaitGroup{}
|
|
wg := &sync.WaitGroup{}
|
|
|
wg.Add(1)
|
|
wg.Add(1)
|
|
@@ -390,4 +390,4 @@ func TestRegisterAndRegisteredConcurrency(t *testing.T) {
|
|
|
}(r, wg)
|
|
}(r, wg)
|
|
|
r.Register("foo", NewCounter())
|
|
r.Register("foo", NewCounter())
|
|
|
wg.Wait()
|
|
wg.Wait()
|
|
|
-}
|
|
|
|
|
|
|
+}
|