geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bschucha...@apache.org
Subject [geode] 02/02: GEODE-3780 suspected member is never watched again after passing final check
Date Wed, 11 Oct 2017 22:47:07 GMT
This is an automated email from the ASF dual-hosted git repository.

bschuchardt pushed a commit to branch feature/GEODE-3780b
in repository https://gitbox.apache.org/repos/asf/geode.git

commit 12416bb99ff7803e6f7d84c6038bc1995be4c1a0
Author: Bruce Schuchardt <bschuchardt@pivotal.io>
AuthorDate: Wed Oct 11 15:25:04 2017 -0700

    GEODE-3780 suspected member is never watched again after passing final check
    
    incorporating review feedback from Hitesh.  We want members other than
    the coordinator to also reconsider the suspected member.  The
    Monitor will now invoke setNextNeighbor at the end of its run() method
    and a final check that passes will result in a message being sent to
    the initiator so that it can start watching the suspect again.
---
 .../internal/membership/gms/fd/GMSHealthMonitor.java   |  1 +
 .../gms/messages/FinalCheckPassedMessage.java          | 18 ++++++++++++++++++
 2 files changed, 19 insertions(+)

diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/fd/GMSHealthMonitor.java
b/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/fd/GMSHealthMonitor.java
index 5a40be1..74109b7 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/fd/GMSHealthMonitor.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/fd/GMSHealthMonitor.java
@@ -263,6 +263,7 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
           // now do check request for this member;
           checkMember(neighbour);
         }
+        setNextNeighbor(currentView, null);
       }
     }
   }
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/FinalCheckPassedMessage.java
b/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/FinalCheckPassedMessage.java
new file mode 100644
index 0000000..f19ddaf
--- /dev/null
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/FinalCheckPassedMessage.java
@@ -0,0 +1,18 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information
regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version
2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain
a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under
the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
express
+ * or implied. See the License for the specific language governing permissions and limitations
under
+ * the License.
+ */
+package org.apache.geode.distributed.internal.membership.gms.messages;
+
+public class FinalCheckPassedMessage {
+}

-- 
To stop receiving notification emails like this one, please contact
"commits@geode.apache.org" <commits@geode.apache.org>.

Mime
View raw message