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

await closing sockets on shutdown

This commit is contained in:
kimchy 2010-12-29 12:49:37 +02:00
parent f993c4b72b
commit e764f41341
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java
View File

@ -324,7 +324,7 @@ public class NettyTransport extends AbstractLifecycleComponent<Transport> implem
for (Iterator<NodeChannels> it = connectedNodes.values().iterator(); it.hasNext();) {
NodeChannels nodeChannels = it.next();
it.remove();
nodeChannels.close();
nodeChannels.closeAndWait();
}
if (clientBootstrap != null) {
@ -615,5 +615,23 @@ public class NettyTransport extends AbstractLifecycleComponent<Transport> implem
}
}
}
public void closeAndWait() {
closeChannelsAndWait(low);
closeChannelsAndWait(med);
closeChannelsAndWait(high);
}
private void closeChannelsAndWait(Channel[] channels) {
for (Channel channel : channels) {
try {
if (channel != null && channel.isOpen()) {
channel.close().awaitUninterruptibly();
}
} catch (Exception e) {
//ignore
}
}
}
}
}