add lgo

Signed-off-by: lhy1024 <[email protected]>
lhy1024 · Oct 30, 2024 · 34312f0 · 34312f0
1 parent fc71a95
commit 34312f0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/pkg/schedule/checker/checker_controller.go b/pkg/schedule/checker/checker_controller.go
@@ -17,6 +17,7 @@ package checker
 import (
 	"bytes"
 	"context"
+	"fmt"
 	"strconv"
 	"sync"
 	"time"
@@ -496,6 +497,7 @@ func (c *Controller) IsPatrolRegionChanEmpty() bool {
 	if c.patrolRegionContext == nil {
 		return true
 	}
+	fmt.Println("IsPatrolRegionChanEmpty", len(c.patrolRegionContext.regionChan))
 	return len(c.patrolRegionContext.regionChan) == 0
 }
 

diff --git a/server/cluster/cluster_test.go b/server/cluster/cluster_test.go
@@ -2957,7 +2957,7 @@ func TestPatrolRegionConcurrency(t *testing.T) {
 	re.NoError(failpoint.Enable("github.com/tikv/pd/pkg/schedule/checker/breakPatrol", `return`))
 	checker.PatrolRegions()
 	testutil.Eventually(re, func() bool {
-		fmt.Println(len(oc.GetOperators()))
+		fmt.Println("TestPatrolRegionConcurrency", len(oc.GetOperators()))
 		return len(oc.GetOperators()) >= mergeScheduleLimit
 	})
 	checkOperatorDuplicate(re, oc.GetOperators())