From f6c1519ba2330b68266c9577ce94e7d87bd22e74 Mon Sep 17 00:00:00 2001
From: zhangxu <zhangxu19830126@gmail.com>
Date: Sat, 18 Sep 2021 09:51:12 +0800
Subject: [PATCH] Add more log to debug

---
 components/prophet/cluster/cluster.go | 12 +++++++++++-
 raftstore/router.go                   |  8 +++++++-
 2 files changed, 18 insertions(+), 2 deletions(-)

diff --git a/components/prophet/cluster/cluster.go b/components/prophet/cluster/cluster.go
index a20338ff..d6839d09 100644
--- a/components/prophet/cluster/cluster.go
+++ b/components/prophet/cluster/cluster.go
@@ -503,9 +503,11 @@ func (c *RaftCluster) processResourceHeartbeat(res *core.CachedResource) error {
 			if origin.GetLeader().GetID() == 0 {
 				isNew = true
 			} else {
-				util.GetLogger().Infof("resource %d leader changed from container %d to container %d",
+				util.GetLogger().Infof("resource %d leader changed from peer %d-%d to peer %d-%d",
 					res.Meta.ID(),
+					origin.GetLeader().GetID(),
 					origin.GetLeader().GetContainerID(),
+					res.GetLeader().GetID(),
 					res.GetLeader().GetContainerID())
 			}
 			saveCache = true
@@ -618,7 +620,15 @@ func (c *RaftCluster) processResourceHeartbeat(res *core.CachedResource) error {
 		resourceEventCounter.WithLabelValues("update_kv").Inc()
 	}
 	if saveKV || saveCache || isNew {
+		util.GetLogger().Infof("begin to add notify for resource %d leader changed to peer %d-%d",
+			res.Meta.ID(),
+			res.GetLeader().GetID(),
+			res.GetLeader().GetContainerID())
 		c.changedEvents <- event.NewResourceEvent(res.Meta, res.GetLeader().GetID(), false, false)
+		util.GetLogger().Infof("end to add notify for resource %d leader changed to peer %d-%d",
+			res.Meta.ID(),
+			res.GetLeader().GetID(),
+			res.GetLeader().GetContainerID())
 	}
 	if saveCache {
 		c.changedEvents <- event.NewResourceStatsEvent(res.GetStat())
diff --git a/raftstore/router.go b/raftstore/router.go
index 3ee14775..ea5847f8 100644
--- a/raftstore/router.go
+++ b/raftstore/router.go
@@ -141,7 +141,7 @@ func (r *defaultRouter) LeaderPeerStore(shardID uint64) bhmetapb.Store {
 	if value, ok := r.leaders.Load(shardID); ok {
 		return value.(bhmetapb.Store)
 	}
-	logger.Debugf("shard %d missing leader", shardID)
+	logger.Warningf("shard %d missing leader", shardID)
 	return bhmetapb.Store{}
 }
 
@@ -242,6 +242,10 @@ func (r *defaultRouter) updateShard(data []byte, leader uint64, removed bool, cr
 		logger.Fatalf("unmarshal shard failed with %+v", err)
 	}
 
+	if leader > 0 {
+		logger.Infof("shard %d leader changed to %d", res.meta.ID, leader)
+	}
+
 	if removed {
 		r.removedHandleFunc(res.meta.ID)
 		if value, ok := r.keyRanges.Load(res.meta.Group); ok {
@@ -286,12 +290,14 @@ func (r *defaultRouter) updateLeader(shardID, leader uint64) {
 		if p.ID == leader {
 			r.missingStoreLeaderChanged.Delete(shardID)
 			r.leaders.Store(shard.ID, r.mustGetStore(p.ContainerID))
+			logger.Infof("shard %d leader changed to %d, updated", shardID, leader)
 			return
 		}
 	}
 
 	// the shard updated will notify later
 	r.missingStoreLeaderChanged.Store(shardID, leader)
+	logger.Warningf("shard %d leader changed to %d, skipped, missing store", shardID, leader)
 }
 
 func (r *defaultRouter) mustGetStore(id uint64) bhmetapb.Store {