You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2020/04/01 18:06:08 UTC
[geode] 01/01: GEODE-7939: membership heartbeat messages aren't
designated high-priority
This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a commit to branch feature/GEODE-7939
in repository https://gitbox.apache.org/repos/asf/geode.git
commit 189ae766efb47dd94ca495a00e7ead88dbd287a1
Author: Bruce Schuchardt <bs...@pivotal.io>
AuthorDate: Wed Apr 1 11:02:10 2020 -0700
GEODE-7939: membership heartbeat messages aren't designated high-priority
Set the heartbeat request/response messages to be high-priority so
they'll never be held up in a receive queue waiting for older messages
to be processed.
---
.../internal/membership/gms/messages/HeartbeatMessage.java | 5 +++++
.../internal/membership/gms/messages/HeartbeatRequestMessage.java | 6 ++++++
2 files changed, 11 insertions(+)
diff --git a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage.java b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage.java
index d1cfc83..263a9bd 100755
--- a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage.java
+++ b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage.java
@@ -72,4 +72,9 @@ public class HeartbeatMessage<ID extends MemberIdentifier> extends AbstractGMSMe
DeserializationContext context) throws IOException, ClassNotFoundException {
requestId = in.readInt();
}
+
+ @Override
+ public boolean isHighPriority() {
+ return true;
+ }
}
diff --git a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatRequestMessage.java b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatRequestMessage.java
index 5441074..bcdb4b1 100755
--- a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatRequestMessage.java
+++ b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatRequestMessage.java
@@ -83,4 +83,10 @@ public class HeartbeatRequestMessage<ID extends MemberIdentifier> extends Abstra
requestId = in.readInt();
target = context.getDeserializer().readObject(in);
}
+
+ @Override
+ public boolean isHighPriority() {
+ return true;
+ }
+
}