diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-11-29 17:40:00 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-11-29 17:40:00 +0100 |
commit | e807b7cab069732251d797a25f2bb6c8fd70c095 (patch) | |
tree | 19a421508950b5a00902bc6ee99fe0b99b83646c /container-search/src/main/java/com/yahoo/search/searchers | |
parent | deaac2672dbf627a319b7ebaba808e7918bd0186 (diff) |
Reduce need to access getJDiscRequest
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/searchers')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/searchers/ConnectionControlSearcher.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/searchers/ConnectionControlSearcher.java b/container-search/src/main/java/com/yahoo/search/searchers/ConnectionControlSearcher.java index 15c683ccb10..90cb05be1f8 100644 --- a/container-search/src/main/java/com/yahoo/search/searchers/ConnectionControlSearcher.java +++ b/container-search/src/main/java/com/yahoo/search/searchers/ConnectionControlSearcher.java @@ -1,7 +1,7 @@ // Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.search.searchers; -import com.yahoo.container.jdisc.HttpRequest; +import com.yahoo.component.annotation.Inject; import com.yahoo.processing.request.CompoundName; import com.yahoo.search.Query; import com.yahoo.search.Result; @@ -53,6 +53,7 @@ public class ConnectionControlSearcher extends Searcher { private static final String HTTP_CONNECTION_HEADER_NAME = "Connection"; private static final String HTTP_CONNECTION_CLOSE_ARGUMENT = "Close"; + @Inject public ConnectionControlSearcher() { this(() -> System.currentTimeMillis()); } @@ -100,14 +101,13 @@ public class ConnectionControlSearcher extends Searcher { } private void setCloseIfLifetimeExceeded(Query query, Result result, int maxLifetimeSeconds) { - final HttpRequest httpRequest = query.getHttpRequest(); - if (httpRequest == null) { + if (query.getHttpRequest() == null) { query.trace(false, 5, simpleName, " got max lifetime = ", maxLifetimeSeconds, ", but got no JDisc request. Setting no header."); return; } - final long connectedAtMillis = httpRequest.getJDiscRequest().getConnectedAt(TimeUnit.MILLISECONDS); + final long connectedAtMillis = query.getHttpRequest().getConnectedAt(TimeUnit.MILLISECONDS); final long maxLifeTimeMillis = maxLifetimeSeconds * 1000L; if (connectedAtMillis + maxLifeTimeMillis < clock.getAsLong()) { result.getHeaders(true).put(HTTP_CONNECTION_HEADER_NAME, HTTP_CONNECTION_CLOSE_ARGUMENT); |