You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by qi...@apache.org on 2015/08/06 19:11:28 UTC
[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
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 <qc...@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);