Function TestManagerConcurrentAccess

internal/loop/manager_test.go:243–264

(t *testing.T)

}

func TestManagerConcurrentAccess(t *testing.T) {
	tmpDir := t.TempDir()
	prdPath := createTestPRDWithName(t, tmpDir, "test-prd")

	m := NewManager(10, testProvider)
	m.Register("test-prd", prdPath)

	// Test concurrent access to manager methods
	var wg sync.WaitGroup
	for i := 0; i < 100; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			_ = m.GetInstance("test-prd")
			_ = m.GetAllInstances()
			_ = m.GetRunningPRDs()
			_ = m.GetRunningCount()
			_, _, _ = m.GetState("test-prd")
		}()
	}
	wg.Wait()
}

func TestLoopStateString(t *testing.T) {
	tests := []struct {