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:07 UTC
[geode] branch feature/GEODE-7939 created (now 189ae76)
This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a change to branch feature/GEODE-7939
in repository https://gitbox.apache.org/repos/asf/geode.git.
at 189ae76 GEODE-7939: membership heartbeat messages aren't designated high-priority
This branch includes the following new commits:
new 189ae76 GEODE-7939: membership heartbeat messages aren't designated high-priority
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[geode] 01/01: GEODE-7939: membership heartbeat messages aren't
designated high-priority
Posted by bs...@apache.org.
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;
+ }
+
}