aboutsummaryrefslogtreecommitdiffstats
path: root/vespa-http-client
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2020-04-16 11:14:09 +0200
committerJon Bratseth <bratseth@gmail.com>2020-04-16 11:14:09 +0200
commit42c17ff03aede800278ce5f56a4124059bf29e7b (patch)
tree0a7781c2d58a6c7e7919a560fc24b000a01bfafb /vespa-http-client
parent748fcdf0901196fb6c7339ffdaf45bd47c56c78b (diff)
Minor fixes
Diffstat (limited to 'vespa-http-client')
-rw-r--r--vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java2
-rw-r--r--vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java3
2 files changed, 2 insertions, 3 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java
index f9279f429ff..d8efeea93bc 100644
--- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java
+++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java
@@ -20,7 +20,7 @@ public class EndpointIOException extends IOException {
this.endpoint = endpoint;
}
- /** Returns the endpoint, or the failure occurred before this was assigned to a unique endpoint */
+ /** Returns the endpoint, or null if the failure occurred before this was assigned to a unique endpoint */
public Endpoint getEndpoint() { return endpoint; }
}
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 a6460c62375..44799e598b0 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
@@ -19,7 +19,6 @@ import java.util.List;
import java.util.Optional;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.logging.Level;
@@ -205,7 +204,7 @@ class IOThread implements Runnable, AutoCloseable {
chunkSizeBytes += document.size();
pendingSize++;
}
- if (log.isLoggable(Level.FINE))
+ if (log.isLoggable(Level.FINEST))
log.finest("Chunk has " + docsForSendChunk.size() + " docs with a size " + chunkSizeBytes + " bytes");
docsReceivedCounter.addAndGet(docsForSendChunk.size());
return docsForSendChunk;