summaryrefslogtreecommitdiffstats
path: root/vespaclient-java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-01-26 12:05:48 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2023-01-26 12:05:48 +0100
commit71608598e54b6e2a095db24d2a27f74475daeb46 (patch)
tree44516d649fab4fee45dc9dffffc1d324499690dd /vespaclient-java
parentb0190ae9c6d6729780d61ef1607e868de12f8ba4 (diff)
Minor code cleanup.
Diffstat (limited to 'vespaclient-java')
-rw-r--r--vespaclient-java/src/main/java/com/yahoo/vespa/filedistribution/status/FileDistributionStatusClient.java30
1 files changed, 12 insertions, 18 deletions
diff --git a/vespaclient-java/src/main/java/com/yahoo/vespa/filedistribution/status/FileDistributionStatusClient.java b/vespaclient-java/src/main/java/com/yahoo/vespa/filedistribution/status/FileDistributionStatusClient.java
index a9bbfafeaf0..249432804ad 100644
--- a/vespaclient-java/src/main/java/com/yahoo/vespa/filedistribution/status/FileDistributionStatusClient.java
+++ b/vespaclient-java/src/main/java/com/yahoo/vespa/filedistribution/status/FileDistributionStatusClient.java
@@ -74,15 +74,13 @@ public class FileDistributionStatusClient {
private String doHttpRequest() {
Timeout timeoutInMillis = Timeout.ofMilliseconds((long) (timeout * 1000));
RequestConfig config = custom()
- .setConnectTimeout(timeoutInMillis)
.setConnectionRequestTimeout(timeoutInMillis)
.setResponseTimeout(timeoutInMillis)
.build();
- CloseableHttpClient httpClient = VespaHttpClientBuilder.create().build();
- URI statusUri = createStatusApiUri();
- if (debug)
- System.out.println("URI:" + statusUri);
- try {
+ try (CloseableHttpClient httpClient = VespaHttpClientBuilder.create().build()) {
+ URI statusUri = createStatusApiUri();
+ if (debug)
+ System.out.println("URI:" + statusUri);
HttpGet request = new HttpGet(statusUri);
request.addHeader("Connection", "Close");
request.setConfig(config);
@@ -95,7 +93,7 @@ public class FileDistributionStatusClient {
return content;
} else {
throw new RuntimeException("Failed to get status for request " + statusUri + ": " +
- response.getCode() + ": " + content);
+ response.getCode() + ": " + content);
}
} catch (IOException | ParseException e) {
throw new RuntimeException(e);
@@ -111,16 +109,12 @@ public class FileDistributionStatusClient {
throw new RuntimeException(e);
}
String status = jsonNode.get("status").asText();
- switch (status) {
- case statusUnknown:
- return "File distribution status unknown: " + jsonNode.get("message").asText();
- case statusInProgress:
- return "File distribution in progress:\n" + inProgressOutput(jsonNode.get("hosts"));
- case statusFinished:
- return "File distribution finished";
- default:
- throw new RuntimeException("Unknown status " + status);
- }
+ return switch (status) {
+ case statusUnknown -> "File distribution status unknown: " + jsonNode.get("message").asText();
+ case statusInProgress -> "File distribution in progress:\n" + inProgressOutput(jsonNode.get("hosts"));
+ case statusFinished -> "File distribution finished";
+ default -> throw new RuntimeException("Unknown status " + status);
+ };
}
private URI createStatusApiUri() {
@@ -158,7 +152,7 @@ public class FileDistributionStatusClient {
finished++;
}
}
- sb.append(" (" + finished + " of " + fileReferencesArray.size() + " finished)");
+ sb.append(" (").append(finished).append(" of ").append(fileReferencesArray.size()).append(" finished)");
break;
case statusFinished:
break; // Nothing to add