renaming

Signed-off-by: Bin Shi <[email protected]>
tikv · Apr 12, 2023 · 79757cb · 79757cb
1 parent e260abd
commit 79757cb
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/pkg/tso/keyspace_group_manager.go b/pkg/tso/keyspace_group_manager.go
@@ -227,7 +227,7 @@ func (kgm *KeyspaceGroupManager) Initialize() error {
 	done := make(chan struct{}, 1)
 	ctx, cancel := context.WithCancel(kgm.ctx)
 	go kgm.checkInitProgress(ctx, cancel, done)
-	watchStartRevision, sawDefaultKeyspaceGroup, err := kgm.initAssignment(ctx)
+	watchStartRevision, defaultKGConfigured, err := kgm.initAssignment(ctx)
 	done <- struct{}{}
 	if err != nil {
 		log.Error("failed to initialize keyspace group manager", errs.ZapError(err))
@@ -237,7 +237,7 @@ func (kgm *KeyspaceGroupManager) Initialize() error {
 	}
 
 	// Initialize the default keyspace group if it isn't configured in the storage.
-	if !sawDefaultKeyspaceGroup {
+	if !defaultKGConfigured {
 		keyspaces := []uint32{mcsutils.DefaultKeyspaceID}
 		kgm.initDefaultKeysapceGroup(keyspaces)
 	}
@@ -292,7 +292,7 @@ func (kgm *KeyspaceGroupManager) initDefaultKeysapceGroup(keyspaces []uint32) {
 // Return watchStartRevision, the start revision for watching keyspace group membership/distribution change.
 func (kgm *KeyspaceGroupManager) initAssignment(
 	ctx context.Context,
-) (watchStartRevision int64, sawDefaultKeyspaceGroup bool, err error) {
+) (watchStartRevision int64, defaultKGConfigured bool, err error) {
 	var (
 		groups               []*endpoint.KeyspaceGroup
 		more                 bool
@@ -323,7 +323,7 @@ func (kgm *KeyspaceGroupManager) initAssignment(
 			}
 
 			if group.ID == mcsutils.DefaultKeyspaceGroupID {
-				sawDefaultKeyspaceGroup = true
+				defaultKGConfigured = true
 			}
 
 			kgm.updateKeyspaceGroup(group)