[geode] branch feature/GEODE-5087 updated: GEODE-5087: after sender is running, flush the tmpDroppedEvents

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhouxj pushed a commit to branch feature/GEODE-5087
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-5087 by this push:
     new a13e2e0  GEODE-5087: after sender is running, flush the tmpDroppedEvents
a13e2e0 is described below

commit a13e2e0f2bbdf42264dcc95fa97fce1f007edffd
Author: zhouxh <gz...@pivotal.io>
AuthorDate: Tue May 8 23:34:50 2018 -0700

    GEODE-5087: after sender is running, flush the tmpDroppedEvents
---
 .../org/apache/geode/internal/cache/wan/AbstractGatewaySender.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySender.java b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySender.java
index 3b55989..57d2c78 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySender.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySender.java
@@ -866,6 +866,11 @@ public abstract class AbstractGatewaySender implements GatewaySender, Distributi
         }
         return;
       }
+      // process tmpDroppedEvents
+      EntryEventImpl droppedEvent = null;
+      while ((droppedEvent = tmpDroppedEvents.poll()) != null) {
+        this.eventProcessor.registerEventDroppedInPrimaryQueue(droppedEvent);
+      }
 
       final GatewaySenderStats stats = getStatistics();
       stats.incEventsReceived();

-- 
To stop receiving notification emails like this one, please contact
zhouxj@apache.org.