Fix regression which I introduced this morning
This commit is contained in:
parent
4c449e902f
commit
5240772424
@ -216,16 +216,12 @@ class NioServerSocketPipelineSink extends AbstractNioChannelSink {
|
||||
try {
|
||||
for (;;) {
|
||||
try {
|
||||
if (selector.select(1000) <= 0) {
|
||||
|
||||
// just continue if there was nothing selected
|
||||
continue;
|
||||
if (selector.select(1000) > 0) {
|
||||
// There was something selected if we reach this point, so clear
|
||||
// the selected keys
|
||||
selector.selectedKeys().clear();
|
||||
}
|
||||
|
||||
// There was something selected if we reach this point, so clear
|
||||
// the selected keys
|
||||
selector.selectedKeys().clear();
|
||||
|
||||
// accept connections in a for loop until no new connection is ready
|
||||
for (;;) {
|
||||
SocketChannel acceptedSocket = channel.socket.accept();
|
||||
|
Loading…
x
Reference in New Issue
Block a user