From 03bce1fe1a494f2ac9d4268d4c90b08011b3f600 Mon Sep 17 00:00:00 2001
From: gjoranv <gjoranv@gmail.com>
Date: Sun, 17 Dec 2017 21:44:49 +0100
Subject: Revert "Bratseth/tensorflow models"

---
 .../yahoo/vespa/http/client/core/communication/IOThread.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

(limited to 'vespa-http-client')

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 16a541f939c..7874dcb24ab 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
@@ -5,7 +5,6 @@ import com.google.common.annotations.Beta;
 import com.yahoo.vespa.http.client.Result;
 import com.yahoo.vespa.http.client.config.Endpoint;
 import com.yahoo.vespa.http.client.core.Document;
-import com.yahoo.vespa.http.client.core.Exceptions;
 import com.yahoo.vespa.http.client.core.operationProcessor.EndPointResultFactory;
 import com.yahoo.vespa.http.client.core.EndpointResult;
 import com.yahoo.vespa.http.client.core.ServerResponseException;
@@ -319,28 +318,29 @@ class IOThread implements Runnable, AutoCloseable {
                     successfullHandshakes.getAndIncrement();
                 } catch (ServerResponseException ser) {
                     executeProblemsCounter.incrementAndGet();
-                    log.log(Level.INFO, "Handshake did not work out " + endpoint, Exceptions.toMessageString(ser));
+                    log.log(Level.INFO, "Handshake did not work out " + endpoint, ser.getMessage());
                     drainFirstDocumentsInQueueIfOld();
                     return ThreadState.CONNECTED;
                 } catch (Throwable throwable) { // This cover IOException as well
                     executeProblemsCounter.incrementAndGet();
-                    log.log(Level.INFO, "Problem with Handshake " + endpoint, Exceptions.toMessageString(throwable));
+                    log.log(Level.INFO, "Problem with Handshake " + endpoint, throwable.getMessage());
                     drainFirstDocumentsInQueueIfOld();
                     client.close();
                     return ThreadState.DISCONNECTED;
                 }
                 return ThreadState.SESSION_SYNCED;
             case SESSION_SYNCED:
+                final int maxWaitTimeMilliSecs = 100;
                 try {
-                    ProcessResponse processResponse = pullAndProcessData(100);
+                    ProcessResponse processResponse = pullAndProcessData(maxWaitTimeMilliSecs);
                     gatewayThrottler.handleCall(processResponse.transitiveErrorCount);
                 }
                 catch (ServerResponseException ser) {
-                    log.info("Problems while handing data over to gateway " + endpoint + ": " + Exceptions.toMessageString(ser));
+                    log.info("Problems while handing data over to gateway " + endpoint + " " + ser.getMessage());
                     return ThreadState.CONNECTED;
                 }
                 catch (Throwable e) { // Covers IOException as well
-                    log.info("Problems while handing data over to gateway  " + endpoint + ": " + Exceptions.toMessageString(e));
+                    log.info("Problems while handing data over to gateway  " + endpoint + " " + e.getMessage());
                     client.close();
                     return ThreadState.DISCONNECTED;
                 }
-- 
cgit v1.2.3