diff options
author | Jon Bratseth <bratseth@oath.com> | 2018-01-31 12:43:43 +0100 |
---|---|---|
committer | Jon Bratseth <bratseth@oath.com> | 2018-01-31 12:43:43 +0100 |
commit | eb6b52500a0894b8d01393fc07e29a56369c7230 (patch) | |
tree | 6f8c8c702c8de7593952022feddc01895d56a5a8 /vespaclient-core | |
parent | 9afaa858a61dccc647eceaf5f12f611beb4578c9 (diff) |
Never log once per request
Diffstat (limited to 'vespaclient-core')
-rwxr-xr-x | vespaclient-core/src/main/java/com/yahoo/feedhandler/VespaFeedHandler.java | 19 |
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); |