diff options
author | Jon Bratseth <bratseth@verizonmedia.com> | 2019-01-24 16:19:53 +0100 |
---|---|---|
committer | Jon Bratseth <bratseth@verizonmedia.com> | 2019-01-24 16:19:53 +0100 |
commit | 67926d3509aaff8bb7a03b732c29a9fe5c7d03fd (patch) | |
tree | 683afce1b7855f54d483d8c3dde12c99dcfebb10 /vespa-http-client | |
parent | 1ed75a5681fc19966fdb1940f3f55e6c8f5c2c76 (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.java | 5 |
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); } } |