diff --git a/management/server/grpcserver.go b/management/server/grpcserver.go index 27d54e6c2..60a00207e 100644 --- a/management/server/grpcserver.go +++ b/management/server/grpcserver.go @@ -258,6 +258,7 @@ func (s *GRPCServer) handleUpdates(ctx context.Context, accountID string, peerKe log.WithContext(ctx).Debugf("received an update for peer %s", peerKey.String()) if err := s.sendUpdate(ctx, accountID, peerKey, peer, update, srv); err != nil { + log.WithContext(ctx).Debugf("error while sending an update to peer %s: %v", peerKey.String(), err) return err } diff --git a/management/server/user.go b/management/server/user.go index 3c7c3f433..d40d33c6a 100644 --- a/management/server/user.go +++ b/management/server/user.go @@ -965,6 +965,7 @@ func (am *DefaultAccountManager) expireAndUpdatePeers(ctx context.Context, accou if len(peerIDs) != 0 { // this will trigger peer disconnect from the management service + log.Debugf("Expiring %d peers for account %s", len(peerIDs), accountID) am.peersUpdateManager.CloseChannels(ctx, peerIDs) am.BufferUpdateAccountPeers(ctx, accountID) }