Add logutil.LogPanic()

Signed-off-by: JmPotato <ghzpotato@gmail.com>

pkg/keyspace/tso_keyspace_group.go

@@ -1015,6 +1015,7 @@
 
 // MergeAllIntoDefaultKeyspaceGroup merges all other keyspace groups into the default keyspace group.
 func (m *GroupManager) MergeAllIntoDefaultKeyspaceGroup() error {
+	defer logutil.LogPanic()
 	mergedGroupNum := 0
 	for i := 0; i < int(endpoint.UserKindCount); i++ {
 		userKind := endpoint.UserKind(i)
@@ -1022,7 +1023,7 @@
 			zap.Stringer("user-kind", userKind))
 		groups, ok := m.groups[userKind]
 		if !ok || groups.Len() == 0 {
 			continue
 		}
 		var (
 			maxBatchSize  = MaxEtcdTxnOps/2 - 1
@@ -1042,12 +1043,12 @@
 				zap.Int("merged-group-num", mergedGroupNum))
 			// Reach the batch size, merge them into the default keyspace group.
 			if err := m.MergeKeyspaceGroups(utils.DefaultKeyspaceGroupID, groupsToMerge); err != nil {
 				log.Error("failed to merge all keyspace groups into the default one",
 					zap.Int("index", idx),
 					zap.Int("batch-size", len(groupsToMerge)),
 					zap.Int("merged-group-num", mergedGroupNum),
 					zap.Error(err))
 				return err
 			}
 			// Wait for the merge to finish.
 			ctx, cancel := context.WithTimeout(m.ctx, time.Minute)
@@ -1055,25 +1056,25 @@
 		checkLoop:
 			for {
 				select {
 				case <-ctx.Done():
 					log.Info("cancel merging all keyspace groups into the default one",
 						zap.Int("index", idx),
 						zap.Int("batch-size", len(groupsToMerge)),
 						zap.Int("merged-group-num", mergedGroupNum))
 					cancel()
 					ticker.Stop()
 					return nil
 				case <-ticker.C:
 					kg, err := m.GetKeyspaceGroupByID(utils.DefaultKeyspaceGroupID)
 					if err != nil {
 						log.Error("failed to check the default keyspace group merge state",
 							zap.Int("index", idx),
 							zap.Int("batch-size", len(groupsToMerge)),
 							zap.Int("merged-group-num", mergedGroupNum),
 							zap.Error(err))
 						cancel()
 						ticker.Stop()
 						return err
 					}
 					if !kg.IsMergeTarget() {
 						break checkLoop