Function TestReaper_KeepsActiveConnection

internal/nodehub/keepalive_test.go:56–97

TestReaper_KeepsActiveConnection 验证持续发帧的连接不会被 reaper 误杀。

(t *testing.T)

// TestReaper_KeepsActiveConnection 验证持续发帧的连接不会被 reaper 误杀。
func TestReaper_KeepsActiveConnection(t *testing.T) {
	hub := New(Options{
		PeerExtractor:         mdPeerExtractor,
		DeadConnectionTimeout: 100 * time.Millisecond,
		ReaperInterval:        20 * time.Millisecond,
	})
	env := newTestEnv(t, hub)

	ctx, cancel := context.WithCancel(context.Background())
	t.Cleanup(cancel)
	go hub.RunReaper(ctx)

	cc := env.dial(t)
	mock := startNodeMock(t, cc, "alive-node")
	waitOnline(t, hub, "alive-node")

	stopPing := make(chan struct{})
	defer close(stopPing)
	go func() {
		var seq uint64
		ticker := time.NewTicker(30 * time.Millisecond)
		defer ticker.Stop()
		for {
			select {
			case <-stopPing:
				return
			case <-ticker.C:
				seq++
				mock.pushUsage(seq, []byte(`{}`))
			}
		}
	}()

	// 跑 500ms（>5x DeadConnectionTimeout），节点应一直在线。
	end := time.Now().Add(500 * time.Millisecond)
	for time.Now().Before(end) {
		if !hub.IsOnline("alive-node") {
			t.Fatalf("alive-node was reaped despite continuous traffic")
		}
		time.Sleep(50 * time.Millisecond)
	}
}

// TestServerKeepaliveDefaults 仅做编译/默认填充层面的 sanity check：
// 调用 ListenAndServe 的代码路径会在所有 keepalive 字段为 0 时填充默认值。