Skip to content

Commit

Permalink
feat: fix build error
Browse files Browse the repository at this point in the history
Signed-off-by: Manan Gupta <[email protected]>
  • Loading branch information
GuptaManan100 committed Nov 15, 2024
1 parent 5e14251 commit ea2c0d8
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion go/vt/vttablet/tabletserver/health_streamer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -597,7 +597,7 @@ func TestDeadlockBwCloseAndReload(t *testing.T) {
go func() {
defer wg.Done()
for i := 0; i < 100; i++ {
se.BroadcastForTesting(nil, nil, nil, true)
se.BroadcastForTesting(nil, nil, nil)
}
}()

Expand Down
2 changes: 1 addition & 1 deletion go/vt/vttablet/tabletserver/messager/engine_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -193,7 +193,7 @@ func TestDeadlockBwCloseAndSchemaChange(t *testing.T) {
go func() {
defer wg.Done()
for i := 0; i < 100; i++ {
se.BroadcastForTesting(nil, nil, nil, true)
se.BroadcastForTesting(nil, nil, nil)
}
}()

Expand Down
4 changes: 2 additions & 2 deletions go/vt/vttablet/tabletserver/schema/engine.go
Original file line number Diff line number Diff line change
Expand Up @@ -744,10 +744,10 @@ func (se *Engine) broadcast(created, altered, dropped []*Table) {
}

// BroadcastForTesting is meant to be a testing function that triggers a broadcast call.
func (se *Engine) BroadcastForTesting(created, altered, dropped []*Table, udfsChanged bool) {
func (se *Engine) BroadcastForTesting(created, altered, dropped []*Table) {
se.mu.Lock()
defer se.mu.Unlock()
se.broadcast(created, altered, dropped, udfsChanged)
se.broadcast(created, altered, dropped)
}

// GetTable returns the info for a table.
Expand Down

0 comments on commit ea2c0d8

Please sign in to comment.