You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2020/10/14 05:12:54 UTC
[geode] branch feature/GEM-3093 created (now f9a0832)
This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a change to branch feature/GEM-3093
in repository https://gitbox.apache.org/repos/asf/geode.git.
at f9a0832 GEM-3093: add some trace code
This branch includes the following new commits:
new f9a0832 GEM-3093: add some trace code
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[geode] 01/01: GEM-3093: add some trace code
Posted by 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);