From 4a5d58ead6a4acfb69c46935d0dac1760b0e87a0 Mon Sep 17 00:00:00 2001 From: xichengliudui Date: Tue, 29 Jan 2019 10:10:23 -0500 Subject: [PATCH] Update comments in functions Signed-off-by: xichengliudui --- go/vt/binlog/binlogplayertest/player.go | 6 +++--- go/vt/proto/vtgate/vtgate.pb.go | 2 +- go/vt/schemamanager/schemaswap/schema_swap.go | 2 +- go/vt/vtgate/planbuilder/insert.go | 2 +- go/vt/vtgate/planbuilder/ordered_aggregate.go | 2 +- go/vt/vtgate/scatter_conn.go | 2 +- 6 files changed, 8 insertions(+), 8 deletions(-) diff --git a/go/vt/binlog/binlogplayertest/player.go b/go/vt/binlog/binlogplayertest/player.go index 5c6a76cd949..c8c0155a8d0 100644 --- a/go/vt/binlog/binlogplayertest/player.go +++ b/go/vt/binlog/binlogplayertest/player.go @@ -96,7 +96,7 @@ var testBinlogTransaction = &binlogdatapb.BinlogTransaction{ }, } -// StreamKeyRange is part of the the UpdateStream interface +// StreamKeyRange is part of the UpdateStream interface func (fake *FakeBinlogStreamer) StreamKeyRange(ctx context.Context, position string, keyRange *topodatapb.KeyRange, charset *binlogdatapb.Charset, callback func(reply *binlogdatapb.BinlogTransaction) error) error { if fake.panics { panic(fmt.Errorf("test-triggered panic")) @@ -162,7 +162,7 @@ var testTablesRequest = &tablesRequest{ }, } -// StreamTables is part of the the UpdateStream interface +// StreamTables is part of the UpdateStream interface func (fake *FakeBinlogStreamer) StreamTables(ctx context.Context, position string, tables []string, charset *binlogdatapb.Charset, callback func(reply *binlogdatapb.BinlogTransaction) error) error { if fake.panics { panic(fmt.Errorf("test-triggered panic")) @@ -214,7 +214,7 @@ func testStreamTablesPanics(t *testing.T, bpc binlogplayer.Client) { } } -// HandlePanic is part of the the UpdateStream interface +// HandlePanic is part of the UpdateStream interface func (fake *FakeBinlogStreamer) HandlePanic(err *error) { if x := recover(); x != nil { *err = fmt.Errorf("Caught panic: %v", x) diff --git a/go/vt/proto/vtgate/vtgate.pb.go b/go/vt/proto/vtgate/vtgate.pb.go index d5bebcf6c71..ae204d1e8ac 100644 --- a/go/vt/proto/vtgate/vtgate.pb.go +++ b/go/vt/proto/vtgate/vtgate.pb.go @@ -2803,7 +2803,7 @@ var xxx_messageInfo_ResolveTransactionResponse proto.InternalMessageInfo // SplitQuery takes a "SELECT" query and generates a list of queries called // "query-parts". Each query-part consists of the original query with an // added WHERE clause that restricts the query-part to operate only on -// rows whose values in the the columns listed in the "split_column" field +// rows whose values in the columns listed in the "split_column" field // of the request (see below) are in a particular range. // // It is guaranteed that the set of rows obtained from diff --git a/go/vt/schemamanager/schemaswap/schema_swap.go b/go/vt/schemamanager/schemaswap/schema_swap.go index 6b39ccfb210..2e8e232b54f 100644 --- a/go/vt/schemamanager/schemaswap/schema_swap.go +++ b/go/vt/schemamanager/schemaswap/schema_swap.go @@ -459,7 +459,7 @@ func (schemaSwap *Swap) stopAllHealthWatchers() { } // initializeSwap starts the schema swap process. If there is already a schema swap process started -// the the method just picks up that. Otherwise it starts a new one and writes into the database that +// the method just picks up that. Otherwise it starts a new one and writes into the database that // the process was started. func (schemaSwap *Swap) initializeSwap() error { var waitGroup sync.WaitGroup diff --git a/go/vt/vtgate/planbuilder/insert.go b/go/vt/vtgate/planbuilder/insert.go index 7046dfcdee6..5bef6cde7e4 100644 --- a/go/vt/vtgate/planbuilder/insert.go +++ b/go/vt/vtgate/planbuilder/insert.go @@ -206,7 +206,7 @@ func modifyForAutoinc(ins *sqlparser.Insert, eins *engine.Insert) error { return nil } -// swapBindVariables swaps in bind variable names at the the specified +// swapBindVariables swaps in bind variable names at the specified // column position in the AST values and returns the converted values back. // Bind variable names are generated using baseName. func swapBindVariables(rows sqlparser.Values, colNum int, baseName string) (sqltypes.PlanValue, error) { diff --git a/go/vt/vtgate/planbuilder/ordered_aggregate.go b/go/vt/vtgate/planbuilder/ordered_aggregate.go index 905fe37bdce..30c4ec28317 100644 --- a/go/vt/vtgate/planbuilder/ordered_aggregate.go +++ b/go/vt/vtgate/planbuilder/ordered_aggregate.go @@ -272,7 +272,7 @@ func (oa *orderedAggregate) PushFilter(_ *primitiveBuilder, _ sqlparser.Expr, wh // be performed 'as they come'. In this respect, oa is the originator for // aggregate expressions like MAX, which will be added to symtab. The underlying // MAX sent to the route will not be added to symtab and will not be reachable by -// others. This functionality depends on the the PushOrderBy to request that +// others. This functionality depends on the PushOrderBy to request that // the rows be correctly ordered for a merge sort. func (oa *orderedAggregate) PushSelect(expr *sqlparser.AliasedExpr, origin builder) (rc *resultColumn, colnum int, err error) { if inner, ok := expr.Expr.(*sqlparser.FuncExpr); ok { diff --git a/go/vt/vtgate/scatter_conn.go b/go/vt/vtgate/scatter_conn.go index 8c42c0fa26c..da72bc52787 100644 --- a/go/vt/vtgate/scatter_conn.go +++ b/go/vt/vtgate/scatter_conn.go @@ -700,7 +700,7 @@ func injectShuffleQueryPartsRandomGenerator( return oldRandGen } -// shuffleQueryParts performs an in-place shuffle of the the given array. +// shuffleQueryParts performs an in-place shuffle of the given array. // The result is a psuedo-random permutation of the array chosen uniformally // from the space of all permutations. func shuffleQueryParts(splits []*vtgatepb.SplitQueryResponse_Part) {