This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a commit to branch feature/GEM-883
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEM-883 by this push:
new 42aec6a GEODE-3967: add a case for invalidate
42aec6a is described below
commit 42aec6af306ce00836d3f38eeb22e0c504259a19
Author: zhouxh <[email protected]>
AuthorDate: Thu Nov 16 17:49:55 2017 -0800
GEODE-3967: add a case for invalidate
---
.../main/java/org/apache/geode/internal/cache/DestroyOperation.java | 3 ---
.../org/apache/geode/internal/cache/DistributedCacheOperation.java | 2 +-
.../java/org/apache/geode/internal/cache/LocalRegionDataView.java | 4 ++++
3 files changed, 5 insertions(+), 4 deletions(-)
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.java
b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.java
index 20cbd28..4d376c6 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.java
@@ -95,9 +95,6 @@ public class DestroyOperation extends
DistributedCacheOperation {
} catch (EntryNotFoundException e) {
dispatchElidedEvent(rgn, ev);
- if (!ev.isConcurrencyConflict()) {
- rgn.notifyGatewaySender(EnumListenerEvent.AFTER_DESTROY, ev);
- }
throw e;
} catch (CacheWriterException e) {
throw new Error(
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.java
b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.java
index aa793f8..5ab3a4a 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.java
@@ -1290,7 +1290,7 @@ public abstract class DistributedCacheOperation {
*/
protected void dispatchElidedEvent(LocalRegion rgn, EntryEventImpl ev) {
if (logger.isDebugEnabled()) {
- logger.debug("dispatching elided event: {}", ev);
+ logger.debug("GGG:dispatching elided event: {}", ev, new Exception());
}
ev.isConcurrencyConflict(true);
rgn.generateLocalFilterRouting(ev);
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.java
b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.java
index eed6176..123734a 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.java
@@ -71,6 +71,10 @@ public class LocalRegionDataView implements InternalDataView
{
} catch (ConcurrentCacheModificationException e) {
// a newer event has already been applied to the cache. this can happen
// in a client cache if another thread is operating on the same key
+ event.isConcurrencyConflict(true);
+ LocalRegion lr = event.getLocalRegion();
+ new Exception("GGG:invalidateExistingEntry:" +
event).printStackTrace(System.out);
+ // lr.notifyGatewaySender(EnumListenerEvent.AFTER_INVALIDATE, event);
}
}
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
