From 753f39f089657ecd1dc9ce6c76bc4fa8ed3bd29f Mon Sep 17 00:00:00 2001 From: zirain Date: Tue, 4 Aug 2026 20:45:22 +0800 Subject: [PATCH 1/2] chore: fix wasm stats test Signed-off-by: zirain --- test/e2e/tests/wasm_http.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/test/e2e/tests/wasm_http.go b/test/e2e/tests/wasm_http.go index 095588d874..03d769ff17 100644 --- a/test/e2e/tests/wasm_http.go +++ b/test/e2e/tests/wasm_http.go @@ -80,10 +80,11 @@ var HTTPWasmTest = suite.ConformanceTest{ // filters"), so each of the 2 wasm-configured routes above gets its own dedicated Wasm // filter/VM even though both reference the same underlying .wasm module. The // process-wide "wasm.wasm_vm_count" gauge should therefore read exactly 3* worker thread. + tlog.Logf(t, "concurrency: %d", runtime.NumCPU()) t.Run("wasm vm count is per-route", func(t *testing.T) { promQL := `sum(envoy_wasm_wasm_vm_count{app_kubernetes_io_component="proxy", app_kubernetes_io_managed_by="envoy-gateway", app_kubernetes_io_name="envoy", gateway_envoyproxy_io_owning_gateway_name="same-namespace"})` - // 3 is the count of routes - expectedCount := model.SampleValue(3 * runtime.NumCPU()) + // 2 is the count of routes with WASM + expectedCount := model.SampleValue(2 * (runtime.NumCPU() + 2)) tlog.Logf(t, "expected to got %v", expectedCount) if err := wait.PollUntilContextTimeout(context.TODO(), time.Second, time.Minute, true, func(_ context.Context) (done bool, err error) { From 3df1ab974b041a97c98ac35b8e8ce0cc31ae0297 Mon Sep 17 00:00:00 2001 From: zirain Date: Wed, 5 Aug 2026 15:37:23 +0800 Subject: [PATCH 2/2] update Signed-off-by: zirain --- test/e2e/tests/wasm_http.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/test/e2e/tests/wasm_http.go b/test/e2e/tests/wasm_http.go index 03d769ff17..c3e7c65145 100644 --- a/test/e2e/tests/wasm_http.go +++ b/test/e2e/tests/wasm_http.go @@ -79,7 +79,7 @@ var HTTPWasmTest = suite.ConformanceTest{ // is unique per EnvoyExtensionPolicy wasm entry ("Do not share VMs across different // filters"), so each of the 2 wasm-configured routes above gets its own dedicated Wasm // filter/VM even though both reference the same underlying .wasm module. The - // process-wide "wasm.wasm_vm_count" gauge should therefore read exactly 3* worker thread. + // process-wide "wasm.wasm_vm_count" gauge should therefore read exactly 2* (worker thread +2). tlog.Logf(t, "concurrency: %d", runtime.NumCPU()) t.Run("wasm vm count is per-route", func(t *testing.T) { promQL := `sum(envoy_wasm_wasm_vm_count{app_kubernetes_io_component="proxy", app_kubernetes_io_managed_by="envoy-gateway", app_kubernetes_io_name="envoy", gateway_envoyproxy_io_owning_gateway_name="same-namespace"})`