diff --git a/cmd/sentry/download/sentry.go b/cmd/sentry/download/sentry.go index a2004ec15..e2c077eef 100644 --- a/cmd/sentry/download/sentry.go +++ b/cmd/sentry/download/sentry.go @@ -883,7 +883,7 @@ func (ss *SentryServerImpl) send(msgID proto_sentry.MessageId, peerID string, b ch := ss.messageStreams[msgID][i] ch <- req 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 for j := 0; j < MessagesQueueSize/4; j++ { select {