geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From qih...@apache.org
Subject [17/19] incubator-geode git commit: GEODE-187:AsyncEventQueue with Event Filter test log shows "IllegalStateException" -AbstractGatewaySenderEventProcessor#processqueue iterates events to get filtered. While iterating 2 consditions are checked and event
Date Thu, 06 Aug 2015 17:11:28 GMT
GEODE-187:AsyncEventQueue with Event Filter test log shows "IllegalStateException"
 -AbstractGatewaySenderEventProcessor#processqueue iterates events to get filtered. While
iterating 2 consditions are checked and event is removed in thses both condition. for single
itr.next() when itr.remove is called second time, it causes IllegalStateException.
 -Added 'continue' after first itr.remove is called


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/e4c77c6d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/e4c77c6d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/e4c77c6d

Branch: refs/heads/feature/GEODE-137
Commit: e4c77c6d013fe45ac07762d5a27dfb8144d83fb8
Parents: cb735a2
Author: kbachhav <kbachhav.pivotal.io>
Authored: Wed Aug 5 12:35:10 2015 +0530
Committer: Qihong Chen <qchen@pivotal.io>
Committed: Thu Aug 6 10:07:48 2015 -0700

----------------------------------------------------------------------
 .../internal/cache/wan/AbstractGatewaySenderEventProcessor.java     | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e4c77c6d/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
index 67b3894..6a0392a 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
@@ -499,6 +499,7 @@ public abstract class AbstractGatewaySenderEventProcessor extends Thread
{
                 
                 itr.remove();
                 statistics.incEventsNotQueued();
+                continue;
               }
               
               boolean transmit = filter.beforeTransmit(event);


Mime
View raw message