Replicate PerResultWaiterCount to fake_consolidator

bgwines · bgwines · commit b087b67b3d7f · 2026-04-15T17:25:51.000-07:00
diff --git a/go/sync2/fake_consolidator.go b/go/sync2/fake_consolidator.go
@@ -53,10 +53,10 @@ type FakePendingResult struct {
 	WaitCalls int
 	// AddWaiterCounterCalls can be used to inspect AddWaiterCounter calls.
 	AddWaiterCounterCalls []int64
-	// WaiterCount simulates the current waiter count
 	WaiterCount int64
-	err         error
-	result      *sqltypes.Result
+	PerResultWaiterCount int64
+	err                  error
+	result               *sqltypes.Result
 }
 
 var (
@@ -118,7 +118,7 @@ func (fr *FakePendingResult) Wait() {
 }
 
 func (fr *FakePendingResult) HasWaiters() bool {
-	return fr.WaiterCount > 0
+	return fr.PerResultWaiterCount > 0
 }
 
 // AddWaiterCounter records the call and simulates waiter count changes.

Original file line number	Diff line number	Diff line change
`@@ -53,10 +53,10 @@ type FakePendingResult struct {`
`53`	`53`	`WaitCalls int`
`54`	`54`	`// AddWaiterCounterCalls can be used to inspect AddWaiterCounter calls.`
`55`	`55`	`AddWaiterCounterCalls []int64`
`56`		`- // WaiterCount simulates the current waiter count`
`57`	`56`	`WaiterCount int64`
`58`		`- err error`
`59`		`- result *sqltypes.Result`
	`57`	`+ PerResultWaiterCount int64`
	`58`	`+ err error`
	`59`	`+ result *sqltypes.Result`
`60`	`60`	`}`
`61`	`61`
`62`	`62`	`var (`
`@@ -118,7 +118,7 @@ func (fr *FakePendingResult) Wait() {`
`118`	`118`	`}`
`119`	`119`
`120`	`120`	`func (fr *FakePendingResult) HasWaiters() bool {`
`121`		`- return fr.WaiterCount > 0`
	`121`	`+ return fr.PerResultWaiterCount > 0`
`122`	`122`	`}`
`123`	`123`
`124`	`124`	`// AddWaiterCounter records the call and simulates waiter count changes.`