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 17:53:20 UTC
[geode] branch feature/GEODE-8608 created (now 3be1dd6)
This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a change to branch feature/GEODE-8608
in repository https://gitbox.apache.org/repos/asf/geode.git.
at 3be1dd6 GEODE-8608: StateFlush could hang when the target member is shutdown
This branch includes the following new commits:
new 3be1dd6 GEODE-8608: StateFlush could hang when the target member is shutdown
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: GEODE-8608: StateFlush could hang when the target
member is shutdown
Posted by zh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a commit to branch feature/GEODE-8608
in repository https://gitbox.apache.org/repos/asf/geode.git
commit 3be1dd6bbc6ce92ce63b7d615eb7c61d6cc46f82
Author: zhouxh <gz...@pivotal.io>
AuthorDate: Wed Oct 14 10:50:55 2020 -0700
GEODE-8608: StateFlush could hang when the target member is shutdown
Co-authored-by: Darrel Schneider <da...@vmware.com>
Co-authored-by: Anil <ag...@pivotal.io>
Co-authored-by: Bill Burcham <bi...@gmail.com>
---
.../main/java/org/apache/geode/internal/cache/StateFlushOperation.java | 3 +++
1 file changed, 3 insertions(+)
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..46adae0 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,9 @@ public class StateFlushOperation {
@Override
public void memberDeparted(DistributionManager distributionManager,
final InternalDistributedMember id, final boolean crashed) {
+ if (id.equals(targetMember)) {
+ targetMemberHasLeft = true;
+ }
super.memberDeparted(distributionManager, id, crashed);
}