address comments

Signed-off-by: nolouch <nolouch@gmail.com>

server/cluster_info.go

@@ -504,7 +504,7 @@ func (c *clusterInfo) handleRegionHeartbeat(region *core.RegionInfo) error {
 			return ErrRegionIsStale(region.GetMeta(), origin.GetMeta())
 		}
 		if r.GetVersion() > o.GetVersion() {
-			log.Info("Region Version Changed",
+			log.Info("region Version changed",
 				zap.Uint64("region-id", region.GetID()),
 				zap.String("detail", core.DiffRegionKeyInfo(origin, region)),
 				zap.Uint64("old-version", o.GetVersion()),
@@ -513,7 +513,7 @@ func (c *clusterInfo) handleRegionHeartbeat(region *core.RegionInfo) error {
 			saveKV, saveCache = true, true
 		}
 		if r.GetConfVer() > o.GetConfVer() {
-			log.Info("Region ConfVer Changed",
+			log.Info("region ConfVer changed",
 				zap.Uint64("region-id", region.GetID()),
 				zap.String("detail", core.DiffRegionPeersInfo(origin, region)),
 				zap.Uint64("old-confver", o.GetConfVer()),
@@ -525,7 +525,7 @@ func (c *clusterInfo) handleRegionHeartbeat(region *core.RegionInfo) error {
 			if origin.GetLeader().GetId() == 0 {
 				isNew = true
 			} else {
-				log.Info("Leader Changed",
+				log.Info("leader changed",
 					zap.Uint64("region-id", region.GetID()),
 					zap.Uint64("from", origin.GetLeader().GetStoreId()),
 					zap.Uint64("to", region.GetLeader().GetStoreId()),
@@ -581,7 +581,7 @@ func (c *clusterInfo) handleRegionHeartbeat(region *core.RegionInfo) error {
 				if err := c.kv.DeleteRegion(item); err != nil {
 					log.Error("fail to delete region from kv",
 						zap.Uint64("region-id", item.GetId()),
-						zap.Stringer("region-meta", core.HexRegionMeta(item)),
+						zap.Reflect("region-meta", core.HexRegionMeta(item)),
 						zap.Error(err))
 				}
 			}

server/coordinator.go

@@ -222,7 +222,7 @@ func (c *coordinator) run() {
 	scheduleCfg.Schedulers = scheduleCfg.Schedulers[:k]
 	c.cluster.opt.store(scheduleCfg)
 	if err := c.cluster.opt.persist(c.cluster.kv); err != nil {
-		log.Error("can't persist schedule config", zap.Error(err))
+		log.Error("cannot persist schedule config", zap.Error(err))
 	}
 
 	c.wg.Add(1)

server/grpc_service.go

@@ -653,7 +653,7 @@ func (s *Server) UpdateGCSafePoint(ctx context.Context, request *pdpb.UpdateGCSa
 		if err := s.kv.SaveGCSafePoint(newSafePoint); err != nil {
 			return nil, err
 		}
-		log.Info("updated gc safe point suces",
+		log.Info("updated gc safe point",
 			zap.Uint64("safe-point", newSafePoint))
 	} else if newSafePoint < oldSafePoint {
 		log.Warn("trying to update gc safe point",

server/heartbeat_stream_test.go

@@ -114,7 +114,7 @@ func newRegionheartbeatClient(c *C, grpcClient pdpb.PDClient) *regionHeartbeatCl
 
 func (c *regionHeartbeatClient) close() {
 	if err := c.stream.CloseSend(); err != nil {
-		log.Error("Failed to terminate client stream", zap.Error(err))
+		log.Error("failed to terminate client stream", zap.Error(err))
 	}
 }
 

server/join.go

@@ -177,14 +177,14 @@ func PrepareJoinCluster(cfg *Config) error {
 func isDataExist(d string) bool {
 	dir, err := os.Open(d)
 	if err != nil {
-		log.Error("failed to open", zap.Error(err))
+		log.Error("failed to open directory", zap.Error(err))
 		return false
 	}
 	defer dir.Close()
 
 	names, err := dir.Readdirnames(-1)
 	if err != nil {
-		log.Error("failed to list", zap.Error(err))
+		log.Error("failed to list directory", zap.Error(err))
 		return false
 	}
 	return len(names) != 0

server/leader.go

@@ -354,7 +354,7 @@ func (s *Server) watchLeader(leader *pdpb.Member, revision int64) {
 // ResignLeader resigns current PD's leadership. If nextLeader is empty, all
 // other pd-servers can campaign.
 func (s *Server) ResignLeader(nextLeader string) error {
-	log.Info("tries to resign leader to next leader", zap.String("from", s.Name()), zap.String("to", nextLeader))
+	log.Info("try to resign leader to next leader", zap.String("from", s.Name()), zap.String("to", nextLeader))
 	// Determine next leaders.
 	var leaderIDs []uint64
 	res, err := etcdutil.ListEtcdMembers(s.client)