[DIRMINA-807] Deadlock with NioDatagramAcceptor/Udp (Compilable code inlined showing issue)

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0, 2.0.1
• Fix Version/s: 2.0.2
• Component/s: Core
• Environment: Windows XP Service Pack 3 (32bit)
• Assignee: Emmanuel Lécharny
• Reporter: Jason
• Created: 03/Nov/10 16:43
• Updated: 08/Feb/11 11:03
• Resolved: 29/Nov/10 10:48

Description

NOTE: This issue occurs with 2.0.0 and 2.0.1

Comment out the addListener and apparent Deadlock goes away.

final IoServiceListener listener = new UdpIoServiceListener();
// APACHE: THIS CREATES A DEADLOCK
acceptor.addListener(listener);

When the listener is added bind never returns.
acceptor.bind(new InetSocketAddress(12345));

If you comment out the addListener, bind returns and you will see
the System.out..

(Compilable code inlined showing issue)

[BEGIN]

import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.util.Set;

import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.service.IoService;
import org.apache.mina.core.service.IoServiceListener;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.transport.socket.DatagramSessionConfig;
import org.apache.mina.transport.socket.nio.NioDatagramAcceptor;

public class UdpBug {
public static class UdpIoServiceListener implements IoServiceListener {
@Override
public void serviceActivated(final IoService service) throws Exception

{ System.out.println("UdpServiceListener#serviceActivated service: " + service); }

@Override
public void serviceDeactivated(final IoService service) throws Exception

{ System.out.println("UdpServiceListener#serviceDeactivated service: " + service); }

@Override
public void serviceIdle(final IoService service, final IdleStatus status) throws Exception

{ System.out.println("UdpServiceListener#serviceIdle service: " + service + " status: " + status); }

@Override
public void sessionCreated(final IoSession session) throws Exception

{ System.out.println("UdpServiceListener#sessionCreated session: " + session); }

@Override
public void sessionDestroyed(final IoSession session) throws Exception

{ System.out.println("UdpServiceListener#sessionDestroyed session: " + session); }

}

public static class UdpIoHandler extends IoHandlerAdapter {
public UdpIoHandler() {
}

@Override
public void sessionCreated(final IoSession session) throws Exception

{ System.out.println("UdpIoHandler#sessionCreated session: " + session); session.getConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10); }

@Override
public void sessionOpened(final IoSession session) throws Exception

{ System.out.println("UdpIoHandler#sessionOpened session: " + session); }

@Override
public void sessionClosed(final IoSession session) throws Exception

{ System.out.println("UdpIoHandler#sessionClosed session: " + session); }

@Override
public void sessionIdle(final IoSession session, final IdleStatus status) throws Exception

{ System.out.println("UdpIoHandler#sessionCreated session: " + session + " status: " + status); session.close(true); }

@Override
public void exceptionCaught(final IoSession session, final Throwable cause) throws Exception

{ System.out.println("UdpIoHandler#exceptionCaught session: " + session + " cause: " + cause); session.close(true); }

@Override
public void messageReceived(final IoSession session, final Object message) throws Exception

{ System.out.println("UdpIoHandler#messageReceived session: " + session + " message: " + message); }

}

public static final void main(String[] args) throws IOException {
// ByteBuffer.setUseDirectBuffers(false);
NioDatagramAcceptor acceptor = new NioDatagramAcceptor();
acceptor.setCloseOnDeactivation(true);

final IoServiceListener listener = new UdpIoServiceListener();
// APACHE: THIS CREATES A DEADLOCK
acceptor.addListener(listener);

final DatagramSessionConfig sessionConfig = acceptor.getSessionConfig();
sessionConfig.setReuseAddress(true);

final DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();

final LoggingFilter loggingFilter = new LoggingFilter();
chain.addLast("logFilter", loggingFilter);

// acceptor.setFilterChainBuilder(chain);
acceptor.setHandler(new UdpIoHandler());
acceptor.bind(new InetSocketAddress(12345));

final Set<SocketAddress> addrs = acceptor.getLocalAddresses();
for (final SocketAddress addr : addrs)

{ System.out.println("UdpServer.start " + addr.toString()); }

System.out.println("UdpServer started on port " + 12345);
}
}

[END]