Skip to content

Commit

Permalink
resolve the conflicts
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <[email protected]>
  • Loading branch information
rleungx committed Feb 6, 2024
1 parent fce748e commit 332f767
Showing 1 changed file with 0 additions and 13 deletions.
13 changes: 0 additions & 13 deletions server/grpc_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -1917,20 +1917,7 @@ func (s *GrpcServer) WatchGlobalConfig(req *pdpb.WatchGlobalConfigRequest, serve
if s.client == nil {
return ErrEtcdNotStarted
}
<<<<<<< HEAD
ctx, cancel := context.WithCancel(s.Context())
=======
if s.GetServiceMiddlewarePersistOptions().IsGRPCRateLimitEnabled() {
fName := currentFunction()
limiter := s.GetGRPCRateLimiter()
if done, err := limiter.Allow(fName); err == nil {
defer done()
} else {
return err
}
}
ctx, cancel := context.WithCancel(server.Context())
>>>>>>> 37be34ef1 (*: fix context usage when watch etcd (#7806))
defer cancel()
configPath := req.GetConfigPath()
if configPath == "" {
Expand Down

0 comments on commit 332f767

Please sign in to comment.