Function TestManager_ConcurrentApply

internal/sniproxy/manager_test.go:302–340

TestManager_ConcurrentApply 用几个 goroutine 同时 Apply，确保内部锁没问题。

(t *testing.T)

// TestManager_ConcurrentApply 用几个 goroutine 同时 Apply，确保内部锁没问题。
func TestManager_ConcurrentApply(t *testing.T) {
	backend := startEchoTLS(t, "x.example.com")
	ln, _ := net.Listen("tcp", "127.0.0.1:0")
	addr := ln.Addr().String()
	_ = ln.Close()

	m := NewManager(filepath.Join(t.TempDir(), "state.json"))
	defer m.Close()

	var wg sync.WaitGroup
	for i := 0; i < 10; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			_ = m.Apply(ManagerConfig{
				Listen: addr,
				Routes: []Route{{SNI: "x.example.com", Backend: backend, Mode: ModeTransparent}},
			})
		}()
	}
	wg.Wait()

	// 收尾：Listen 应可用
	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
	defer cancel()
	for {
		select {
		case <-ctx.Done():
			t.Fatal("proxy never came up")
		default:
		}
		c, err := net.Dial("tcp", addr)
		if err == nil {
			_ = c.Close()
			return
		}
		time.Sleep(20 * time.Millisecond)
	}
}