summaryrefslogtreecommitdiffstats
path: root/vespa-http-client
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@verizonmedia.com>2019-01-24 16:19:53 +0100
committerJon Bratseth <bratseth@verizonmedia.com>2019-01-24 16:19:53 +0100
commit67926d3509aaff8bb7a03b732c29a9fe5c7d03fd (patch)
tree683afce1b7855f54d483d8c3dde12c99dcfebb10 /vespa-http-client
parent1ed75a5681fc19966fdb1940f3f55e6c8f5c2c76 (diff)
Nonfunctional changes only
Diffstat (limited to 'vespa-http-client')
-rw-r--r--vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java5
1 files changed, 2 insertions, 3 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java
index 618c187be33..8c4ff3ae108 100644
--- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java
+++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java
@@ -300,7 +300,7 @@ class IOThread implements Runnable, AutoCloseable {
return processResponse;
}
- private ThreadState cycle(final ThreadState threadState) {
+ private ThreadState cycle(ThreadState threadState) {
switch(threadState) {
case DISCONNECTED:
try {
@@ -359,7 +359,6 @@ class IOThread implements Runnable, AutoCloseable {
}
private void sleepIfProblemsGettingSyncedConnection(ThreadState newState, ThreadState oldState) {
-
if (newState == ThreadState.SESSION_SYNCED) return;
if (newState == ThreadState.CONNECTED && oldState == ThreadState.DISCONNECTED) return;
try {
@@ -394,7 +393,7 @@ class IOThread implements Runnable, AutoCloseable {
EndpointResult endpointResult = EndPointResultFactory.createTransientError(
endpoint, document.get().getOperationId(),
new Exception("Not sending document operation, timed out in queue after "
- + document.get().timeInQueueMillis() + " ms."));
+ + document.get().timeInQueueMillis() + " ms."));
resultQueue.failOperation(endpointResult, clusterId);
}
}