aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2023-09-17 19:27:31 +0200
committerHarald Musum <musum@yahooinc.com>2023-09-17 19:27:31 +0200
commit831975ebd5be0792ad6e100e07b1b96011089ac9 (patch)
treecb137b81d334497aa65047054e4cec81832741f5
parent8f26508bf1d99839e78e4ba95e6ad3c4bffd22fb (diff)
Split out common code into a method
-rw-r--r--config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/UrlDownloadRpcServer.java14
1 files changed, 8 insertions, 6 deletions
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/UrlDownloadRpcServer.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/UrlDownloadRpcServer.java
index 7ec60985007..e48ad3c8759 100644
--- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/UrlDownloadRpcServer.java
+++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/UrlDownloadRpcServer.java
@@ -84,13 +84,9 @@ class UrlDownloadRpcServer {
else
req.setError(DOES_NOT_EXIST, "URL '" + url + "' not found");
} catch (RuntimeException e) {
- String message = "Download of '" + url + "' failed: " + Exceptions.toMessageString(e);
- log.log(Level.SEVERE, message);
- req.setError(HTTP_ERROR, e.getMessage());
+ logAndSetRpcError(req, url, e, HTTP_ERROR);
} catch (Throwable e) {
- String message = "Download of '" + url + "' failed: " + Exceptions.toMessageString(e);
- log.log(Level.SEVERE, message);
- req.setError(INTERNAL_ERROR, message);
+ logAndSetRpcError(req, url, e, INTERNAL_ERROR);
}
req.returnRequest();
}
@@ -101,6 +97,12 @@ class UrlDownloadRpcServer {
: new UrlDownloader().downloadFile(url, downloadDir);
}
+ private static void logAndSetRpcError(Request req, String url, Throwable e, int rpcErrorCode) {
+ String message = "Download of '" + url + "' failed: " + Exceptions.toMessageString(e);
+ log.log(Level.SEVERE, message);
+ req.setError(rpcErrorCode, e.getMessage());
+ }
+
private static String urlToDirName(String uri) {
return String.valueOf(XXHashFactory.fastestJavaInstance().hash64().hash(ByteBuffer.wrap(Utf8.toBytes(uri)), 0));
}