[geode] branch feature/GEM-883 updated: GEODE-3967: trace into basicPut

[zhouxj]

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>'].