Function TestConcurrentHasLink

rbac/default-role-manager/role_manager_test.go:396–433

TestConcurrentHasLink tests concurrent HasLink calls for race conditions. This test verifies that concurrent HasLink calls with matching functions don't produce inconsistent results due to temporary role creation/deletion races. Regression test for issue #1318.

(t *testing.T)

// don't produce inconsistent results due to temporary role creation/deletion races.
// Regression test for issue #1318.
func TestConcurrentHasLink(t *testing.T) {
	rm := NewRoleManager(10)
	rm.AddMatchingFunc("keyMatch2", util.KeyMatch2)

	_ = rm.AddLink("alice", "admin")
	_ = rm.AddLink("admin", "/data/*")

	expected, _ := rm.HasLink("alice", "/data/123")

	const numGoroutines = 20
	const numIterations = 100

	var inconsistencies int64
	var wg sync.WaitGroup

	for i := 0; i < numGoroutines; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for j := 0; j < numIterations; j++ {
				result, err := rm.HasLink("alice", "/data/123")
				if err != nil {
					t.Errorf("HasLink failed: %v", err)
					return
				} else if result != expected {
					atomic.AddInt64(&inconsistencies, 1)
				}
			}
		}()
	}

	wg.Wait()

	if inconsistencies > 0 {
		t.Errorf("Found %d inconsistencies in %d total operations",
			inconsistencies, numGoroutines*numIterations)
	}
}