Skip to content

Commit

Permalink
var rename
Browse files Browse the repository at this point in the history
Signed-off-by: Tim Vaillancourt <[email protected]>
  • Loading branch information
timvaillancourt committed Dec 19, 2024
1 parent bd2a087 commit 895fcb5
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions go/vt/topo/stats_conn_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ import (

var testStatsConnReadSem = semaphore.NewWeighted(1)

func testResetStats() {
func testStatsConnStatsReset() {
topoStatsConnErrors.ResetAll()
topoStatsConnTimings.Reset()
topoStatsConnReadWaitTimings.Reset()
Expand Down Expand Up @@ -202,7 +202,7 @@ func createTestReadSemaphoreContention(ctx context.Context, duration time.Durati

// TestStatsConnTopoListDir emits stats on ListDir
func TestStatsConnTopoListDir(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand All @@ -229,7 +229,7 @@ func TestStatsConnTopoListDir(t *testing.T) {

// TestStatsConnTopoCreate emits stats on Create
func TestStatsConnTopoCreate(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand All @@ -251,7 +251,7 @@ func TestStatsConnTopoCreate(t *testing.T) {

// TestStatsConnTopoUpdate emits stats on Update
func TestStatsConnTopoUpdate(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand All @@ -273,7 +273,7 @@ func TestStatsConnTopoUpdate(t *testing.T) {

// TestStatsConnTopoGet emits stats on Get
func TestStatsConnTopoGet(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand All @@ -300,7 +300,7 @@ func TestStatsConnTopoGet(t *testing.T) {

// TestStatsConnTopoDelete emits stats on Delete
func TestStatsConnTopoDelete(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand All @@ -322,7 +322,7 @@ func TestStatsConnTopoDelete(t *testing.T) {

// TestStatsConnTopoLock emits stats on Lock
func TestStatsConnTopoLock(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand Down Expand Up @@ -350,7 +350,7 @@ func TestStatsConnTopoLock(t *testing.T) {

// TestStatsConnTopoWatch emits stats on Watch
func TestStatsConnTopoWatch(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand All @@ -364,7 +364,7 @@ func TestStatsConnTopoWatch(t *testing.T) {

// TestStatsConnTopoNewLeaderParticipation emits stats on NewLeaderParticipation
func TestStatsConnTopoNewLeaderParticipation(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand All @@ -385,7 +385,7 @@ func TestStatsConnTopoNewLeaderParticipation(t *testing.T) {

// TestStatsConnTopoClose emits stats on Close
func TestStatsConnTopoClose(t *testing.T) {
defer testResetStats()
defer testStatsConnStatsReset()

conn := &fakeConn{}
statsConn := NewStatsConn("global", conn, testStatsConnReadSem)
Expand Down

0 comments on commit 895fcb5

Please sign in to comment.