diff --git a/management/server/grpcserver.go b/management/server/grpcserver.go index 329a58a91..a8b170142 100644 --- a/management/server/grpcserver.go +++ b/management/server/grpcserver.go @@ -175,6 +175,10 @@ func getRealIP(ctx context.Context) net.IP { // Sync validates the existence of a connecting peer, sends an initial state (all available for the connecting peers) and // notifies the connected peer of any updates (e.g. new peers under the same account) func (s *GRPCServer) Sync(req *proto.EncryptedMessage, srv proto.ManagementService_SyncServer) error { + if s.appMetrics != nil { + s.appMetrics.GRPCMetrics().CountSyncRequest() + } + if !s.syncLimiter.Allow() { time.Sleep(time.Second + (time.Millisecond * time.Duration(rand.IntN(20)*100))) log.Warnf("sync rate limit exceeded for peer %s", req.WgPubKey) @@ -182,9 +186,6 @@ func (s *GRPCServer) Sync(req *proto.EncryptedMessage, srv proto.ManagementServi } reqStart := time.Now() - if s.appMetrics != nil { - s.appMetrics.GRPCMetrics().CountSyncRequest() - } ctx := srv.Context()