Skip to content

Commit

Permalink
Fix comment issues
Browse files Browse the repository at this point in the history
  • Loading branch information
espresso98 committed May 5, 2022
1 parent 52f3043 commit 9b87f06
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 1 deletion.
1 change: 1 addition & 0 deletions config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -261,6 +261,7 @@ func (c *Config) UpdateTempStoragePath() {
}
}

// GetTiKVConfig returns configuration options from tikvcfg
func (c *Config) GetTiKVConfig() *tikvcfg.Config {
return &tikvcfg.Config{
CommitterConcurrency: int(tikvutil.CommitterConcurrency.Load()),
Expand Down
1 change: 0 additions & 1 deletion sessionctx/variable/sysvar.go
Original file line number Diff line number Diff line change
Expand Up @@ -686,7 +686,6 @@ var defaultSysVars = []*SysVar{
return fmt.Sprint(QueryLogMaxLen.Load()), nil
}},
{Scope: ScopeGlobal, Name: TiDBCommitterConcurrency, Value: strconv.Itoa(DefTiDBCommitterConcurrency), Type: TypeInt, MinValue: 1, MaxValue: 10000, SetGlobal: func(s *SessionVars, val string) error {
//CommitterConcurrency.Store(int32(TidbOptInt64(val, DefTiDBCommitterConcurrency)))
cfg := config.GetGlobalConfig().GetTiKVConfig()
tikvcfg.StoreGlobalConfig(cfg)
return nil
Expand Down
1 change: 1 addition & 0 deletions util/tikvutil/tikvutil.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,4 +18,5 @@ import (
"go.uber.org/atomic"
)

// CommitterConcurrency stores the current value of the sysvar tidb_committer_concurrency
var CommitterConcurrency = atomic.NewInt32(128)

0 comments on commit 9b87f06

Please sign in to comment.