fix block event

alibaba · Nov 27, 2023 · 16821b2 · 16821b2
1 parent d0600a9
commit 16821b2
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/event/BlockEventManager.h b/core/event/BlockEventManager.h
@@ -50,7 +50,11 @@ 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) {
-                delete mEvent;
+                if (!pEvent->IsReaderFlushTimeout() || mEvent->IsReaderFlushTimeout()) {
+                    delete mEvent;
+                } else {
+                    return;
+                }
             }
             mEvent = pEvent;
             mLogstoreKey = logstoreKey;