Skip to content

Commit 58faa34

Browse files
[management] Add logs for update channel (#4527)
1 parent 5853b55 commit 58faa34

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

management/server/grpcserver.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,6 +258,7 @@ func (s *GRPCServer) handleUpdates(ctx context.Context, accountID string, peerKe
258258
log.WithContext(ctx).Debugf("received an update for peer %s", peerKey.String())
259259

260260
if err := s.sendUpdate(ctx, accountID, peerKey, peer, update, srv); err != nil {
261+
log.WithContext(ctx).Debugf("error while sending an update to peer %s: %v", peerKey.String(), err)
261262
return err
262263
}
263264

management/server/user.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -965,6 +965,7 @@ func (am *DefaultAccountManager) expireAndUpdatePeers(ctx context.Context, accou
965965

966966
if len(peerIDs) != 0 {
967967
// this will trigger peer disconnect from the management service
968+
log.Debugf("Expiring %d peers for account %s", len(peerIDs), accountID)
968969
am.peersUpdateManager.CloseChannels(ctx, peerIDs)
969970
am.BufferUpdateAccountPeers(ctx, accountID)
970971
}

0 commit comments

Comments
 (0)