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

["Emmanuel Lecharny (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/DIRMINA-807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Emmanuel Lecharny resolved DIRMINA-807.
---------------------------------------

    Resolution: Fixed

Applied in trunk

> Deadlock with NioDatagramAcceptor/Udp (Compilable code inlined showing issue)
> -----------------------------------------------------------------------------
>
>                 Key: DIRMINA-807
>                 URL: https://issues.apache.org/jira/browse/DIRMINA-807
>             Project: MINA
>          Issue Type: Bug
>          Components: Core
>    Affects Versions: 2.0.0, 2.0.1
>         Environment: Windows XP Service Pack 3 (32bit)
>            Reporter: Jason
>            Assignee: Emmanuel Lecharny
>             Fix For: 2.0.2
>
>         Attachments: fix-race.diff
>
>
> 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] 

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.