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

don't execute it on a thread pool

This commit is contained in:
kimchy 2010-07-20 18:34:01 +03:00
parent 553e8134ee
commit b3b5c9b0cc
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
modules/elasticsearch/src/main/java/org/elasticsearch/transport/local/LocalTransport.java
View File

@ -90,11 +90,7 @@ public class LocalTransport extends AbstractLifecycleComponent<Transport> implem
for (final LocalTransport targetTransport : transports.values()) {
for (final Map.Entry<DiscoveryNode, LocalTransport> entry : targetTransport.connectedNodes.entrySet()) {
if (entry.getValue() == this) {
targetTransport.threadPool().cached().execute(new Runnable() {
@Override public void run() {
targetTransport.disconnectFromNode(entry.getKey());
}
});
targetTransport.disconnectFromNode(entry.getKey());
}
}
}