summaryrefslogtreecommitdiffstats
path: root/fileacquirer
diff options
context:
space:
mode:
authorHÃ¥kon Hallingstad <hakon.hallingstad@gmail.com>2023-01-13 13:06:39 +0100
committerGitHub <noreply@github.com>2023-01-13 13:06:39 +0100
commit45bcd747f2affce11d670f4457678be4b0931aea (patch)
tree5d2b97f3fb171d141442e87edb7869df7b9cb3f3 /fileacquirer
parentdbb6406528fc5723cf7310d6d53961e96c8ce257 (diff)
parentb581d31a9f793f6f5bad93ede8de3b8283baa428 (diff)
Merge pull request #25561 from vespa-engine/hmusum/file-acquirer-cleanup
Remove unused error code and exception
Diffstat (limited to 'fileacquirer')
-rw-r--r--fileacquirer/abi-spec.json12
-rw-r--r--fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java21
-rw-r--r--fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileReferenceRemovedException.java14
-rw-r--r--fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/MockFileAcquirer.java15
-rw-r--r--fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/TimeoutException.java2
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();
}