From 26b418c42f359e5fe54fa73139c0a825afec3eab Mon Sep 17 00:00:00 2001 From: Pascal Fischer Date: Thu, 8 May 2025 16:32:33 +0200 Subject: [PATCH] move sync counter metrics --- management/server/grpcserver.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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()