From 45fe02a989df9c7151c925f1f8601ec75ed0846c Mon Sep 17 00:00:00 2001 From: shuting Date: Fri, 13 Jan 2023 16:41:38 +0800 Subject: [PATCH] drop events when queue size is 0 (#5994) Signed-off-by: ShutingZhao Signed-off-by: ShutingZhao --- pkg/event/controller.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/event/controller.go b/pkg/event/controller.go index 8579835931..7284a89f2b 100644 --- a/pkg/event/controller.go +++ b/pkg/event/controller.go @@ -96,7 +96,7 @@ func (gen *Generator) Add(infos ...Info) { logger := gen.log logger.V(3).Info("generating events", "count", len(infos)) - if gen.queue.Len() > gen.maxQueuedEvents { + if gen.maxQueuedEvents == 0 || gen.queue.Len() > gen.maxQueuedEvents { logger.V(2).Info("exceeds the event queue limit, dropping the event", "maxQueuedEvents", gen.maxQueuedEvents, "current size", gen.queue.Len()) return }