[geode] 01/01: GEODE-8608: StateFlush could hang when the target member is shutdown

[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);
     }