[#1539] Fix bug in DefaultChannelGroup.close() which was blocking the close() call on ServerChannel
This commit is contained in:
parent
65c2a6ed46
commit
39b57b889c
@ -186,7 +186,7 @@ public class DefaultChannelGroup extends AbstractSet<Channel> implements Channel
|
|||||||
new LinkedHashMap<Integer, ChannelFuture>(size());
|
new LinkedHashMap<Integer, ChannelFuture>(size());
|
||||||
|
|
||||||
for (Channel c: serverChannels.values()) {
|
for (Channel c: serverChannels.values()) {
|
||||||
futures.put(c.id(), c.close().awaitUninterruptibly());
|
futures.put(c.id(), c.close());
|
||||||
}
|
}
|
||||||
for (Channel c: nonServerChannels.values()) {
|
for (Channel c: nonServerChannels.values()) {
|
||||||
futures.put(c.id(), c.close());
|
futures.put(c.id(), c.close());
|
||||||
|
Loading…
Reference in New Issue
Block a user