Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <[email protected]>
  • Loading branch information
rleungx committed Nov 21, 2024
1 parent 6517e52 commit bf4aed3
Showing 1 changed file with 0 additions and 14 deletions.
14 changes: 0 additions & 14 deletions server/region_syncer/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,11 +36,7 @@ import (
const (
keepaliveTime = 10 * time.Second
keepaliveTimeout = 3 * time.Second
<<<<<<< HEAD:server/region_syncer/client.go
=======
msgSize = 8 * units.MiB
retryInterval = time.Second
>>>>>>> 41ec8dced (syncer: exit watch leader immediately (#8824)):pkg/syncer/client.go
)

// StopSyncWithLeader stop to sync the region with leader.
Expand Down Expand Up @@ -228,17 +224,7 @@ func (s *RegionSyncer) StartSyncWithLeader(addr string) {
log.Debug("region is stale", zap.Stringer("origin", origin.GetMeta()), errs.ZapError(err))
continue
}
<<<<<<< HEAD:server/region_syncer/client.go
_, saveKV, _, _ := regionGuide(region, origin)
=======
cctx := &core.MetaProcessContext{
Context: ctx,
TaskRunner: ratelimit.NewSyncRunner(),
Tracer: core.NewNoopHeartbeatProcessTracer(),
// no limit for followers.
}
saveKV, _, _, _ := regionGuide(cctx, region, origin)
>>>>>>> 41ec8dced (syncer: exit watch leader immediately (#8824)):pkg/syncer/client.go
overlaps := bc.PutRegion(region)

if saveKV {
Expand Down

0 comments on commit bf4aed3

Please sign in to comment.