From cf330f4b459a8808edaa7532ba18531b0096ca21 Mon Sep 17 00:00:00 2001 From: Pascal Fischer Date: Thu, 13 Mar 2025 17:56:48 +0100 Subject: [PATCH] limit update channel to 2 messages only --- management/server/updatechannel.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/management/server/updatechannel.go b/management/server/updatechannel.go index f58ceb53d..62dd7725c 100644 --- a/management/server/updatechannel.go +++ b/management/server/updatechannel.go @@ -31,7 +31,7 @@ type PeersUpdateManager struct { // NewPeersUpdateManager returns a new instance of PeersUpdateManager func NewPeersUpdateManager(metrics telemetry.AppMetrics) *PeersUpdateManager { return &PeersUpdateManager{ - peerChannels: make(map[string]chan *UpdateMessage, 2), + peerChannels: make(map[string]chan *UpdateMessage), channelsMux: &sync.RWMutex{}, metrics: metrics, } @@ -90,7 +90,7 @@ func (p *PeersUpdateManager) CreateChannel(ctx context.Context, peerID string) c close(channel) } // mbragin: todo shouldn't it be more? or configurable? - channel := make(chan *UpdateMessage, channelBufferSize) + channel := make(chan *UpdateMessage, 2) p.peerChannels[peerID] = channel log.WithContext(ctx).Debugf("opened updates channel for a peer %s", peerID)