geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject incubator-geode git commit: GEODE-2017: Fixing Formatting
Date Mon, 07 Nov 2016 18:47:45 GMT
Repository: incubator-geode
Updated Branches:
  refs/heads/feature/GEODE-2017 cc67eddb6 -> b62cb1d1a


GEODE-2017: Fixing Formatting


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/b62cb1d1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/b62cb1d1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/b62cb1d1

Branch: refs/heads/feature/GEODE-2017
Commit: b62cb1d1afb95868a4e1909e2936b2998fc928ff
Parents: cc67edd
Author: Udo Kohlmeyer <ukohlmeyer@pivotal.io>
Authored: Tue Nov 8 05:47:20 2016 +1100
Committer: Udo Kohlmeyer <ukohlmeyer@pivotal.io>
Committed: Tue Nov 8 05:47:40 2016 +1100

----------------------------------------------------------------------
 .../client/internal/ClientMetadataService.java  | 32 +++++++++-----------
 1 file changed, 14 insertions(+), 18 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/b62cb1d1/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
index d4d5ac9..3cf0d7b 100755
--- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClientMetadataService.java
@@ -49,6 +49,7 @@ import java.util.concurrent.CopyOnWriteArraySet;
  * Maintains {@link ClientPartitionAdvisor} for Partitioned Regions on servers Client operations
  * will consult this service to identify the server locations on which the data for the client
  * operation is residing
+ * 
  * @since GemFire 6.5
  */
 public final class ClientMetadataService {
@@ -117,7 +118,7 @@ public final class ClientMetadataService {
   }
 
   public ServerLocation getBucketServerLocation(Region region, Operation operation, Object
key,
-                                                Object value, Object callbackArg) {
+      Object value, Object callbackArg) {
     ClientPartitionAdvisor prAdvisor = this.getClientPartitionAdvisor(region.getFullPath());
     if (prAdvisor == null) {
       return null;
@@ -148,7 +149,7 @@ public final class ClientMetadataService {
       String partition = ((FixedPartitionResolver) resolver).getPartitionName(entryOp,
           prAdvisor.getFixedPartitionNames());
       if (partition == null) {
-        Object[] prms = new Object[]{region.getName(), resolver};
+        Object[] prms = new Object[] {region.getName(), resolver};
         throw new IllegalStateException(
             LocalizedStrings.PartitionedRegionHelper_FOR_REGION_0_PARTITIONRESOLVER_1_RETURNED_PARTITION_NAME_NULL
                 .toLocalizedString(prms));
@@ -193,15 +194,12 @@ public final class ClientMetadataService {
   }
 
   public Map<ServerLocation, HashSet> getServerToFilterMap(final Collection routingKeys,
-                                                           final Region region,
-                                                           boolean primaryMembersNeeded)
{
+      final Region region, boolean primaryMembersNeeded) {
     return getServerToFilterMap(routingKeys, region, primaryMembersNeeded, false);
   }
 
   public Map<ServerLocation, HashSet> getServerToFilterMap(final Collection routingKeys,
-                                                           final Region region,
-                                                           boolean primaryMembersNeeded,
-                                                           boolean bucketsAsFilter) {
+      final Region region, boolean primaryMembersNeeded, boolean bucketsAsFilter) {
     final String regionFullPath = region.getFullPath();
     ClientPartitionAdvisor prAdvisor = this.getClientPartitionAdvisor(regionFullPath);
     if (prAdvisor == null || prAdvisor.adviseRandomServerLocation() == null) {
@@ -241,7 +239,7 @@ public final class ClientMetadataService {
   }
 
   public HashMap<ServerLocation, HashSet<Integer>> groupByServerToAllBuckets(Region
region,
-                                                                             boolean primaryOnly)
{
+      boolean primaryOnly) {
     final String regionFullPath = region.getFullPath();
     ClientPartitionAdvisor prAdvisor = this.getClientPartitionAdvisor(regionFullPath);
     if (prAdvisor == null || prAdvisor.adviseRandomServerLocation() == null) {
@@ -293,7 +291,7 @@ public final class ClientMetadataService {
 
 
   private HashMap<ServerLocation, HashSet<Integer>> pruneNodes(ClientPartitionAdvisor
prAdvisor,
-                                                               Set<Integer> buckets)
{
+      Set<Integer> buckets) {
 
     final boolean isDebugEnabled = logger.isDebugEnabled();
     if (isDebugEnabled) {
@@ -397,7 +395,7 @@ public final class ClientMetadataService {
 
 
   private ServerLocation findNextServer(Set<Map.Entry<ServerLocation, HashSet<Integer>>>
entrySet,
-                                        HashSet<Integer> currentBucketSet) {
+      HashSet<Integer> currentBucketSet) {
 
     ServerLocation server = null;
     int max = -1;
@@ -427,9 +425,7 @@ public final class ClientMetadataService {
   }
 
   private HashMap<Integer, HashSet> groupByBucketOnClientSide(Region region,
-                                                              ClientPartitionAdvisor prAdvisor,
-                                                              Collection routingKeys,
-                                                              boolean bucketsAsFilter) {
+      ClientPartitionAdvisor prAdvisor, Collection routingKeys, boolean bucketsAsFilter)
{
 
     HashMap<Integer, HashSet> bucketToKeysMap = new HashMap();
     int totalNumberOfBuckets = prAdvisor.getTotalNumBuckets();
@@ -452,7 +448,7 @@ public final class ClientMetadataService {
   }
 
   private int extractBucketID(Region region, ClientPartitionAdvisor prAdvisor,
-                              int totalNumberOfBuckets, Object key) {
+      int totalNumberOfBuckets, Object key) {
     int bucketId = -1;
     final PartitionResolver resolver = getResolver(region, key, null);
     Object resolveKey;
@@ -478,7 +474,7 @@ public final class ClientMetadataService {
       String partition = ((FixedPartitionResolver) resolver).getPartitionName(entryOp,
           prAdvisor.getFixedPartitionNames());
       if (partition == null) {
-        Object[] prms = new Object[]{region.getName(), resolver};
+        Object[] prms = new Object[] {region.getName(), resolver};
         throw new IllegalStateException(
             LocalizedStrings.PartitionedRegionHelper_FOR_REGION_0_PARTITIONRESOLVER_1_RETURNED_PARTITION_NAME_NULL
                 .toLocalizedString(prms));
@@ -590,7 +586,7 @@ public final class ClientMetadataService {
   }
 
   public void scheduleGetPRMetaData(final LocalRegion region, final boolean isRecursive,
-                                    byte nwHopType) {
+      byte nwHopType) {
     if (this.nonPRs.contains(region.getFullPath())) {
       return;
     }
@@ -674,7 +670,7 @@ public final class ClientMetadataService {
   }
 
   public byte getMetaDataVersion(Region region, Operation operation, Object key, Object value,
-                                 Object callbackArg) {
+      Object callbackArg) {
     ClientPartitionAdvisor prAdvisor = this.getClientPartitionAdvisor(region.getFullPath());
     if (prAdvisor == null) {
       return 0;
@@ -707,7 +703,7 @@ public final class ClientMetadataService {
       String partition = ((FixedPartitionResolver) resolver).getPartitionName(entryOp,
           prAdvisor.getFixedPartitionNames());
       if (partition == null) {
-        Object[] prms = new Object[]{region.getName(), resolver};
+        Object[] prms = new Object[] {region.getName(), resolver};
         throw new IllegalStateException(
             LocalizedStrings.PartitionedRegionHelper_FOR_REGION_0_PARTITIONRESOLVER_1_RETURNED_PARTITION_NAME_NULL
                 .toLocalizedString(prms));


Mime
View raw message