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 <[email protected]> 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);
