[geode] 01/01: GEM-3093: add some trace code

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhouxj pushed a commit to branch feature/GEM-3093
in repository https://gitbox.apache.org/repos/asf/geode.git

commit f9a08325533cb5d94072d904305b0f21cc01c6cb
Author: zhouxh <gz...@pivotal.io>
AuthorDate: Tue Oct 13 22:10:31 2020 -0700

    GEM-3093: add some trace code
---
 .../java/org/apache/geode/internal/cache/StateFlushOperation.java   | 1 +
 .../geode/distributed/internal/membership/gms/GMSMembership.java    | 6 +++++-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
index 5f09010..a66803f 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
@@ -772,6 +772,7 @@ public class StateFlushOperation {
     @Override
     public void memberDeparted(DistributionManager distributionManager,
         final InternalDistributedMember id, final boolean crashed) {
+      logger.info("GGG:StateFlushReplyProcesssor.memberDeparted:id=" + id);
       super.memberDeparted(distributionManager, id, crashed);
     }
 
diff --git a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/GMSMembership.java b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/GMSMembership.java
index db2ecae..97f26cc 100644
--- a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/GMSMembership.java
+++ b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/GMSMembership.java
@@ -688,6 +688,8 @@ public class GMSMembership<ID extends MemberIdentifier> implements Membership<ID
       return; // Explicit deletion, no upcall.
     }
 
+    logger.info("GGG:" + shutdownMembers.containsKey(dm) + ":shutdownMembers=" + shutdownMembers
+        + ":dm=" + dm + ":reason=" + reason);
     if (!shutdownMembers.containsKey(dm)) {
       // if we've received a shutdown message then DistributionManager will already have
       // notified listeners
@@ -1243,7 +1245,9 @@ public class GMSMembership<ID extends MemberIdentifier> implements Membership<ID
       logger.debug("Membership: recording shutdown status of {}", id);
     }
     synchronized (this.shutdownMembers) {
-      this.shutdownMembers.put(id, id);
+      Object oldId = this.shutdownMembers.put(id, id);
+      logger.info("GGG:shutdownMessageReceived:id=" + id + ":oldId=" + oldId + ":size="
+          + shutdownMembers.size());
       services.getHealthMonitor()
           .memberShutdown(id, reason);
       services.getJoinLeave().memberShutdown(id, reason);