geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kishorbach...@apache.org
Subject 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 is remo
Date Wed, 05 Aug 2015 07:34:13 GMT
Repository: incubator-geode
Updated Branches:
  refs/heads/develop 8e4c70429 -> 01145b8e9


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/01145b8e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/01145b8e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/01145b8e

Branch: refs/heads/develop
Commit: 01145b8e9eeec8d7fdf8e6fed500ff54021ab609
Parents: 8e4c704
Author: kbachhav <kbachhav.pivotal.io>
Authored: Wed Aug 5 12:35:10 2015 +0530
Committer: kbachhav <kbachhav.pivotal.io>
Committed: Wed Aug 5 12:35:10 2015 +0530

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


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/01145b8e/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