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 <[email protected]> Authored: Tue Nov 8 05:47:20 2016 +1100 Committer: Udo Kohlmeyer <[email protected]> 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));
