revert some code

Signed-off-by: HunDunDM <hundundm@gmail.com>

server/region_syncer/client.go

@@ -134,9 +134,9 @@ func (s *RegionSyncer) StartSyncWithLeader(addr string) {
 				log.Error("cannot establish connection with leader", zap.String("server", s.server.Name()), zap.String("leader", s.server.GetLeader().GetName()), errs.ZapError(err))
 				continue
 			}
+			defer conn.Close()
 			break
 		}
-		defer conn.Close()
 
 		// Start syncing data.
 		for {

server/region_syncer/server.go

@@ -115,8 +115,8 @@ func (s *RegionSyncer) RunServer(ctx context.Context, regionNotifier <-chan *cor
 			return
 		case first := <-regionNotifier:
 			requests = append(requests, first.GetMeta())
-			stats = append(stats, first.GetStat())
-			leaders = append(leaders, first.GetLeader())
+			stats := append(stats, first.GetStat())
+			leaders := append(leaders, first.GetLeader())
 			startIndex := s.history.GetNextIndex()
 			s.history.Record(first)
 			pending := len(regionNotifier)
@@ -143,8 +143,6 @@ func (s *RegionSyncer) RunServer(ctx context.Context, regionNotifier <-chan *cor
 			s.broadcast(alive)
 		}
 		requests = requests[:0]
-		stats = stats[:0]
-		leaders = leaders[:0]
 	}
 }
 
@@ -233,7 +231,6 @@ func (s *RegionSyncer) syncHistoryRegion(ctx context.Context, request *pdpb.Sync
 				lastIndex += len(metas)
 				if err := stream.Send(resp); err != nil {
 					log.Error("failed to send sync region response", errs.ZapError(errs.ErrGRPCSend, err))
-					return err
 				}
 				metas = metas[:0]
 				stats = stats[:0]