Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id A6743200CFD for ; Wed, 6 Sep 2017 23:24:57 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id A50921609D7; Wed, 6 Sep 2017 21:24:57 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id C6C801609BA for ; Wed, 6 Sep 2017 23:24:56 +0200 (CEST) Received: (qmail 1696 invoked by uid 500); 6 Sep 2017 21:24:55 -0000 Mailing-List: contact commits-help@geode.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@geode.apache.org Delivered-To: mailing list commits@geode.apache.org Received: (qmail 1687 invoked by uid 99); 6 Sep 2017 21:24:55 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 06 Sep 2017 21:24:55 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id A707081705; Wed, 6 Sep 2017 21:24:53 +0000 (UTC) Date: Wed, 06 Sep 2017 21:24:53 +0000 To: "commits@geode.apache.org" Subject: [geode] branch feature/GEODE-3557 updated: spotless MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <150473309313.15303.8249379019805542143@gitbox.apache.org> From: dschneider@apache.org Reply-To: "commits@geode.apache.org" X-Git-Host: gitbox.apache.org X-Git-Repo: geode X-Git-Refname: refs/heads/feature/GEODE-3557 X-Git-Reftype: branch X-Git-Oldrev: d0c2507dcad1a6cc874d9612657a9ebd02a880a4 X-Git-Newrev: 88fe429087a5f66df4154940a51f07cedd8bdb42 X-Git-Rev: 88fe429087a5f66df4154940a51f07cedd8bdb42 X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated archived-at: Wed, 06 Sep 2017 21:24:57 -0000 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 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 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" '].