Function TestConnStateMachine_ConcurrentAccess

internal/pool/conn_state_test.go:192–230

(t *testing.T)

}

func TestConnStateMachine_ConcurrentAccess(t *testing.T) {
	sm := NewConnStateMachine()
	sm.Transition(StateIdle)

	const numGoroutines = 100
	const numIterations = 100

	var wg sync.WaitGroup
	var successCount atomic.Int32

	for i := 0; i < numGoroutines; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()

			for j := 0; j < numIterations; j++ {
				// Try to transition from READY to REAUTH_IN_PROGRESS
				_, err := sm.TryTransition([]ConnState{StateIdle}, StateUnusable)
				if err == nil {
					successCount.Add(1)
					// Transition back to READY
					sm.Transition(StateIdle)
				}

				// Read state (hot path)
				_ = sm.GetState()
			}
		}()
	}

	wg.Wait()

	// At least some transitions should have succeeded
	if successCount.Load() == 0 {
		t.Error("expected at least some successful transitions")
	}

	t.Logf("Successful transitions: %d out of %d attempts", successCount.Load(), numGoroutines*numIterations)
}

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