summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/DispatchedChannel.java
diff options
context:
space:
mode:
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.java38
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();
- }
-}