Skip to content

Commit

Permalink
func rename
Browse files Browse the repository at this point in the history
Signed-off-by: Tim Vaillancourt <tim@timvaillancourt.com>
  • Loading branch information
timvaillancourt committed Dec 16, 2024
1 parent a1710ba commit 77e93a5
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions go/vt/topo/stats_conn_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -154,8 +154,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) {

Check failure on line 158 in go/vt/topo/stats_conn_test.go

View workflow job for this annotation

GitHub Actions / Unit Test (Race)

undefined: time
if err := testStatsConnReadSem.Acquire(ctx, 1); err != nil {
panic(err)
}
Expand All @@ -169,7 +169,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)

Check failure on line 172 in go/vt/topo/stats_conn_test.go

View workflow job for this annotation

GitHub Actions / Unit Test (Race)

undefined: time
statsConn.ListDir(ctx, "", true)
timingCounts := topoStatsConnTimings.Counts()["ListDir.global"]
if got, want := timingCounts, int64(1); got != want {
Expand Down Expand Up @@ -256,7 +256,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)

Check failure on line 259 in go/vt/topo/stats_conn_test.go

View workflow job for this annotation

GitHub Actions / Unit Test (Race)

undefined: time
statsConn.Get(ctx, "")
timingCounts := topoStatsConnTimings.Counts()["Get.global"]
if got, want := timingCounts, int64(1); got != want {
Expand Down

0 comments on commit 77e93a5

Please sign in to comment.