Skip to content

Commit 853bb6f

Browse files
Remove unnecessary param
Signed-off-by: Rohit Nayak <rohit@planetscale.com>
1 parent ff0279f commit 853bb6f

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

go/vt/vttablet/tabletmanager/vdiff/controller.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ type controller struct {
8383
TableDiffPhaseTimings *stats.Timings
8484
}
8585

86-
func newController(ctx context.Context, row sqltypes.RowNamedValues, dbClientFactory func() binlogplayer.DBClient,
86+
func newController(row sqltypes.RowNamedValues, dbClientFactory func() binlogplayer.DBClient,
8787
ts *topo.Server, vde *Engine, options *tabletmanagerdata.VDiffOptions) (*controller, error) {
8888

8989
log.Infof("VDiff controller initializing for %+v", row)

go/vt/vttablet/tabletmanager/vdiff/engine.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -212,7 +212,7 @@ func (vde *Engine) retry(ctx context.Context, err error) {
212212
// addController creates a new controller using the given vdiff record and adds it to the engine.
213213
// You must already have the main engine mutex (mu) locked before calling this.
214214
func (vde *Engine) addController(row sqltypes.RowNamedValues, options *tabletmanagerdata.VDiffOptions) error {
215-
ct, err := newController(vde.ctx, row, vde.dbClientFactoryDba, vde.ts, vde, options)
215+
ct, err := newController(row, vde.dbClientFactoryDba, vde.ts, vde, options)
216216
if err != nil {
217217
return fmt.Errorf("controller could not be initialized for stream %+v on tablet %v",
218218
row, vde.thisTablet.Alias)

go/vt/vttablet/tabletmanager/vdiff/framework_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -693,7 +693,7 @@ func (tvde *testVDiffEnv) createController(t *testing.T, id int) *controller {
693693

694694
func (tvde *testVDiffEnv) newController(t *testing.T, controllerQR *sqltypes.Result) *controller {
695695
ctx := context.Background()
696-
ct, err := newController(ctx, controllerQR.Named().Row(), tvde.dbClientFactory, tstenv.TopoServ, tvde.vde, tvde.opts)
696+
ct, err := newController(controllerQR.Named().Row(), tvde.dbClientFactory, tstenv.TopoServ, tvde.vde, tvde.opts)
697697
require.NoError(t, err)
698698
ctx2, cancel := context.WithCancel(ctx)
699699
ct.cancel = cancel

0 commit comments

Comments
 (0)