mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-03 09:37:38 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

save

Browse Source
This commit is contained in:
alex.sharov 2021-11-04 16:05:33 +07:00
parent 5d0f081a9c
commit f1a493914f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/sentry/download/sentry.go
View File

@ -883,7 +883,7 @@ func (ss *SentryServerImpl) send(msgID proto_sentry.MessageId, peerID string, b
ch := ss.messageStreams[msgID][i] ch := ss.messageStreams[msgID][i]
ch <- req ch <- req
if len(ch) > MessagesQueueSize/2 { if len(ch) > MessagesQueueSize/2 {
log.Warn("[sentry] consuming is slow", "msgID", msgID.String()) log.Debug("[sentry] consuming is slow, drop 50% of old messages", "msgID", msgID.String())
// evict old messages from channel // evict old messages from channel
for j := 0; j < MessagesQueueSize/4; j++ { for j := 0; j < MessagesQueueSize/4; j++ {
select { select {