summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@yahoo-inc.com>2016-07-06 13:14:46 +0200
committerJon Bratseth <bratseth@yahoo-inc.com>2016-07-06 13:14:46 +0200
commit607dfd6a96996e4371cd5a791fe7749dd83c84ec (patch)
tree621bae58998b03d44ea76a8885af79e0ed43fdbd /configserver
parente559b79c6bec0427935ef0e20730e61663cc599e (diff)
Dont support delete if exist in transaction
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/Rotations.java2
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKApplicationRepo.java4
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java2
3 files changed, 4 insertions, 4 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/Rotations.java b/configserver/src/main/java/com/yahoo/vespa/config/server/Rotations.java
index b8a0d344f09..4584e36b0a1 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/Rotations.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/Rotations.java
@@ -71,7 +71,7 @@ public class Rotations {
Path rotationsPath = path.append(applicationId.serializedForm());
if ( ! curator.exists(rotationsPath)) return CuratorTransaction.empty(curator);
- return CuratorTransaction.from(CuratorOperations.deleteOrThrow(rotationsPath.getAbsolute()), curator);
+ return CuratorTransaction.from(CuratorOperations.delete(rotationsPath.getAbsolute()), curator);
}
}
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKApplicationRepo.java b/configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKApplicationRepo.java
index eb0e9ea3f24..46278120b0d 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKApplicationRepo.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/application/ZKApplicationRepo.java
@@ -84,7 +84,7 @@ public class ZKApplicationRepo implements ApplicationRepo, PathChildrenCacheList
if (curator.framework().checkExists().forPath(newPath) == null) {
transaction.add(CuratorOperations.create(newPath, Utf8.toAsciiBytes(sessionId)));
}
- transaction.add(CuratorOperations.deleteOrThrow(oldPath));
+ transaction.add(CuratorOperations.delete(oldPath));
transaction.commit();
} catch (Exception e) {
log.log(LogLevel.WARNING, "Error rewriting application id from " + origNode + " to " + appId.serializedForm());
@@ -139,7 +139,7 @@ public class ZKApplicationRepo implements ApplicationRepo, PathChildrenCacheList
@Override
public CuratorTransaction deleteApplication(ApplicationId applicationId) {
Path path = root.append(applicationId.serializedForm());
- return CuratorTransaction.from(CuratorOperations.deleteOrThrow(path.getAbsolute()), curator);
+ return CuratorTransaction.from(CuratorOperations.delete(path.getAbsolute()), curator);
}
@Override
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java
index fda3b46fd47..567ec4718ca 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java
@@ -127,7 +127,7 @@ public class SessionZooKeeperClient {
}
}
- /** Returns a transaction deleting this path on commit */
+ /** Returns a transaction deleting this session on commit */
public CuratorTransaction deleteTransaction() {
return CuratorTransaction.from(CuratorOperations.delete(rootPath.getAbsolute()), curator);
}