diff options
author | Harald Musum <musum@yahooinc.com> | 2023-09-17 19:27:31 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2023-09-17 19:27:31 +0200 |
commit | 831975ebd5be0792ad6e100e07b1b96011089ac9 (patch) | |
tree | cb137b81d334497aa65047054e4cec81832741f5 | |
parent | 8f26508bf1d99839e78e4ba95e6ad3c4bffd22fb (diff) |
Split out common code into a method
-rw-r--r-- | config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/UrlDownloadRpcServer.java | 14 |
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)); } |