diff options
author | HÃ¥kon Hallingstad <hakon.hallingstad@gmail.com> | 2023-01-13 13:06:39 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-01-13 13:06:39 +0100 |
commit | 45bcd747f2affce11d670f4457678be4b0931aea (patch) | |
tree | 5d2b97f3fb171d141442e87edb7869df7b9cb3f3 /fileacquirer | |
parent | dbb6406528fc5723cf7310d6d53961e96c8ce257 (diff) | |
parent | b581d31a9f793f6f5bad93ede8de3b8283baa428 (diff) |
Merge pull request #25561 from vespa-engine/hmusum/file-acquirer-cleanup
Remove unused error code and exception
Diffstat (limited to 'fileacquirer')
5 files changed, 11 insertions, 53 deletions
diff --git a/fileacquirer/abi-spec.json b/fileacquirer/abi-spec.json index b72099063d8..560d1fb7a16 100644 --- a/fileacquirer/abi-spec.json +++ b/fileacquirer/abi-spec.json @@ -36,17 +36,6 @@ "public final java.lang.String fileReference" ] }, - "com.yahoo.filedistribution.fileacquirer.FileReferenceRemovedException" : { - "superClass" : "java.lang.RuntimeException", - "interfaces" : [ ], - "attributes" : [ - "public" - ], - "methods" : [ ], - "fields" : [ - "public final java.lang.String fileReference" - ] - }, "com.yahoo.filedistribution.fileacquirer.MockFileAcquirer" : { "superClass" : "java.lang.Object", "interfaces" : [ @@ -73,7 +62,6 @@ "public" ], "methods" : [ - "public void <init>()", "public void <init>(java.lang.String)", "public void <init>(java.lang.String, java.lang.Throwable)" ], diff --git a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java index 122027d706b..5d6477cd927 100644 --- a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java +++ b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java @@ -30,9 +30,7 @@ class FileAcquirerImpl implements FileAcquirer { public static final int baseErrorCode = 0x10000; public static final int baseFileProviderErrorCode = baseErrorCode + 0x1000; - public static final int fileReferenceDoesNotExists = baseFileProviderErrorCode; - public static final int fileReferenceRemoved = fileReferenceDoesNotExists + 1; } @@ -113,16 +111,10 @@ class FileAcquirerImpl implements FileAcquirer { private final Connection connection = new Connection(); private boolean temporaryError(int errorCode) { - switch (errorCode) { - case ErrorCode.ABORT: - case ErrorCode.CONNECTION: - case ErrorCode.GENERAL_ERROR: - case ErrorCode.OVERLOAD: - case ErrorCode.TIMEOUT: - return true; - default: - return false; - } + return switch (errorCode) { + case ErrorCode.ABORT, ErrorCode.CONNECTION, ErrorCode.GENERAL_ERROR, ErrorCode.OVERLOAD, ErrorCode.TIMEOUT -> true; + default -> false; + }; } public FileAcquirerImpl(String configId) { @@ -168,12 +160,11 @@ class FileAcquirerImpl implements FileAcquirer { } else { if (request.errorCode() == FileDistributionErrorCode.fileReferenceDoesNotExists) throw new FileReferenceDoesNotExistException(fileReference.value()); - else if (request.errorCode() == FileDistributionErrorCode.fileReferenceRemoved) - throw new FileReferenceRemovedException(fileReference.value()); else - throw new RuntimeException("Wait for " + fileReference + " failed:" + request.errorMessage() + " (" + request.errorCode() + ")"); + throw new RuntimeException("Wait for " + fileReference + " failed: " + request.errorMessage() + " (" + request.errorCode() + ")"); } } while ( timer.isTimeLeft() ); + throw new TimeoutException("Timed out waiting for " + fileReference + " after " + timeout + " " + timeUnit.name().toLowerCase()); } diff --git a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileReferenceRemovedException.java b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileReferenceRemovedException.java deleted file mode 100644 index 542fbcc7532..00000000000 --- a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileReferenceRemovedException.java +++ /dev/null @@ -1,14 +0,0 @@ -// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.filedistribution.fileacquirer; - -/** - * @author Tony Vaagenes - */ -public class FileReferenceRemovedException extends RuntimeException { - public final String fileReference; - - FileReferenceRemovedException(String fileReference) { - super("The file with file reference '" + fileReference + "' was removed while waiting."); - this.fileReference = fileReference; - } -} diff --git a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/MockFileAcquirer.java b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/MockFileAcquirer.java index 024aa8990d7..744c49629e9 100644 --- a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/MockFileAcquirer.java +++ b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/MockFileAcquirer.java @@ -3,9 +3,6 @@ package com.yahoo.filedistribution.fileacquirer; import com.yahoo.config.FileReference; import java.io.File; -import java.lang.reflect.Constructor; -import java.lang.reflect.InvocationTargetException; -import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; @@ -19,8 +16,7 @@ public abstract class MockFileAcquirer implements FileAcquirer { public static FileAcquirer returnFile(File file) { return new MockFileAcquirer() { @Override - public File waitFor(FileReference fileReference, - long timeout, TimeUnit timeUnit) throws InterruptedException { + public File waitFor(FileReference fileReference, long timeout, TimeUnit timeUnit) { return file; } }; @@ -30,8 +26,7 @@ public abstract class MockFileAcquirer implements FileAcquirer { public static FileAcquirer returnFiles(Map<String, File> files) { return new MockFileAcquirer() { @Override - public File waitFor(FileReference fileReference, - long timeout, TimeUnit timeUnit) throws InterruptedException { + public File waitFor(FileReference fileReference, long timeout, TimeUnit timeUnit) { return files.get(fileReference.value()); } }; @@ -41,8 +36,7 @@ public abstract class MockFileAcquirer implements FileAcquirer { public static FileAcquirer throwTimeoutException() { return new MockFileAcquirer() { @Override - public File waitFor(FileReference fileReference, - long timeout, TimeUnit timeUnit) throws InterruptedException { + public File waitFor(FileReference fileReference, long timeout, TimeUnit timeUnit) { throw new TimeoutException("Timed out"); } }; @@ -52,8 +46,7 @@ public abstract class MockFileAcquirer implements FileAcquirer { public static FileAcquirer throwFileReferenceDoesNotExistException() { return new MockFileAcquirer() { @Override - public File waitFor(FileReference fileReference, - long timeout, TimeUnit timeUnit) throws InterruptedException { + public File waitFor(FileReference fileReference, long timeout, TimeUnit timeUnit) { throw new FileReferenceDoesNotExistException(null); } }; diff --git a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/TimeoutException.java b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/TimeoutException.java index ebb14a99239..8360a9db13d 100644 --- a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/TimeoutException.java +++ b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/TimeoutException.java @@ -7,7 +7,7 @@ package com.yahoo.filedistribution.fileacquirer; public class TimeoutException extends RuntimeException { /** Do not use this constructor */ - public TimeoutException() { + private TimeoutException() { super(); } |