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 c4787b1 commit 5f9c7c8
Showing 1 changed file with 1 addition and 13 deletions.
14 changes: 1 addition & 13 deletions server/region_syncer/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ import (
"context"
"time"

"github.com/docker/go-units"
"github.com/pingcap/errors"
"github.com/pingcap/kvproto/pkg/metapb"
"github.com/pingcap/kvproto/pkg/pdpb"
Expand All @@ -38,11 +39,8 @@ import (
const (
keepaliveTime = 10 * time.Second
keepaliveTimeout = 3 * time.Second
<<<<<<< HEAD:server/region_syncer/client.go
=======
msgSize = 8 * units.MiB

Check failure on line 42 in server/region_syncer/client.go

View workflow job for this annotation

GitHub Actions / statics

other declaration of msgSize

Check failure on line 42 in server/region_syncer/client.go

View workflow job for this annotation

GitHub Actions / tso-function-test

other declaration of msgSize

Check failure on line 42 in server/region_syncer/client.go

View workflow job for this annotation

GitHub Actions / chunks (2)

other declaration of msgSize

Check failure on line 42 in server/region_syncer/client.go

View workflow job for this annotation

GitHub Actions / chunks (4)

other declaration of msgSize

Check failure on line 42 in server/region_syncer/client.go

View workflow job for this annotation

GitHub Actions / chunks (5)

other declaration of msgSize

Check failure on line 42 in server/region_syncer/client.go

View workflow job for this annotation

GitHub Actions / chunks (5)

other declaration of msgSize

Check failure on line 42 in server/region_syncer/client.go

View workflow job for this annotation

GitHub Actions / chunks (9)

other declaration of msgSize
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 @@ -233,17 +231,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 hasBuckets {
Expand Down

0 comments on commit 5f9c7c8

Please sign in to comment.