summaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin
diff options
context:
space:
mode:
authorHaakon Dybdahl <dybdahl@yahoo-inc.com>2016-11-02 09:48:27 +0100
committerHaakon Dybdahl <dybdahl@yahoo-inc.com>2016-11-02 09:48:27 +0100
commit660704ec1025b775d7bb12592c1d00db5e94b04c (patch)
treef5610d98a0b3e13b0ef5cb4d8efce096ff8ef053 /vespaclient-container-plugin
parent57b6439da5a4b54c9392c40fb6bd2ddcd9e80026 (diff)
Improve log messages.
Diffstat (limited to 'vespaclient-container-plugin')
-rw-r--r--vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/Feeder.java25
1 files changed, 13 insertions, 12 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/Feeder.java b/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/Feeder.java
index cb3c7a7ab69..a7842f3b89f 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/Feeder.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/Feeder.java
@@ -73,6 +73,7 @@ public class Feeder implements Runnable {
private final CountDownLatch requestReceived = new CountDownLatch(1);
private final FeedReaderFactory feedReaderFactory;
+ // TODO refactor this perverse pile of constructor arguments
public Feeder(InputStream requestInputStream,
FeedReaderFactory feedReaderFactory,
DocumentTypeManager docTypeManager,
@@ -120,10 +121,7 @@ public class Feeder implements Runnable {
if (!clientId.contains("#")) {
throw new UnknownClientException("Got request from client with id '" + clientId +
"', but found no session for this client. " +
- "Most probably this server is in VIP rotation, " +
- "and a client session was rotated from one server to another. " +
- "This must not happen. Configure VIP with persistence=enabled, " +
- "or (preferably) do not use a VIP at all.");
+ "This is expected during upgrades of gateways and infrastructure nodes.");
}
int hashPos = clientId.indexOf("#");
String supposedHostname = clientId.substring(hashPos + 1, clientId.length());
@@ -131,7 +129,8 @@ public class Feeder implements Runnable {
throw new UnknownClientException("Got request from client with id '" + clientId +
"', but found no session for this client. Possible session " +
"timeout due to inactivity, server restart or reconfig, " +
- "or bad VIP usage.");
+ "or bad VIP usage. " +
+ "This is expected during upgrades of gateways and infrastructure nodes.");
}
if (!supposedHostname.equals(localHostname)) {
@@ -140,10 +139,9 @@ public class Feeder implements Runnable {
"Session was originally established towards host " +
supposedHostname + ", but our hostname is " +
localHostname + ". " +
- "Most probably this server is in VIP rotation, " +
- "and a session was rotated from one server to another. " +
- "This should not happen. Configure VIP with persistence=enabled, " +
- "or (preferably) do not use a VIP at all.");
+ "If using VIP rotation, this could be due to a session was rotated from one server to another. " +
+ "Configure VIP with persistence=enabled. " +
+ "This is expected during upgrades of gateways and infrastructure nodes.");
}
log.log(LogLevel.DEBUG, "Client '" + clientId + "' reconnected after session inactivity, or server restart " +
"or reconfig. Re-establishing session.");
@@ -273,14 +271,17 @@ public class Feeder implements Runnable {
++numPending;
updateMetrics(msg.second);
updateOpsPerSec();
- log(LogLevel.DEBUG, "Sent message successfully, document id: ", msg.first);
+ log(LogLevel.DEBUG, "Sent message successfully, document id: ",
+ msg.first);
} else if (!result.getError().isFatal()) {
- enqueue(msg.first, result.getError().getMessage(), ErrorCode.TRANSIENT_ERROR, msg.second);
+ enqueue(msg.first, result.getError().getMessage(),
+ ErrorCode.TRANSIENT_ERROR, msg.second);
break;
} else {
// should probably not happen, but everybody knows stuff that
// shouldn't happen, happens all the time
- enqueue(msg.first, result.getError().getMessage(), ErrorCode.ERROR, msg.second);
+ enqueue(msg.first, result.getError().getMessage(),
+ ErrorCode.ERROR, msg.second);
break;
}
}