Skip to content

Commit

Permalink
Remove unused/deprecated TransportNodesAction ctor (#103304)
Browse files Browse the repository at this point in the history
Relates #100867
  • Loading branch information
DaveCTurner authored Dec 12, 2023
1 parent 4c55011 commit 7d2fb63
Showing 1 changed file with 0 additions and 28 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
import org.elasticsearch.action.FailedNodeException;
import org.elasticsearch.action.support.ActionFilters;
import org.elasticsearch.action.support.CancellableFanOut;
import org.elasticsearch.action.support.ChannelActionListener;
import org.elasticsearch.action.support.ThreadedActionListener;
import org.elasticsearch.action.support.TransportAction;
import org.elasticsearch.cluster.ClusterState;
Expand All @@ -27,7 +26,6 @@
import org.elasticsearch.common.util.concurrent.EsExecutors;
import org.elasticsearch.core.CheckedConsumer;
import org.elasticsearch.tasks.Task;
import org.elasticsearch.threadpool.ThreadPool;
import org.elasticsearch.transport.TransportChannel;
import org.elasticsearch.transport.TransportRequest;
import org.elasticsearch.transport.TransportRequestHandler;
Expand Down Expand Up @@ -83,32 +81,6 @@ protected TransportNodesAction(
transportService.registerRequestHandler(transportNodeAction, finalExecutor, nodeRequest, new NodeTransportHandler());
}

/**
* @deprecated Use the local-only constructor instead.
*/
@Deprecated(forRemoval = true)
@SuppressWarnings("this-escape")
protected TransportNodesAction(
String actionName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters,
Writeable.Reader<NodesRequest> requestReader,
Writeable.Reader<NodeRequest> nodeRequest,
Executor executor
) {
this(actionName, clusterService, transportService, actionFilters, nodeRequest, executor);
transportService.registerRequestHandler(
actionName,
executor,
false,
true,
requestReader,
(request, channel, task) -> execute(task, request, new ChannelActionListener<>(channel))
);
}

@Override
protected void doExecute(Task task, NodesRequest request, ActionListener<NodesResponse> listener) {
// coordination can run on SAME because it's only O(#nodes) work
Expand Down

0 comments on commit 7d2fb63

Please sign in to comment.