summaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin
diff options
context:
space:
mode:
authorHaakon Dybdahl <dybdahl@yahoo-inc.com>2017-01-26 11:18:16 +0100
committerHaakon Dybdahl <dybdahl@yahoo-inc.com>2017-01-26 11:18:16 +0100
commit29e2f5bcd58d287bc6e18cac7247801f1945f52d (patch)
tree519786528af1ce35a899bfe57f6903213fda6b2f /vespaclient-container-plugin
parent942c92856bc211250535170dc03d3a9a25cdade7 (diff)
Clean up code a bit
Diffstat (limited to 'vespaclient-container-plugin')
-rw-r--r--vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/ClientFeederV3.java15
1 files changed, 8 insertions, 7 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/ClientFeederV3.java b/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/ClientFeederV3.java
index 2b33c23cf5f..301b81f040c 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/ClientFeederV3.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/ClientFeederV3.java
@@ -133,13 +133,7 @@ class ClientFeederV3 {
* We try 10 for now. This should only kick in with very massive feeding to few gateway nodes.
*/
if (feederSettings.denyIfBusy && threadsAvailableForFeeding.get() < -10) {
- final int returnCode;
- if (request.getHeader(Headers.SILENTUPGRADE) != null ) {
- returnCode = 299;
- } else {
- returnCode = 429;
- }
- return new ErrorHttpResponse(returnCode, "Gateway overloaded");
+ return new ErrorHttpResponse(getOverloadReturnCode(request), "Gateway overloaded");
}
InputStream inputStream = StreamReaderV3.unzipStreamIfNeeded(request);
@@ -172,6 +166,13 @@ class ClientFeederV3 {
}
}
+ private int getOverloadReturnCode(HttpRequest request) {
+ if (request.getHeader(Headers.SILENTUPGRADE) != null ) {
+ return 299;
+ }
+ return 429;
+ }
+
private Optional<DocumentOperationMessageV3> pullMessageFromRequest(
FeederSettings settings, InputStream requestInputStream, BlockingQueue<OperationStatus> repliesFromOldMessages) {
while (true) {