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

Get: Add a specific `get` thread pool that handles get request, closes #1778.

This commit is contained in:
Shay Banon 2012-03-09 21:07:50 +02:00
parent b83378f4ce
commit 1ed07a0c50
3 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/elasticsearch/action/get/TransportGetAction.java
View File

@ -56,7 +56,7 @@ public class TransportGetAction extends TransportShardSingleOperationAction<GetR
@Override
protected String executor() {
return ThreadPool.Names.SEARCH;
return ThreadPool.Names.GET;
}
@Override

2
src/main/java/org/elasticsearch/action/get/TransportShardMultiGetAction.java
View File

@ -54,7 +54,7 @@ public class TransportShardMultiGetAction extends TransportShardSingleOperationA
@Override
protected String executor() {
return ThreadPool.Names.SEARCH;
return ThreadPool.Names.GET;
}
@Override

2
src/main/java/org/elasticsearch/threadpool/ThreadPool.java
View File

@ -59,6 +59,7 @@ public class ThreadPool extends AbstractComponent {
public static class Names {
public static final String SAME = "same";
public static final String GENERIC = "generic";
public static final String GET = "get";
public static final String INDEX = "index";
public static final String BULK = "bulk";
public static final String SEARCH = "search";
@ -91,6 +92,7 @@ public class ThreadPool extends AbstractComponent {
executors.put(Names.GENERIC, build(Names.GENERIC, "cached", groupSettings.get(Names.GENERIC), settingsBuilder().put("keep_alive", "30s").build()));
executors.put(Names.INDEX, build(Names.INDEX, "cached", groupSettings.get(Names.INDEX), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.BULK, build(Names.BULK, "cached", groupSettings.get(Names.BULK), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.GET, build(Names.GET, "cached", groupSettings.get(Names.GET), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.SEARCH, build(Names.SEARCH, "cached", groupSettings.get(Names.SEARCH), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.PERCOLATE, build(Names.PERCOLATE, "cached", groupSettings.get(Names.PERCOLATE), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.MANAGEMENT, build(Names.MANAGEMENT, "scaling", groupSettings.get(Names.MANAGEMENT), settingsBuilder().put("keep_alive", "5m").put("size", 5).build()));