summaryrefslogtreecommitdiffstats
path: root/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDatabaseClient.java
diff options
context:
space:
mode:
Diffstat (limited to 'node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDatabaseClient.java')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDatabaseClient.java20
1 files changed, 10 insertions, 10 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDatabaseClient.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDatabaseClient.java
index 08d56c9cb42..544772ecb8f 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDatabaseClient.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDatabaseClient.java
@@ -68,7 +68,7 @@ public class CuratorDatabaseClient {
curatorDatabase.create(root);
for (Node.State state : Node.State.values())
curatorDatabase.create(toPath(state));
- curatorDatabase.create(deactivatedJobsPath());
+ curatorDatabase.create(inactiveJobsPath());
}
/**
@@ -308,26 +308,26 @@ public class CuratorDatabaseClient {
return root.append("defaultFlavor").append(applicationId.serializedForm());
}
- public Set<String> readDeactivatedJobs() {
- return curatorDatabase.getData(deactivatedJobsPath())
+ public Set<String> readInactiveJobs() {
+ return curatorDatabase.getData(inactiveJobsPath())
.map(data -> stringSetSerializer.fromJson(data))
.orElse(Collections.emptySet());
}
- public void writeDeactivatedJobs(Set<String> deactivatedJobs) {
+ public void writeInactiveJobs(Set<String> inactiveJobs) {
NestedTransaction transaction = new NestedTransaction();
CuratorTransaction curatorTransaction = curatorDatabase.newCuratorTransactionIn(transaction);
- curatorTransaction.add(CuratorOperations.setData(deactivatedJobsPath().getAbsolute(),
- stringSetSerializer.toJson(deactivatedJobs)));
+ curatorTransaction.add(CuratorOperations.setData(inactiveJobsPath().getAbsolute(),
+ stringSetSerializer.toJson(inactiveJobs)));
transaction.commit();
}
- public CuratorMutex lockDeactivatedJobs() {
- return lock(deactivatedJobsPath(), defaultLockTimeout);
+ public CuratorMutex lockInactiveJobs() {
+ return lock(inactiveJobsPath(), defaultLockTimeout);
}
- private Path deactivatedJobsPath() {
- return root.append("deactivatedJobs");
+ private Path inactiveJobsPath() {
+ return root.append("inactiveJobs");
}
}