[KAFKA-6303] Potential lack of synchronization in NioEchoServer#AcceptorThread

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: network
• Assignee: siva santhalingam
• Reporter: Ted Yu
• Created: 04/Dec/17 00:32
• Updated: 01/Oct/18 22:42

Description

In the run() method:

                                SocketChannel socketChannel = ((ServerSocketChannel) key.channel()).accept();
                                socketChannel.configureBlocking(false);
                                newChannels.add(socketChannel);

Modification to newChannels should be protected by synchronized block.

Issue Links

• links to: GitHub Pull Request #4400