summaryrefslogtreecommitdiffstats
path: root/vespaclient-core
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@oath.com>2018-01-31 12:43:43 +0100
committerJon Bratseth <bratseth@oath.com>2018-01-31 12:43:43 +0100
commiteb6b52500a0894b8d01393fc07e29a56369c7230 (patch)
tree6f8c8c702c8de7593952022feddc01895d56a5a8 /vespaclient-core
parent9afaa858a61dccc647eceaf5f12f611beb4578c9 (diff)
Never log once per request
Diffstat (limited to 'vespaclient-core')
-rwxr-xr-xvespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java19
1 files changed, 8 insertions, 11 deletions
diff --git a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java
index cf29814bef3..4b7d913c0f4 100755
--- a/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java
+++ b/vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java
@@ -21,9 +21,8 @@ import com.yahoo.vespa.config.content.LoadTypeConfig;
import com.yahoo.vespaclient.config.FeederConfig;
import java.util.List;
-import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.Executor;
-import java.util.logging.Logger;
+import java.util.concurrent.atomic.AtomicInteger;
/**
@@ -34,20 +33,19 @@ import java.util.logging.Logger;
*/
public final class VespaFeedHandler extends VespaFeedHandlerBase {
- private final static Logger log = Logger.getLogger(VespaFeedHandler.class.getName());
public static final String JSON_INPUT = "jsonInput";
- private AtomicInteger busyThreads = new AtomicInteger(0);
+ private final AtomicInteger busyThreads = new AtomicInteger(0);
private final int maxBusyThreads;
-
+ @SuppressWarnings("unused")
@Inject
- public VespaFeedHandler(FeederConfig feederConfig,
- LoadTypeConfig loadTypeConfig,
+ public VespaFeedHandler(FeederConfig feederConfig,
+ LoadTypeConfig loadTypeConfig,
DocumentmanagerConfig documentmanagerConfig,
SlobroksConfig slobroksConfig,
ClusterListConfig clusterListConfig,
- Executor executor,
+ Executor executor,
Metric metric) throws Exception {
super(feederConfig, loadTypeConfig, documentmanagerConfig, slobroksConfig, clusterListConfig, executor, metric);
this.maxBusyThreads = feederConfig.maxbusythreads();
@@ -73,10 +71,9 @@ public final class VespaFeedHandler extends VespaFeedHandlerBase {
}
try {
int busy = busyThreads.incrementAndGet();
- if (busy > maxBusyThreads) {
- log.warning("too many threads [" + busy + "] busy, returning SERVICE UNAVAILABLE");
+ if (busy > maxBusyThreads)
return new EmptyResponse(com.yahoo.jdisc.http.HttpResponse.Status.SERVICE_UNAVAILABLE);
- }
+
boolean asynchronous = request.getBooleanProperty("asynchronous");
MessagePropertyProcessor.PropertySetter properties = getPropertyProcessor().buildPropertySetter(request);