diff options
author | Harald Musum <musum@oath.com> | 2018-05-22 09:13:32 +0200 |
---|---|---|
committer | Harald Musum <musum@oath.com> | 2018-05-22 09:13:32 +0200 |
commit | c81ac708653168116b550f0bbca96a3c4d32f3ff (patch) | |
tree | a43ba71501d26d8af85a4efbba889b13a3e43685 | |
parent | 1486c90bd20d4f2d7ac7d59a89551efdbca6b43b (diff) |
Simplify
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java index bf4cdce1348..d0da4870f4f 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java @@ -153,9 +153,7 @@ public class ApplicationRepository implements com.yahoo.config.provision.Deploye public PrepareResult deploy(CompressedApplicationInputStream in, PrepareParams prepareParams, boolean ignoreLockFailure, boolean ignoreSessionStaleFailure, Instant now) { - File tempDir = Files.createTempDir(); - File applicationPackage = decompressApplication(in, tempDir); - return deploy(applicationPackage, prepareParams, ignoreLockFailure, ignoreSessionStaleFailure, now); + return deploy(decompressApplication(in), prepareParams, ignoreLockFailure, ignoreSessionStaleFailure, now); } public PrepareResult deploy(File applicationPackage, PrepareParams prepareParams) { @@ -350,8 +348,7 @@ public class ApplicationRepository implements com.yahoo.config.provision.Deploye } public long createSession(ApplicationId applicationId, TimeoutBudget timeoutBudget, InputStream in, String contentType) { - File tempDir = Files.createTempDir(); - return createSession(applicationId, timeoutBudget, decompressApplication(in, contentType, tempDir)); + return createSession(applicationId, timeoutBudget, decompressApplication(in, contentType)); } public long createSession(ApplicationId applicationId, TimeoutBudget timeoutBudget, File applicationDirectory) { @@ -442,17 +439,17 @@ public class ApplicationRepository implements com.yahoo.config.provision.Deploye return currentActiveApplicationSet; } - private File decompressApplication(InputStream in, String contentType, File tempDir) { + private File decompressApplication(InputStream in, String contentType) { try (CompressedApplicationInputStream application = CompressedApplicationInputStream.createFromCompressedStream(in, contentType)) { - return decompressApplication(application, tempDir); + return decompressApplication(application); } catch (IOException e) { - cleanupTempDirectory(tempDir, logger); throw new IllegalArgumentException("Unable to decompress data in body", e); } } - private File decompressApplication(CompressedApplicationInputStream in, File tempDir) { + private File decompressApplication(CompressedApplicationInputStream in) { + File tempDir = Files.createTempDir(); try { return in.decompress(tempDir); } catch (IOException e) { |