summaryrefslogtreecommitdiffstats
path: root/controller-server
diff options
context:
space:
mode:
authorJon Marius Venstad <jvenstad@yahoo-inc.com>2017-11-21 10:02:51 +0100
committerJon Marius Venstad <jvenstad@yahoo-inc.com>2017-11-21 10:02:51 +0100
commitf8e3996178ce043292a763f79861c4c310c41ae1 (patch)
treeb9e93530dc97c0be185f48c506cba542ea5268a4 /controller-server
parentcdc91a0bb3d12e5ce52c3184066d802bf41e750d (diff)
Clean
Diffstat (limited to 'controller-server')
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java15
1 files changed, 4 insertions, 11 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java
index 565c92f3a28..67b63c87ea3 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java
@@ -1,7 +1,6 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.hosted.controller;
-import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableSet;
import com.yahoo.component.Version;
import com.yahoo.config.application.api.ValidationId;
@@ -120,12 +119,6 @@ public class ApplicationController {
return db.getApplication(id);
}
-
- /** Returns an locked application with the given id that be updated and stored */
- private Optional<LockedApplication> get(ApplicationId id, Lock lock) {
- return get(id).map(application -> new LockedApplication(application, lock));
- }
-
/**
* Returns the application with the given id
*
@@ -276,9 +269,9 @@ public class ApplicationController {
ApplicationPackage applicationPackage, DeployOptions options) {
try (Lock lock = lock(applicationId)) {
// TODO: Shouldn't this go through the above method? Seems you can cheat the checks here ... ?
- LockedApplication application = get(applicationId, lock).orElse(new LockedApplication(
+ LockedApplication application = get(applicationId).map(application1 -> new LockedApplication(application1, lock)).orElse(new LockedApplication(
new Application(applicationId), lock)
- );
+ );
// Determine what we are doing
Version version;
@@ -532,7 +525,7 @@ public class ApplicationController {
*/
public void lockedIfPresent(ApplicationId applicationId, Consumer<LockedApplication> actions) {
try (Lock lock = lock(applicationId)) {
- get(applicationId, lock).ifPresent(actions);
+ get(applicationId).map(application -> new LockedApplication(application, lock)).ifPresent(actions);
}
}
@@ -544,7 +537,7 @@ public class ApplicationController {
*/
public void lockedOrThrow(ApplicationId applicationId, Consumer<LockedApplication> actions) {
try (Lock lock = lock(applicationId)) {
- actions.accept(get(applicationId, lock).orElseThrow(() -> new IllegalArgumentException(applicationId + " not found")));
+ actions.accept(new LockedApplication(require(applicationId), lock));
}
}