diff options
author | Jon Bratseth <bratseth@oath.com> | 2018-04-24 15:26:18 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@oath.com> | 2018-04-24 15:26:18 +0200 |
commit | 06371345a7b7f7d27406bd8d72ca6769b7edb651 (patch) | |
tree | 4257b1f4b9f9891ce44bac60998029ebcf6b0e03 /container-search/src/main/java/com/yahoo/fs4 | |
parent | 29d894be652512bf2e44ce57ac126a35fb1985e1 (diff) |
Clear renderer hit groups
This allows us to stream more data than can fit in the container
(across all concurrent queries), as rendered hits in completed groups
can now be garbage collected.
We can not deference the hit groups themselves as that entails modifying
the parent list.
Diffstat (limited to 'container-search/src/main/java/com/yahoo/fs4')
-rw-r--r-- | container-search/src/main/java/com/yahoo/fs4/mplex/ConnectionPool.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/container-search/src/main/java/com/yahoo/fs4/mplex/ConnectionPool.java b/container-search/src/main/java/com/yahoo/fs4/mplex/ConnectionPool.java index 342dc120113..e84adfbef2c 100644 --- a/container-search/src/main/java/com/yahoo/fs4/mplex/ConnectionPool.java +++ b/container-search/src/main/java/com/yahoo/fs4/mplex/ConnectionPool.java @@ -13,10 +13,11 @@ import com.yahoo.log.LogLevel; /** * Pool of FS4 connections. * - * @author tonytv + * @author Tony Vaagenes */ public class ConnectionPool { - final static int CLEANINGPERIOD = 1000; // Execute every second + + private final static int CLEANINGPERIOD = 1000; // Execute every second private final Queue<FS4Connection> connections = new ConcurrentLinkedQueue<>(); private final AtomicInteger activeConnections = new AtomicInteger(0); private final AtomicInteger passiveConnections = new AtomicInteger(0); |