You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ki...@apache.org on 2015/08/05 09:34:13 UTC
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
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);