geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dschnei...@apache.org
Subject [geode] branch feature/GEODE-3557 updated: spotless
Date Wed, 06 Sep 2017 21:24:53 GMT
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 <dschneider@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" <commits@geode.apache.org>'].

Mime
View raw message