From 91e9640bc5edd1c150a3ab864a13c234e11b4daf Mon Sep 17 00:00:00 2001 From: Tim Vaillancourt Date: Mon, 16 Dec 2024 19:33:06 +0100 Subject: [PATCH] func rename Signed-off-by: Tim Vaillancourt --- go/vt/topo/stats_conn_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/go/vt/topo/stats_conn_test.go b/go/vt/topo/stats_conn_test.go index 2dfc64bea01..9bc1d51d9ed 100644 --- a/go/vt/topo/stats_conn_test.go +++ b/go/vt/topo/stats_conn_test.go @@ -184,8 +184,8 @@ func (st *fakeConn) IsReadOnly() bool { return st.readOnly } -// createSemaphoreContention simulates semaphore contention on the test read semaphore. -func createSemaphoreContention(ctx context.Context, duration time.Duration) { +// createTestReadSemaphoreContention simulates semaphore contention on the test read semaphore. +func createTestReadSemaphoreContention(ctx context.Context, duration time.Duration) { if err := testStatsConnReadSem.Acquire(ctx, 1); err != nil { panic(err) } @@ -199,7 +199,7 @@ func TestStatsConnTopoListDir(t *testing.T) { statsConn := NewStatsConn("global", conn, testStatsConnReadSem) ctx := context.Background() - go createSemaphoreContention(ctx, 100*time.Millisecond) + go createTestReadSemaphoreContention(ctx, 100*time.Millisecond) statsConn.ListDir(ctx, "", true) timingCounts := topoStatsConnTimings.Counts()["ListDir.global"] if got, want := timingCounts, int64(1); got != want { @@ -286,7 +286,7 @@ func TestStatsConnTopoGet(t *testing.T) { statsConn := NewStatsConn("global", conn, testStatsConnReadSem) ctx := context.Background() - go createSemaphoreContention(ctx, time.Millisecond*100) + go createTestReadSemaphoreContention(ctx, time.Millisecond*100) statsConn.Get(ctx, "") timingCounts := topoStatsConnTimings.Counts()["Get.global"] if got, want := timingCounts, int64(1); got != want {