diff --git a/core/event/BlockEventManager.h b/core/event/BlockEventManager.h index 0ad5fcdfc7..690fb14ce9 100644 --- a/core/event/BlockEventManager.h +++ b/core/event/BlockEventManager.h @@ -50,6 +50,9 @@ class BlockedEventManager : public LogstoreFeedBackInterface { BlockedEvent() : mLogstoreKey(0), mEvent(NULL), mInvalidTime(time(NULL)), mTimeout(1) {} void Update(const LogstoreFeedBackKey& logstoreKey, Event* pEvent, int32_t curTime) { if (mEvent != NULL) { + // There are only two situations where event coverage is possible + // 1. the new event is not timeout event + // 2. old event is timeout event if (!pEvent->IsReaderFlushTimeout() || mEvent->IsReaderFlushTimeout()) { delete mEvent; } else {