diff --git a/xds/internal/clients/xdsclient/test/helpers_test.go b/xds/internal/clients/xdsclient/test/helpers_test.go index 16453c8052f3..600aa8af31de 100644 --- a/xds/internal/clients/xdsclient/test/helpers_test.go +++ b/xds/internal/clients/xdsclient/test/helpers_test.go @@ -296,5 +296,5 @@ func (r *testMetricsReporter) waitForMetric(ctx context.Context, metricsDataWant // ReportMetric sends the metrics data to the metricsCh channel. func (r *testMetricsReporter) ReportMetric(m any) { - r.metricsCh.Send(m) + r.metricsCh.Replace(m) } diff --git a/xds/internal/clients/xdsclient/test/metrics_test.go b/xds/internal/clients/xdsclient/test/metrics_test.go index 008573615477..91053dd1a79e 100644 --- a/xds/internal/clients/xdsclient/test/metrics_test.go +++ b/xds/internal/clients/xdsclient/test/metrics_test.go @@ -40,7 +40,7 @@ import ( // to send valid and invalid LDS updates, and verifies that the expected metrics // for both good and bad updates are emitted. func (s) TestResourceUpdateMetrics(t *testing.T) { - ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout*1000) + ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout) defer cancel() tmr := newTestMetricsReporter()