diff options
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/DispatchedChannel.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/DispatchedChannel.java | 38 |
1 files changed, 0 insertions, 38 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/DispatchedChannel.java b/container-search/src/main/java/com/yahoo/search/dispatch/DispatchedChannel.java deleted file mode 100644 index d005d9491d5..00000000000 --- a/container-search/src/main/java/com/yahoo/search/dispatch/DispatchedChannel.java +++ /dev/null @@ -1,38 +0,0 @@ -// Copyright 2018 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.search.dispatch; - -import com.yahoo.prelude.fastsearch.FS4ResourcePool; -import com.yahoo.search.dispatch.SearchCluster.Group; -import com.yahoo.search.dispatch.SearchCluster.Node; - -import java.util.Optional; - -/** - * An extension to CloseableChannel that encapsulates the release of a LoadBalancer group allocation. - * - * @author ollivir - */ -public class DispatchedChannel extends CloseableChannel { - private final SearchCluster.Group group; - private final LoadBalancer loadBalancer; - private boolean groupAllocated = true; - - public DispatchedChannel(FS4ResourcePool fs4ResourcePool, LoadBalancer loadBalancer, Group group, Node node) { - super(fs4ResourcePool.getBackend(node.hostname(), node.fs4port()), Optional.of(node.key())); - - this.loadBalancer = loadBalancer; - this.group = group; - } - - public DispatchedChannel(FS4ResourcePool fs4ResourcePool, LoadBalancer loadBalancer, Group group) { - this(fs4ResourcePool, loadBalancer, group, group.nodes().iterator().next()); - } - - public void close() { - if (groupAllocated) { - groupAllocated = false; - loadBalancer.releaseGroup(group); - } - super.close(); - } -} |