summaryrefslogtreecommitdiffstats
path: root/vdslib
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-05-20 13:41:55 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-05-20 13:41:55 +0200
commit746eaa0435071319347e1eae8c9125b4e422be79 (patch)
tree8596a9e83310ef2117ea0b62ad592467b9804e43 /vdslib
parentf460d59553f64c1b72ad652359b08ea9095c1030 (diff)
get -> getAcquire, set -> setRelease
Diffstat (limited to 'vdslib')
-rw-r--r--vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java12
1 files changed, 6 insertions, 6 deletions
diff --git a/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java b/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java
index 000b6c92110..52708ea6d8e 100644
--- a/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java
+++ b/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java
@@ -45,11 +45,11 @@ public class Distribution {
private final AtomicReference<Config> config = new AtomicReference<>(new Config(null, 1, false));
public Group getRootGroup() {
- return config.get().nodeGraph;
+ return config.getAcquire().nodeGraph;
}
public int getRedundancy() {
- return config.get().redundancy;
+ return config.getAcquire().redundancy;
}
private ConfigSubscriber.SingleSubscriber<StorDistributionConfig> configSubscriber = new ConfigSubscriber.SingleSubscriber<>() {
@@ -103,7 +103,7 @@ public class Distribution {
+ "\nminimum:\n" + config.toString());
}
root.calculateDistributionHashValues();
- Distribution.this.config.set(new Config(root, config.redundancy(), config.distributor_auto_ownership_transfer_on_whole_group_down()));
+ Distribution.this.config.setRelease(new Config(root, config.redundancy(), config.distributor_auto_ownership_transfer_on_whole_group_down()));
} catch (ParseException e) {
throw new IllegalStateException("Failed to parse config", e);
}
@@ -350,7 +350,7 @@ public class Distribution {
// Find what hierarchical groups we should have copies in
List<ResultGroup> groupDistribution = new ArrayList<>();
- Config cfg = config.get();
+ Config cfg = config.getAcquire();
getIdealGroups(bucket, clusterState, cfg.nodeGraph, cfg.redundancy, groupDistribution);
int seed = getStorageSeed(bucket, clusterState);
@@ -438,7 +438,7 @@ public class Distribution {
+ " bits when cluster uses " + state.getDistributionBitCount() + " distribution bits.");
}
- Config cfg = config.get();
+ Config cfg = config.getAcquire();
Group idealGroup = getIdealDistributorGroup(cfg.distributorAutoOwnershipTransferOnWholeGroupDown, bucket, state, cfg.nodeGraph, cfg.redundancy);
if (idealGroup == null) {
throw new NoDistributorsAvailableException("No distributors available in cluster state version " + state.getVersion());
@@ -490,7 +490,7 @@ public class Distribution {
}
public void visitGroups(GroupVisitor visitor) {
Map<Integer, Group> groups = new TreeMap<>();
- Group nodeGraph = config.get().nodeGraph;
+ Group nodeGraph = config.getAcquire().nodeGraph;
groups.put(nodeGraph.getIndex(), nodeGraph);
visitGroups(visitor, groups);
}