honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove dead code in EsExecutors (#61574) 

Removes a couple of unused methods.
This commit is contained in:
David Turner 2020-08-26 16:01:25 +01:00
parent 3ed65eb418
commit f2dc664228
1 changed files with 0 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
server/src/main/java/org/elasticsearch/common/util/concurrent/EsExecutors.java
View File

@ -28,7 +28,6 @@ import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.unit.TimeValue; import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.node.Node; import org.elasticsearch.node.Node;
import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import java.util.concurrent.AbstractExecutorService; import java.util.concurrent.AbstractExecutorService;
@ -44,7 +43,6 @@ import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Function; import java.util.function.Function;
import java.util.stream.Collectors;
public class EsExecutors { public class EsExecutors {
@ -240,15 +238,6 @@ public class EsExecutors {
return DIRECT_EXECUTOR_SERVICE; return DIRECT_EXECUTOR_SERVICE;
} }
public static String threadName(Settings settings, String ... names) {
String namePrefix =
Arrays
.stream(names)
.filter(name -> name != null)
.collect(Collectors.joining(".", "[", "]"));
return threadName(settings, namePrefix);
}
public static String threadName(Settings settings, String namePrefix) { public static String threadName(Settings settings, String namePrefix) {
if (Node.NODE_NAME_SETTING.exists(settings)) { if (Node.NODE_NAME_SETTING.exists(settings)) {
return threadName(Node.NODE_NAME_SETTING.get(settings), namePrefix); return threadName(Node.NODE_NAME_SETTING.get(settings), namePrefix);
@ -272,10 +261,6 @@ public class EsExecutors {
return daemonThreadFactory(threadName(nodeName, namePrefix)); return daemonThreadFactory(threadName(nodeName, namePrefix));
} }
public static ThreadFactory daemonThreadFactory(Settings settings, String ... names) {
return daemonThreadFactory(threadName(settings, names));
}
public static ThreadFactory daemonThreadFactory(String namePrefix) { public static ThreadFactory daemonThreadFactory(String namePrefix) {
return new EsThreadFactory(namePrefix); return new EsThreadFactory(namePrefix);
} }