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 b206139 GEODE-3967: trace into basicPut b206139 is described below commit b2061392860bf28033072aa3304a9c77aba965d3 Author: zhouxh <gz...@pivotal.io> AuthorDate: Thu Jan 18 21:47:24 2018 -0800 GEODE-3967: trace into basicPut --- .../java/org/apache/geode/internal/cache/AbstractRegionMap.java | 6 ++++++ .../org/apache/geode/internal/cache/AbstractUpdateOperation.java | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java index 205dacd..fbd3a67 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java @@ -2824,6 +2824,8 @@ public abstract class AbstractRegionMap implements RegionMap { } // check expectedOldValue if (!satisfiesExpectedOldValue(event, re, expectedOldValue, replaceOnClient)) { + logger.info("GGG:not satisfiesExpectedOldValue:" + event + ":" + expectedOldValue + + ":" + re); return null; } // invoke cacheWriter @@ -2840,9 +2842,11 @@ public abstract class AbstractRegionMap implements RegionMap { // set || !re.isRemoved() || replaceOnClient) { // update + logger.info("GGG:before updateEntry:" + event); updateEntry(event, requireOldValue, oldValueForDelta, re); } else { // create + logger.info("GGG:before createEntry:" + event); createEntry(event, owner, re); } owner.recordEvent(event); @@ -3089,10 +3093,12 @@ public abstract class AbstractRegionMap implements RegionMap { if (!_getOwner().isInitialized() && (oldValueInVM == Token.DESTROYED || oldValueInVM == Token.TOMBSTONE)) { event.setOldValueDestroyedToken(); + logger.info("GGG:1continueOverwriteDestroyed:" + overwriteDestroyed + ":" + oldValueInVM); return false; } } if (ifNew && !Token.isRemoved(oldValueInVM)) { + logger.info("GGG:2continueOverwriteDestroyed:" + overwriteDestroyed + ":" + oldValueInVM); return false; } return true; diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java index 66a11bd..ad38a94 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java @@ -185,7 +185,7 @@ public abstract class AbstractUpdateOperation extends DistributedCacheOperation rgn.getCachePerfStats().endPut(startPut, ev.isOriginRemote()); updated = true; if (logger.isDebugEnabled()) { - logger.debug("GGG:Updated put key " + ev); + logger.debug("GGG:Updated put key " + ev + ":" + overwriteDestroyed); } } else { if (rgn.getVersionVector() != null && ev.getVersionTag() != null) { -- To stop receiving notification emails like this one, please contact ['"commits@geode.apache.org" <commits@geode.apache.org>'].