Function TestCall_ContextTimeoutSendsCancel

internal/nodehub/hub_test.go:243–267

---- 测试：ctx 超时 + cancel_id 下发 ----

(t *testing.T)

// ---- 测试：ctx 超时 + cancel_id 下发 ----

func TestCall_ContextTimeoutSendsCancel(t *testing.T) {
	hub := New(Options{PeerExtractor: mdPeerExtractor})
	env := newTestEnv(t, hub)
	cc := env.dial(t)
	mock := startNodeMock(t, cc, "n")
	waitOnline(t, hub, "n")

	mock.silent.Store(true) // 不响应任何请求

	ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond)
	defer cancel()
	_, err := hub.Call(ctx, "n", "slow", nil)
	if !errors.Is(err, context.DeadlineExceeded) {
		t.Fatalf("expected DeadlineExceeded, got %v", err)
	}

	select {
	case id := <-mock.cancelIDs:
		if id == "" {
			t.Fatalf("expected non-empty cancel_id")
		}
	case <-time.After(time.Second):
		t.Fatal("did not receive cancel_id from server")
	}
}

// ---- 测试：ErrNodeOffline ----