You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2017/09/06 21:24:53 UTC
[geode] branch feature/GEODE-3557 updated: spotless
This is an automated email from the ASF dual-hosted git repository.
dschneider pushed a commit to branch feature/GEODE-3557
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-3557 by this push:
new 88fe429 spotless
88fe429 is described below
commit 88fe429087a5f66df4154940a51f07cedd8bdb42
Author: Darrel Schneider <ds...@pivotal.io>
AuthorDate: Wed Sep 6 14:24:29 2017 -0700
spotless
---
.../src/main/java/org/apache/geode/distributed/internal/DM.java | 1 +
.../org/apache/geode/internal/cache/CacheDistributionAdvisor.java | 3 +--
.../java/org/apache/geode/internal/cache/control/ResourceAdvisor.java | 3 ++-
.../geode/internal/cache/persistence/MembershipViewRequest.java | 4 ++--
.../geode/internal/cache/persistence/PersistentStateQueryMessage.java | 4 ++--
.../internal/cache/persistence/PrepareNewPersistentMemberMessage.java | 4 ++--
.../internal/cache/persistence/RemovePersistentMemberMessage.java | 4 ++--
7 files changed, 12 insertions(+), 11 deletions(-)
diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DM.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DM.java
index 56d21a5..ca79c62 100644
--- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DM.java
+++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DM.java
@@ -465,5 +465,6 @@ public interface DM extends ReplySender {
int getDMType();
InternalCache getCache();
+
void setCache(InternalCache instance);
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.java
index 73b0a87..5e877ad 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.java
@@ -768,8 +768,7 @@ public class CacheDistributionAdvisor extends DistributionAdvisor {
} else {
if (lclRgn == null) {
handleCacheDistributionAdvisee(
- PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(),
- adviseePath, false),
+ PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(), adviseePath, false),
adviseePath, removeProfile, exchangeProfiles, false, replyProfiles);
} else {
if (logger.isDebugEnabled()) {
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/control/ResourceAdvisor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/control/ResourceAdvisor.java
index 153e96e..ca4a42e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/control/ResourceAdvisor.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/control/ResourceAdvisor.java
@@ -341,7 +341,8 @@ public class ResourceAdvisor extends DistributionAdvisor {
boolean exchangeProfiles, final List<Profile> replyProfiles) {
final InternalCache cache = dm.getCache();
if (cache != null && !cache.isClosed()) {
- handleDistributionAdvisee((DistributionAdvisee) cache, removeProfile, exchangeProfiles, replyProfiles);
+ handleDistributionAdvisee((DistributionAdvisee) cache, removeProfile, exchangeProfiles,
+ replyProfiles);
}
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/MembershipViewRequest.java b/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/MembershipViewRequest.java
index d6cdaa5..420d256 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/MembershipViewRequest.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/MembershipViewRequest.java
@@ -114,8 +114,8 @@ public class MembershipViewRequest extends DistributionMessage implements Messag
if (region instanceof DistributedRegion) {
persistenceAdvisor = ((DistributedRegion) region).getPersistenceAdvisor();
} else if (region == null) {
- Bucket proxy = PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(),
- this.regionPath, false);
+ Bucket proxy =
+ PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(), this.regionPath, false);
if (proxy != null) {
persistenceAdvisor = proxy.getPersistenceAdvisor();
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/PersistentStateQueryMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/PersistentStateQueryMessage.java
index 2af1591..018325d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/PersistentStateQueryMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/PersistentStateQueryMessage.java
@@ -107,8 +107,8 @@ public class PersistentStateQueryMessage extends HighPriorityDistributionMessage
if (region instanceof DistributedRegion) {
persistenceAdvisor = ((DistributedRegion) region).getPersistenceAdvisor();
} else if (region == null) {
- Bucket proxy = PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(),
- this.regionPath, false);
+ Bucket proxy =
+ PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(), this.regionPath, false);
if (proxy != null) {
persistenceAdvisor = proxy.getPersistenceAdvisor();
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/PrepareNewPersistentMemberMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/PrepareNewPersistentMemberMessage.java
index b9856f6..5029bb0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/PrepareNewPersistentMemberMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/PrepareNewPersistentMemberMessage.java
@@ -97,8 +97,8 @@ public class PrepareNewPersistentMemberMessage extends HighPriorityDistributionM
if (region instanceof DistributedRegion) {
persistenceAdvisor = ((DistributedRegion) region).getPersistenceAdvisor();
} else if (region == null) {
- Bucket proxy = PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(),
- this.regionPath, false);
+ Bucket proxy =
+ PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(), this.regionPath, false);
if (proxy != null) {
persistenceAdvisor = proxy.getPersistenceAdvisor();
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/RemovePersistentMemberMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/RemovePersistentMemberMessage.java
index 3e8aeef..a035c74 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/RemovePersistentMemberMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/persistence/RemovePersistentMemberMessage.java
@@ -101,8 +101,8 @@ public class RemovePersistentMemberMessage extends HighPriorityDistributionMessa
if (region instanceof DistributedRegion) {
persistenceAdvisor = ((DistributedRegion) region).getPersistenceAdvisor();
} else if (region == null) {
- Bucket proxy = PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(),
- this.regionPath, false);
+ Bucket proxy =
+ PartitionedRegionHelper.getProxyBucketRegion(dm.getCache(), this.regionPath, false);
if (proxy != null) {
persistenceAdvisor = proxy.getPersistenceAdvisor();
}
--
To stop receiving notification emails like this one, please contact
['"commits@geode.apache.org" <co...@geode.apache.org>'].