You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by jb...@apache.org on 2021/08/17 18:17:36 UTC
[geode] 04/18: GEODE-6588: Cleanup RegisterInterest61
This is an automated email from the ASF dual-hosted git repository.
jbarrett pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
commit 4f8a6cabc5088ad7171d421a2c9da5dee63e702d
Author: Jacob Barrett <jb...@pivotal.io>
AuthorDate: Thu May 20 14:54:17 2021 -0700
GEODE-6588: Cleanup RegisterInterest61
---
.../internal/cache/tier/sockets/command/RegisterInterest61.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java
index 888bcfd..c4310b5 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java
@@ -93,7 +93,7 @@ public class RegisterInterest61 extends BaseCommand {
}
// region data policy
byte[] regionDataPolicyPartBytes;
- boolean serializeValues = false;
+ final boolean serializeValues;
try {
Part regionDataPolicyPart = clientMessage.getPart(clientMessage.getNumberOfParts() - 1);
regionDataPolicyPartBytes = (byte[]) regionDataPolicyPart.getObject();
@@ -228,8 +228,8 @@ public class RegisterInterest61 extends BaseCommand {
// Send chunk response
try {
- if (region.getDistributionManager() instanceof LonerDistributionManager
- && region instanceof PartitionedRegion) {
+ if (region instanceof PartitionedRegion
+ && region.getDistributionManager() instanceof LonerDistributionManager) {
throw new IllegalStateException(
"Should not register interest for a partitioned region when mcast-port is 0 and no locator is present");
}