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 <[email protected]> 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 <[email protected]> Co-authored-by: Anil <[email protected]> Co-authored-by: Bill Burcham <[email protected]> --- .../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); }
