aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-01-26 09:20:12 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2023-01-26 09:24:36 +0100
commitdec5fd736f9d3b02f4885407ae8def2360846014 (patch)
treea5237dc3fbf991b41b7313e96d53d1ccc41f0361 /vespaclient-java
parentb6e0d375b0f4c3096cd9299e81154451e8387006 (diff)
Revert apache 5.1 -> 5.2
Diffstat (limited to 'vespaclient-java')
-rw-r--r--vespaclient-java/src/main/java/com/yahoo/vespa/filedistribution/status/FileDistributionStatusClient.java31
1 files changed, 18 insertions, 13 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 bb532589750..a9bbfafeaf0 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
@@ -71,17 +71,18 @@ public class FileDistributionStatusClient {
System.out.println(parseAndGenerateOutput(json));
}
- @SuppressWarnings("deprecation")
private String doHttpRequest() {
Timeout timeoutInMillis = Timeout.ofMilliseconds((long) (timeout * 1000));
RequestConfig config = custom()
+ .setConnectTimeout(timeoutInMillis)
.setConnectionRequestTimeout(timeoutInMillis)
.setResponseTimeout(timeoutInMillis)
.build();
- try (CloseableHttpClient httpClient = VespaHttpClientBuilder.custom().connectTimeout(timeoutInMillis).buildClient()) {
- URI statusUri = createStatusApiUri();
- if (debug)
- System.out.println("URI:" + statusUri);
+ CloseableHttpClient httpClient = VespaHttpClientBuilder.create().build();
+ URI statusUri = createStatusApiUri();
+ if (debug)
+ System.out.println("URI:" + statusUri);
+ try {
HttpGet request = new HttpGet(statusUri);
request.addHeader("Connection", "Close");
request.setConfig(config);
@@ -94,7 +95,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);
@@ -110,12 +111,16 @@ public class FileDistributionStatusClient {
throw new RuntimeException(e);
}
String status = jsonNode.get("status").asText();
- 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);
- };
+ 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);
+ }
}
private URI createStatusApiUri() {
@@ -153,7 +158,7 @@ public class FileDistributionStatusClient {
finished++;
}
}
- sb.append(" (").append(finished).append(" of ").append(fileReferencesArray.size()).append(" finished)");
+ sb.append(" (" + finished + " of " + fileReferencesArray.size() + " finished)");
break;
case statusFinished:
break; // Nothing to add