geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bschucha...@apache.org
Subject [geode] branch develop updated: GEODE-3780 suspected member is never watched again after passing final check
Date Fri, 13 Oct 2017 15:07:46 GMT
This is an automated email from the ASF dual-hosted git repository.

bschuchardt pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/develop by this push:
     new 081bccd  GEODE-3780 suspected member is never watched again after passing final check
081bccd is described below

commit 081bccd8391709381f2b3c4cce3b1cf6df49b1ce
Author: Bruce Schuchardt <bschuchardt@pivotal.io>
AuthorDate: Fri Oct 13 08:04:58 2017 -0700

    GEODE-3780 suspected member is never watched again after passing final check
    
    A member going through a final health check is now put in the
    suspected members collection and a new "neighbour" is selected for
    the background monitor thread, ensuring that it doesn't interfere
    with the health check.  Once the health check is done the member is
    removed from the suspected members collection and a new "neighbour"
    is selected, allowing the monitor thread to once again consider the
    suspected member.
    
    A message is also sent to the node that initiated suspicion so that
    it also will resume watching the formerly suspect member.
---
 .../membership/gms/fd/GMSHealthMonitor.java        | 28 ++++++--
 .../gms/messages/FinalCheckPassedMessage.java      | 71 +++++++++++++++++++
 .../geode/internal/DataSerializableFixedID.java    |  1 +
 .../gms/fd/GMSHealthMonitorJUnitTest.java          | 81 ++++++++++++++++++++--
 .../codeAnalysis/sanctionedDataSerializables.txt   | 44 ++++++------
 5 files changed, 193 insertions(+), 32 deletions(-)

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 e62fee8..30d083d 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
@@ -14,6 +14,7 @@
  */
 package org.apache.geode.distributed.internal.membership.gms.fd;
 
+import static org.apache.geode.internal.DataSerializableFixedID.FINAL_CHECK_PASSED_MESSAGE;
 import static org.apache.geode.internal.DataSerializableFixedID.HEARTBEAT_REQUEST;
 import static org.apache.geode.internal.DataSerializableFixedID.HEARTBEAT_RESPONSE;
 import static org.apache.geode.internal.DataSerializableFixedID.SUSPECT_MEMBERS_MESSAGE;
@@ -31,6 +32,7 @@ import org.apache.geode.distributed.internal.membership.gms.GMSMember;
 import org.apache.geode.distributed.internal.membership.gms.Services;
 import org.apache.geode.distributed.internal.membership.gms.interfaces.HealthMonitor;
 import org.apache.geode.distributed.internal.membership.gms.interfaces.MessageHandler;
+import org.apache.geode.distributed.internal.membership.gms.messages.FinalCheckPassedMessage;
 import org.apache.geode.distributed.internal.membership.gms.messages.HeartbeatMessage;
 import org.apache.geode.distributed.internal.membership.gms.messages.HeartbeatRequestMessage;
 import org.apache.geode.distributed.internal.membership.gms.messages.SuspectMembersMessage;
@@ -263,6 +265,7 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
           // now do check request for this member;
           checkMember(neighbour);
         }
+        setNextNeighbor(currentView, null);
       }
     }
   }
@@ -861,7 +864,7 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
    * It becomes null when we suspect current neighbour, during that time it watches member
next to
    * suspect member.
    */
-  private synchronized void setNextNeighbor(NetView newView, InternalDistributedMember nextTo)
{
+  protected synchronized void setNextNeighbor(NetView newView, InternalDistributedMember
nextTo) {
     if (newView == null) {
       return;
     }
@@ -933,6 +936,7 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
     services.getMessenger().addHandler(HeartbeatRequestMessage.class, this);
     services.getMessenger().addHandler(HeartbeatMessage.class, this);
     services.getMessenger().addHandler(SuspectMembersMessage.class, this);
+    services.getMessenger().addHandler(FinalCheckPassedMessage.class, this);
   }
 
   @Override
@@ -1017,7 +1021,9 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
 
   @Override
   public void memberSuspected(InternalDistributedMember initiator,
-      InternalDistributedMember suspect, String reason) {}
+      InternalDistributedMember suspect, String reason) {
+    suspectedMemberInView.putIfAbsent(suspect, currentView);
+  }
 
   @Override
   public void beSick() {
@@ -1074,6 +1080,9 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
           processSuspectMembersRequest((SuspectMembersMessage) m);
         }
         break;
+      case FINAL_CHECK_PASSED_MESSAGE:
+        contactedBy(((FinalCheckPassedMessage) m).getSuspect());
+        break;
       default:
         throw new IllegalArgumentException("unknown message type: " + m);
     }
@@ -1266,7 +1275,7 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
     }
   }
 
-  private boolean inlineCheckIfAvailable(final InternalDistributedMember initiator,
+  protected boolean inlineCheckIfAvailable(final InternalDistributedMember initiator,
       final NetView cv, boolean initiateRemoval, final InternalDistributedMember mbr,
       final String reason) {
 
@@ -1277,6 +1286,8 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
     boolean failed = false;
 
     membersInFinalCheck.add(mbr);
+    setNextNeighbor(currentView, mbr);
+
     try {
       services.memberSuspected(initiator, mbr, reason);
       long startTime = System.currentTimeMillis();
@@ -1321,13 +1332,22 @@ public class GMSHealthMonitor implements HealthMonitor, MessageHandler
{
               "Final check failed but detected recent message traffic for suspect member
" + mbr);
         }
       }
+
       if (!failed) {
+        if (!isStopping && !initiator.equals(localAddress)
+            && initiator.getVersionObject().compareTo(Version.GEODE_130) >= 0)
{
+          // let the sender know that it's okay to monitor this member again
+          FinalCheckPassedMessage message = new FinalCheckPassedMessage(initiator, mbr);
+          services.getMessenger().send(message);
+        }
+
         logger.info("Final check passed for suspect member " + mbr);
       }
+    } finally {
       // whether it's alive or not, at this point we allow it to
       // be watched again
       suspectedMemberInView.remove(mbr);
-    } finally {
+      setNextNeighbor(currentView, null);
       membersInFinalCheck.remove(mbr);
     }
     return !failed;
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..3f3b278
--- /dev/null
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/FinalCheckPassedMessage.java
@@ -0,0 +1,71 @@
+/*
+ * 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;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+import org.apache.geode.DataSerializer;
+import org.apache.geode.distributed.internal.DistributionManager;
+import org.apache.geode.distributed.internal.HighPriorityDistributionMessage;
+import org.apache.geode.distributed.internal.membership.InternalDistributedMember;
+import org.apache.geode.internal.Version;
+
+public class FinalCheckPassedMessage extends HighPriorityDistributionMessage {
+
+  private InternalDistributedMember suspect;
+
+  public FinalCheckPassedMessage(InternalDistributedMember recipient,
+      InternalDistributedMember suspect) {
+    super();
+    setRecipient(recipient);
+    this.suspect = suspect;
+  }
+
+  @Override
+  public int getDSFID() {
+    return FINAL_CHECK_PASSED_MESSAGE;
+  }
+
+  @Override
+  public void process(DistributionManager dm) {
+    throw new IllegalStateException("this message is not intended to execute in a thread
pool");
+  }
+
+  @Override
+  public String toString() {
+    return "FinalCheckPassedMessage [suspect=" + suspect + "]";
+  }
+
+  @Override
+  public Version[] getSerializationVersions() {
+    return null;
+  }
+
+  @Override
+  public void toData(DataOutput out) throws IOException {
+    DataSerializer.writeObject(suspect, out);
+  }
+
+  @Override
+  public void fromData(DataInput in) throws IOException, ClassNotFoundException {
+    suspect = (InternalDistributedMember) DataSerializer.readObject(in);
+  }
+
+  public InternalDistributedMember getSuspect() {
+    return suspect;
+  }
+}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/DataSerializableFixedID.java
b/geode-core/src/main/java/org/apache/geode/internal/DataSerializableFixedID.java
index b4fbac7..7f8cd5d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/DataSerializableFixedID.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/DataSerializableFixedID.java
@@ -68,6 +68,7 @@ public interface DataSerializableFixedID extends SerializationVersions {
    * 
    * In DSFIDFactory, add a case for the new class case FOO: return new FOO(in);
    */
+  public static final short FINAL_CHECK_PASSED_MESSAGE = -158;
   public static final short NETWORK_PARTITION_MESSAGE = -157;
   public static final short SUSPECT_MEMBERS_MESSAGE = -156;
 
diff --git a/geode-core/src/test/java/org/apache/geode/distributed/internal/membership/gms/fd/GMSHealthMonitorJUnitTest.java
b/geode-core/src/test/java/org/apache/geode/distributed/internal/membership/gms/fd/GMSHealthMonitorJUnitTest.java
index 5365307..2d0d0cd 100644
--- a/geode-core/src/test/java/org/apache/geode/distributed/internal/membership/gms/fd/GMSHealthMonitorJUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/distributed/internal/membership/gms/fd/GMSHealthMonitorJUnitTest.java
@@ -25,6 +25,7 @@ import org.apache.geode.distributed.internal.membership.gms.fd.GMSHealthMonitor.
 import org.apache.geode.distributed.internal.membership.gms.interfaces.JoinLeave;
 import org.apache.geode.distributed.internal.membership.gms.interfaces.Manager;
 import org.apache.geode.distributed.internal.membership.gms.interfaces.Messenger;
+import org.apache.geode.distributed.internal.membership.gms.messages.FinalCheckPassedMessage;
 import org.apache.geode.distributed.internal.membership.gms.messages.HeartbeatMessage;
 import org.apache.geode.distributed.internal.membership.gms.messages.HeartbeatRequestMessage;
 import org.apache.geode.distributed.internal.membership.gms.messages.SuspectMembersMessage;
@@ -55,7 +56,9 @@ import java.util.Properties;
 import java.util.concurrent.TimeUnit;
 
 import static org.apache.geode.distributed.ConfigurationProperties.*;
+import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotEquals;
 import static org.junit.Assert.assertTrue;
 import static org.mockito.Matchers.any;
 import static org.mockito.Matchers.isA;
@@ -156,8 +159,8 @@ public class GMSHealthMonitorJUnitTest {
 
     gmsHealthMonitor.processMessage(new HeartbeatRequestMessage(mbr, 1));
     verify(messenger, atLeastOnce()).send(any(HeartbeatMessage.class));
-    Assert.assertEquals(1, gmsHealthMonitor.getStats().getHeartbeatRequestsReceived());
-    Assert.assertEquals(1, gmsHealthMonitor.getStats().getHeartbeatsSent());
+    assertEquals(1, gmsHealthMonitor.getStats().getHeartbeatRequestsReceived());
+    assertEquals(1, gmsHealthMonitor.getStats().getHeartbeatsSent());
   }
 
   /**
@@ -166,7 +169,7 @@ public class GMSHealthMonitorJUnitTest {
   @Test
   public void testHMNextNeighborVerify() throws IOException {
     installAView();
-    Assert.assertEquals(mockMembers.get(myAddressIndex + 1), gmsHealthMonitor.getNextNeighbor());
+    assertEquals(mockMembers.get(myAddressIndex + 1), gmsHealthMonitor.getNextNeighbor());
   }
 
   // @Category(FlakyTest.class) // GEODE-2073
@@ -215,7 +218,7 @@ public class GMSHealthMonitorJUnitTest {
     System.out.println("next neighbor is " + gmsHealthMonitor.getNextNeighbor() + "\nmy address
is "
         + mockMembers.get(myAddressIndex) + "\nview is " + joinLeave.getView());
 
-    Assert.assertEquals(mockMembers.get(myAddressIndex + 1), gmsHealthMonitor.getNextNeighbor());
+    assertEquals(mockMembers.get(myAddressIndex + 1), gmsHealthMonitor.getNextNeighbor());
   }
 
   /***
@@ -476,6 +479,72 @@ public class GMSHealthMonitorJUnitTest {
 
 
   @Test
+  public void testNeighborRemainsSameAfterSuccessfulFinalCheck() {
+    useGMSHealthMonitorTestClass = true;
+
+    try {
+      NetView v = installAView();
+
+      setFailureDetectionPorts(v);
+
+      InternalDistributedMember memberToCheck = gmsHealthMonitor.getNextNeighbor();
+
+      gmsHealthMonitor.setNextNeighbor(v, memberToCheck);
+      assertNotEquals(memberToCheck, gmsHealthMonitor.getNextNeighbor());
+
+      boolean retVal = gmsHealthMonitor.checkIfAvailable(memberToCheck, "Not responding",
true);
+
+      assertTrue("CheckIfAvailable should have return true", retVal);
+      // we should now be watching the same member
+      assertEquals(memberToCheck, gmsHealthMonitor.getNextNeighbor());
+
+    } finally {
+      useGMSHealthMonitorTestClass = false;
+    }
+  }
+
+
+  @Test
+  public void testExonerationMessageIsSentAfterSuccessfulFinalCheck() {
+    useGMSHealthMonitorTestClass = true;
+
+    try {
+      NetView v = installAView();
+
+      setFailureDetectionPorts(v);
+
+      InternalDistributedMember memberToCheck = gmsHealthMonitor.getNextNeighbor();
+
+      gmsHealthMonitor.setNextNeighbor(v, memberToCheck);
+      assertNotEquals(memberToCheck, gmsHealthMonitor.getNextNeighbor());
+
+      boolean retVal = gmsHealthMonitor.inlineCheckIfAvailable(mockMembers.get(0), v, true,
+          memberToCheck, "Not responding");
+
+      assertTrue("CheckIfAvailable should have return true", retVal);
+      verify(messenger, atLeastOnce()).send(isA(FinalCheckPassedMessage.class));
+
+    } finally {
+      useGMSHealthMonitorTestClass = false;
+    }
+  }
+
+
+  @Test
+  public void testInitiatorRewatchesSuspectAfterSuccessfulFinalCheck() {
+    NetView v = installAView();
+
+    setFailureDetectionPorts(v);
+
+    InternalDistributedMember memberToCheck = gmsHealthMonitor.getNextNeighbor();
+    gmsHealthMonitor.memberSuspected(mockMembers.get(0), memberToCheck, "Not responding");
+    assertTrue(gmsHealthMonitor.isSuspectMember(memberToCheck));
+    gmsHealthMonitor.processMessage(new FinalCheckPassedMessage(mockMembers.get(0), memberToCheck));
+    assertFalse(gmsHealthMonitor.isSuspectMember(memberToCheck));
+  }
+
+
+  @Test
   public void testShutdown() {
 
     installAView();
@@ -584,7 +653,7 @@ public class GMSHealthMonitorJUnitTest {
     // verify the written bytes are as expected
     DataInputStream dis = new DataInputStream(new ByteArrayInputStream(outputStream.toByteArray()));
     int byteReply = dis.read();
-    Assert.assertEquals(expectedResult, byteReply);
+    assertEquals(expectedResult, byteReply);
 
     Assert.assertTrue(gmsHealthMonitor.getStats().getFinalCheckResponsesSent() > 0);
     Assert.assertTrue(gmsHealthMonitor.getStats().getTcpFinalCheckResponsesSent() > 0);
@@ -652,7 +721,7 @@ public class GMSHealthMonitorJUnitTest {
     when(fakeSocket.getOutputStream()).thenReturn(outputStream);
     when(fakeSocket.isConnected()).thenReturn(true);
 
-    Assert.assertEquals(expectedResult, gmsHealthMonitor.doTCPCheckMember(otherMember, fakeSocket));
+    assertEquals(expectedResult, gmsHealthMonitor.doTCPCheckMember(otherMember, fakeSocket));
     Assert.assertTrue(gmsHealthMonitor.getStats().getFinalCheckRequestsSent() > 0);
     Assert.assertTrue(gmsHealthMonitor.getStats().getTcpFinalCheckRequestsSent() > 0);
     Assert.assertTrue(gmsHealthMonitor.getStats().getFinalCheckResponsesReceived() > 0);
diff --git a/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
b/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
index 3cc48c7..56f79cb 100644
--- a/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
+++ b/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
@@ -316,6 +316,10 @@ org/apache/geode/distributed/internal/membership/gms/locator/GetViewResponse,2
 fromData,12,2a2bb80005c00006b50002b1
 toData,9,2ab400022bb80004b1
 
+org/apache/geode/distributed/internal/membership/gms/messages/FinalCheckPassedMessage,2
+fromData,12,2a2bb80010c00011b50003b1
+toData,9,2ab400032bb8000fb1
+
 org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage,2
 fromData,11,2a2bb900110100b50002b1
 toData,11,2b2ab40002b900100200b1
@@ -755,8 +759,8 @@ fromData,16,2a2bb700072a2bb900080100b50005b1
 toData,16,2a2bb700092b2ab40005b9000a0200b1
 
 org/apache/geode/internal/admin/remote/ShutdownAllRequest,2
-fromData,6,2a2bb70044b1
-toData,6,2a2bb70045b1
+fromData,6,2a2bb70045b1
+toData,6,2a2bb70046b1
 
 org/apache/geode/internal/admin/remote/ShutdownAllResponse,2
 fromData,16,2a2bb700072a2bb900080100b50002b1
@@ -966,19 +970,19 @@ org/apache/geode/internal/cache/DistributedPutAllOperation$PutAllEntryData,1
 toData,229,2ab4000a4d2ab4000c4e2c2bb8003d2dc1003e9a00072dc700182b03b9003f02002dc0003ec0003e2bb80040a700312dc1004199001e2dc000413a042b04b9003f02001904b9004201002bb80040a7000f2b04b9003f02002d2bb800432b2ab40012b40044b9003f02002ab4000636042ab40026c6000a150407809136042ab40017c6001d15041008809136042ab40017c1004599000b150410208091360415041080809136042b1504b9003f02002ab40026c6000b2ab400262bb8003d2ab40017c6000b2ab400172bb800462ab6002899000b2ab400142bb800462ab400082bb80047b1
 
 org/apache/geode/internal/cache/DistributedPutAllOperation$PutAllMessage,2
-fromData,197,2a2bb700392a2bb8003ac0003bb500052a2bb8003c88b500152a2ab40015bd003db500062ab400159e00722bb8003e4dbb003f59b700404e03360415042ab40015a200202ab400061504bb003d592b2ab4000515042c2db7004153840401a7ffdd2bb9004201003604150499002f2bb800433a0503360615062ab40015a2001d2ab4000615063219051506b60044c00045b5002b840601a7ffe02ab400461140007e99000e2a2bb8003ac00047b5000b2a2ab400461180007e99000704a7000403b5001ab1
-toData,165,2a2bb700482ab400052bb800492ab40015852bb8004a2ab400159e007bbb004b592ab40015b7004c4d033e03360415042ab40015a200511d9a00122ab40006150432b4002bc60005043e2ab40006150432b4002b3a052c1905b6004d572ab4000615043201b5002b2ab400061504322bb6004e2ab400061504321905b5002b840401a7ffac2b1db9004f02001d9900082c2bb800502ab4000bc6000b2ab4000b2bb80049b1
+fromData,197,2a2bb7003a2a2bb8003bc0003cb500052a2bb8003d88b500152a2ab40015bd003eb500062ab400159e00722bb8003f4dbb004059b700414e03360415042ab40015a200202ab400061504bb003e592b2ab4000515042c2db7004253840401a7ffdd2bb9004301003604150499002f2bb800443a0503360615062ab40015a2001d2ab4000615063219051506b60045c00046b5002c840601a7ffe02ab400471140007e99000e2a2bb8003bc00048b5000b2a2ab400471180007e99000704a7000403b5001ab1
+toData,165,2a2bb700492ab400052bb8004a2ab40015852bb8004b2ab400159e007bbb004c592ab40015b7004d4d033e03360415042ab40015a200511d9a00122ab40006150432b4002cc60005043e2ab40006150432b4002c3a052c1905b6004e572ab4000615043201b5002c2ab400061504322bb6004f2ab400061504321905b5002c840401a7ffac2b1db9005002001d9900082c2bb800512ab4000bc6000b2ab4000b2bb8004ab1
 
 org/apache/geode/internal/cache/DistributedRegionFunctionStreamingMessage,2
-fromData,171,2a2bb700632bb9006401003d1c047e9900142a2bb900650100b500092ab40009b800661c077e99000d2a2bb900650100b500061c057e99000e2a2bb80067c00068b500072bb800674e2dc100699900252a03b5000e2a2dc00069b8006ab500082ab40008c7001b2a2dc00069b5004ea700102a2dc0006bb500082a04b5000e2a2bb80067c0006cb5000a2a2bb8006db5000c2a2bb8006eb5000b2a1c10407e99000704a7000403b5000db1
-toData,173,2a2bb70070033d2ab400099900081c0480933d2ab40006029f00081c0780933d2ab40007c600081c0580933d2ab4000d9900091c104080933d2b1cb9007102002ab4000999000d2b2ab40009b9007202002ab40006029f000d2b2ab40006b9007202002ab40007c6000b2ab400072bb800732ab4000e99000e2ab400082bb80073a700102ab40008b9005901002bb800732ab4000a2bb800732ab4000cc000742bb800752ab4000b2bb80076b1
+fromData,171,2a2bb700642bb9006501003d1c047e9900142a2bb900660100b500092ab40009b800671c077e99000d2a2bb900660100b500061c057e99000e2a2bb80068c00069b500072bb800684e2dc1006a9900252a03b5000e2a2dc0006ab8006bb500082ab40008c7001b2a2dc0006ab5004fa700102a2dc0006cb500082a04b5000e2a2bb80068c0006db5000a2a2bb8006eb5000c2a2bb8006fb5000b2a1c10407e99000704a7000403b5000db1
+toData,173,2a2bb70071033d2ab400099900081c0480933d2ab40006029f00081c0780933d2ab40007c600081c0580933d2ab4000d9900091c104080933d2b1cb9007202002ab4000999000d2b2ab40009b9007302002ab40006029f000d2b2ab40006b9007302002ab40007c6000b2ab400072bb800742ab4000e99000e2ab400082bb80074a700102ab40008b9005a01002bb800742ab4000a2bb800742ab4000cc000752bb800762ab4000b2bb80077b1
 
 org/apache/geode/internal/cache/DistributedRemoveAllOperation$RemoveAllEntryData,1
 toData,136,2ab4000a4d2c2bb800412b2ab40010b40042b9004302002ab400063e2ab40024c600081d0780913e2ab40015c600191d100880913e2ab40015c100449900091d102080913e1d108080913e2b1db9004302002ab40024c6000b2ab400242bb800412ab40015c6000b2ab400152bb800452ab6002699000b2ab400122bb800452ab400082bb80046b1
 
 org/apache/geode/internal/cache/DistributedRemoveAllOperation$RemoveAllMessage,2
-fromData,197,2a2bb700382a2bb80039c0003ab500052a2bb8003b88b500152a2ab40015bd003cb500062ab400159e00722bb8003d4dbb003e59b7003f4e03360415042ab40015a200202ab400061504bb003c592b2ab4000515042c2db7004053840401a7ffdd2bb9004101003604150499002f2bb800423a0503360615062ab40015a2001d2ab4000615063219051506b60043c00044b5002b840601a7ffe02ab400451140007e99000e2a2bb80039c00046b5000b2a2ab400451180007e99000704a7000403b5001ab1
-toData,165,2a2bb700472ab400052bb800482ab40015852bb800492ab400159e007bbb004a592ab40015b7004b4d033e03360415042ab40015a200511d9a00122ab40006150432b4002bc60005043e2ab40006150432b4002b3a052c1905b6004c572ab4000615043201b5002b2ab400061504322bb6004d2ab400061504321905b5002b840401a7ffac2b1db9004e02001d9900082c2bb8004f2ab4000bc6000b2ab4000b2bb80048b1
+fromData,197,2a2bb700392a2bb8003ac0003bb500052a2bb8003c88b500152a2ab40015bd003db500062ab400159e00722bb8003e4dbb003f59b700404e03360415042ab40015a200202ab400061504bb003d592b2ab4000515042c2db7004153840401a7ffdd2bb9004201003604150499002f2bb800433a0503360615062ab40015a2001d2ab4000615063219051506b60044c00045b5002c840601a7ffe02ab400461140007e99000e2a2bb8003ac00047b5000b2a2ab400461180007e99000704a7000403b5001ab1
+toData,165,2a2bb700482ab400052bb800492ab40015852bb8004a2ab400159e007bbb004b592ab40015b7004c4d033e03360415042ab40015a200511d9a00122ab40006150432b4002cc60005043e2ab40006150432b4002c3a052c1905b6004d572ab4000615043201b5002c2ab400061504322bb6004e2ab400061504321905b5002c840401a7ffac2b1db9004f02001d9900082c2bb800502ab4000bc6000b2ab4000b2bb80049b1
 
 org/apache/geode/internal/cache/DistributedTombstoneOperation$TombstoneMessage,2
 fromData,125,2a2bb700172ab800182bb90019010032b5001a2bb9001b01003d2abb001c591cb7001db500122bb9001e01003e03360415041ca2003e1d990019bb001f59b700203a0619062bb8002119063a05a700092bb800223a052ab4001219052bb900230100b80024b90025030057840401a7ffc22a2bb80026c00027b50004b1
@@ -1002,10 +1006,6 @@ fromDataPre_GFE_8_0_0_0,33,2a2bb80041b500042bb80041b800424d2a2cb80043b500092a2cb
 toData,97,2bb8003c4d2cb20033b600349c00292ab20036b6002e4ebb001059b20036b7003d3a042d1904b600151904b600162bb8003ea7000b2ab400042bb8003e2ab400092ab4000bb8003a2bb8003e2b2ab4000cb9003f02002b2ab40001b900400200b1
 toDataPre_GFE_8_0_0_0,24,2ab400042bb8003e2ab400092ab4000bb8003a2bb8003eb1
 
-org/apache/geode/internal/cache/EventTracker$EventSeqnoHolder,2
-fromData,22,2a2bb9000e0100b500042a2bb8000fc00010b50005b1
-toData,19,2b2ab40004b9001103002ab400052bb80012b1
-
 org/apache/geode/internal/cache/EvictionAttributesImpl,2
 fromData,33,2a2bb9001b0100b500072a2bb8001cc0001db500052a2bb8001cc0001eb50003b1
 toData,27,2b2ab40007b9001902002ab400052bb8001a2ab400032bb8001ab1
@@ -1075,8 +1075,8 @@ fromData,16,2a2bb7000d2a2bb9000e0100b50002b1
 toData,16,2a2bb7000f2b2ab40002b900100200b1
 
 org/apache/geode/internal/cache/InitialImageOperation$Entry,2
-fromData,89,2a2bb900150100b500032bb9001501003d2a2bb80016b5000f2ab40003b8001199000d2ab20017b50002a7000b2a2bb80018b500022a2bb900190100b500041c047e9900162a1c057e99000704a70004032bb8001ab5000ab1
-toData,101,2b2ab40003b9000c02002ab4000ac6000704a70004033d1c2ab4000ac1000e99000705a700040380913d2b1cb9000c02002ab4000f2bb800102ab40003b800119a000b2ab400022bb800122b2ab40004b9001303002ab4000ac6000b2ab4000a2bb80014b1
+fromData,89,2a2bb900150100b500032bb9001501003d2a2bb80016b5000a2ab40003b8001199000d2ab20017b50002a7000b2a2bb80018b500022a2bb900190100b500041c047e9900162a1c057e99000704a70004032bb8001ab5000bb1
+toData,101,2b2ab40003b9000d02002ab4000bc6000704a70004033d1c2ab4000bc1000f99000705a700040380913d2b1cb9000d02002ab4000a2bb800102ab40003b800119a000b2ab400022bb800122b2ab40004b9001303002ab4000bc6000b2ab4000b2bb80014b1
 
 org/apache/geode/internal/cache/InitialImageOperation$FilterInfoMessage,2
 fromData,230,2a2bb7008f2a2bb80090b5001f2ab4000403322bb80090b5003e2ab4000403322bb80090b500412ab4000403322bb80090b500432ab4000403322bb80090b500452ab4000403322bb80090b500472ab4000403322bb80090b500492ab4000403322bb80090b5004b2ab4000403322bb80090b5004d2ab4000404322bb80090b5003e2ab4000404322bb80090b500412ab4000404322bb80090b500432ab4000404322bb80090b500452ab4000404322bb80090b500472ab4000404322bb80090b500492ab4000404322bb80090b5004b2ab4000404322bb80090b5004d2a2bb80090b50033b1
@@ -1139,8 +1139,8 @@ fromData,26,2a2bb700232a2bb900240100b500042a2bb900240100b50002b1
 toData,26,2a2bb700212b2ab40004b9002202002b2ab40002b900220200b1
 
 org/apache/geode/internal/cache/MemberFunctionStreamingMessage,2
-fromData,163,2a2bb700512bb9005201003d1c047e9900142a2bb900530100b500082ab40008b800541c077e99000d2a2bb900530100b500051c057e99000e2a2bb80055c00056b500062bb800554e2dc1002a9900252a03b5000a2a2dc0002ab80057b500072ab40007c7001b2a2dc0002ab5001aa700102a2dc00058b500072a04b5000a2a2bb80055b500092a2bb80055c00059b500102a1c10407e99000704a7000403b5000bb1
-toData,162,2a2bb7005b033d2ab400089900081c0480933d2ab40005029f00081c0780933d2ab40006c600081c0580933d2ab4000b9900091c104080933d2b1cb9005c02002ab4000899000d2b2ab40008b9005d02002ab40005029f000d2b2ab40005b9005d02002ab40006c6000b2ab400062bb8005e2ab4000a99000e2ab400072bb8005ea700102ab40007b9001f01002bb8005e2ab400092bb8005e2ab400102bb8005eb1
+fromData,163,2a2bb700522bb9005301003d1c047e9900142a2bb900540100b500082ab40008b800551c077e99000d2a2bb900540100b500051c057e99000e2a2bb80056c00057b500062bb800564e2dc1002b9900252a03b5000a2a2dc0002bb80058b500072ab40007c7001b2a2dc0002bb5001ba700102a2dc00059b500072a04b5000a2a2bb80056b500092a2bb80056c0005ab500102a1c10407e99000704a7000403b5000bb1
+toData,162,2a2bb7005c033d2ab400089900081c0480933d2ab40005029f00081c0780933d2ab40006c600081c0580933d2ab4000b9900091c104080933d2b1cb9005d02002ab4000899000d2b2ab40008b9005e02002ab40005029f000d2b2ab40005b9005e02002ab40006c6000b2ab400062bb8005f2ab4000a99000e2ab400072bb8005fa700102ab40007b9002001002bb8005f2ab400092bb8005f2ab400102bb8005fb1
 
 org/apache/geode/internal/cache/Node,2
 fromData,60,2abb001c59b7001db500052ab400052bb8001e2a2bb9001f0100b500032a2bb900200100b500042a2bb900210100b500152a2bb9001f0100b50006b1
@@ -1440,8 +1440,8 @@ org/apache/geode/internal/cache/control/MemoryThresholds$MemoryState,1
 toData,12,2ab60009b8000a2bb8000bb1
 
 org/apache/geode/internal/cache/control/ResourceAdvisor$ResourceManagerProfile,2
-fromData,66,2a2bb7001f2bb900200100412bb800213a042bb800223a052a2019041905b60023572bb90020010037062bb800213a082bb800223a092a160619081909b6002457b1
-toData,99,2a593a0ac22ab40005412ab400063a042ab400043a052ab4000237062ab400033a082ab400013a09190ac3a7000b3a0b190ac3190bbf2a2bb700252b20b90026030019042bb6002719052bb600282b1606b90026030019082bb6002719092bb60028b1
+fromData,66,2a2bb700202bb900210100412bb800223a042bb800233a052a2019041905b60024572bb90021010037062bb800223a082bb800233a092a160619081909b6002557b1
+toData,99,2a593a0ac22ab40005412ab400063a042ab400043a052ab4000237062ab400033a082ab400013a09190ac3a7000b3a0b190ac3190bbf2a2bb700262b20b90027030019042bb6002819052bb600292b1606b90027030019082bb6002819092bb60029b1
 
 org/apache/geode/internal/cache/control/ResourceAdvisor$ResourceProfileMessage,2
 fromData,84,2a2bb7001d2a2bb9001e0100b500032bb9001e01003d1c029f00362a1cbd0004b50005033e1d2ab40005bea20020bb000459b7001f3a0419042bb800202ab400051d190453840301a7ffdda700082a01b50005b1
@@ -1928,8 +1928,8 @@ fromData,145,2bb9001c01003d1c99000e2abb001d59b7001eb500062a1cb500052bb9001f01003
 toData,202,2b2ab40005b9001202002ab4000fc600b42ab4000cb9000b01003d2b1cb900130200033e1d1ca200992ab4000c1db9000d02003a042ab4000f1d3336052ab400059900112ab400061db9000d02002bb80014150506a0000d2b06b900150200a7001a150505a0000d2b05b900150200a7000a2b04b900150200150504a0001c1904c100169900142b1904c00016c00016b900170200a70024150505a000181904b800182bb800191904b6001a2bb8001ba7000919042bb80014840301a7ff68a7000a2b03b900130200b1
 
 org/apache/geode/internal/cache/tier/sockets/RemoveClientFromBlacklistMessage,2
-fromData,14,2a2bb7001b2a2bb8001cb50010b1
-toData,14,2a2bb700182ab400102bb80019b1
+fromData,14,2a2bb700172a2bb80018b5000ab1
+toData,14,2a2bb700142ab4000a2bb80015b1
 
 org/apache/geode/internal/cache/tier/sockets/SerializedObjectPartList,2
 fromData,145,2bb9001401003d1c99000e2abb001559b70016b5000a2a1cb500032bb9001701003e2a1dbc08b500051d9e006603360415041da2005d1c9900152bb800183a052ab4000a1905b900190200572bb9001a010036052ab400051504150554150505a000182bb8001b3a071907b8001c3a062bb8001d57a700092bb8001b3a062ab400061906b90019020057840401a7ffa3b1
@@ -2061,8 +2061,8 @@ fromData,16,2a2bb7000e2a2bb9000f0100b50005b1
 toData,16,2a2bb7000c2b2ab40005b9000d0200b1
 
 org/apache/geode/management/internal/cli/domain/DataCommandResult,2
-fromData,133,2a2bb800b3b500232a2bb800b4b500112a2bb800b4b5000b2a2bb800b5b5001d2a2bb800b4c0004fb5001b2a2bb800b6b60055b5002f2a2bb800b4b500172a2bb800b4b500092a2bb800b4b500142a2bb800b4c000b7b5002c2a2bb800b3b5001e2a2bb800b3b5002e2a2bb800b3b500332a2bb800b3b500342a2bb800b6b60055b5002db1
-toData,140,2ab400232bb800ae2b2ab40023b900af02002ab400112bb800b02ab4000b2bb800b02ab4001b2bb800b02ab4001dc0006a2bb800b12ab4002fb8003c2bb800b22ab400172bb800b02ab400092bb800b02ab400142bb800b02ab4002c2bb800b02ab4001e2bb800ae2ab4002e2bb800ae2ab400332bb800ae2ab400342bb800ae2ab4002db8003c2bb800b2b1
+fromData,133,2a2bb800a5b500232a2bb800a6b500112a2bb800a6b5000b2a2bb800a7b5001d2a2bb800a6c0004eb5001b2a2bb800a8b60054b5002f2a2bb800a6b500172a2bb800a6b500092a2bb800a6b500142a2bb800a6c000a9b5002c2a2bb800a5b5001e2a2bb800a5b5002e2a2bb800a5b500332a2bb800a5b500342a2bb800a8b60054b5002db1
+toData,140,2ab400232bb800a02b2ab40023b900a102002ab400112bb800a22ab4000b2bb800a22ab4001b2bb800a22ab4001dc0006b2bb800a32ab4002fb8003c2bb800a42ab400172bb800a22ab400092bb800a22ab400142bb800a22ab4002c2bb800a22ab4001e2bb800a02ab4002e2bb800a02ab400332bb800a02ab400342bb800a02ab4002db8003c2bb800a4b1
 
 org/apache/geode/management/internal/cli/domain/DataCommandResult$KeyInfo,2
 fromData,41,2a2bb80020b500062a2bb80020b500072a2bb80020b500082a2bb80021b500092a2bb80022b50002b1

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

Mime
View raw message