I created a JIRA issue regarding the problem:

http://issues.apache.org/jira/browse/DIRMINA-342

Trustin

On 12/27/06, Marc Boorshtein <[EMAIL PROTECTED]> wrote:

I hope everyone had a merry christmas and appoligies for sending this
to both lists, but I thought it was applicable to both apacheds and
mina.

I am utilizing the mina start and stop code from the apacheds class
"org.apache.directory.server.jndi.ServerContextFactory" in order to
start my own server.  The server starts OK, but when I try to stop the
server and start it again I am given the exception:

[2006-12-26 12:04:16,584][main] INFO  Server - Starting server...
[2006-12-26 12:04:16,909][main] ERROR Server - Could not bind to address
java.net.BindException: Address already in use
        at sun.nio.ch.Net.bind(Native Method)
        at sun.nio.ch.ServerSocketChannelImpl.bind(
ServerSocketChannelImpl.java:119)
        at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java
:59)
        at org.apache.mina.transport.socket.nio.SocketAcceptor.registerNew
(SocketAcceptor.java:442)
        at org.apache.mina.transport.socket.nio.SocketAcceptor.access$900(
SocketAcceptor.java:52)
        at org.apache.mina.transport.socket.nio.SocketAcceptor$Worker.run(
SocketAcceptor.java:268)
        at org.apache.mina.util.NamePreservingRunnable.run(
NamePreservingRunnable.java:43)
        at java.lang.Thread.run(Thread.java:595)

Here is my startup code:

LdapProtocolProvider protocolProvider = new
LdapProtocolProvider(this.globalChain,this.router);

//                       Disable the disconnection of the clients on
unbind
            SocketAcceptorConfig acceptorCfg = new SocketAcceptorConfig();
            acceptorCfg.setDisconnectOnUnbind( false );

            acceptorCfg.setReuseAddress( true );
            acceptorCfg.setFilterChainBuilder( new
DefaultIoFilterChainBuilder() );
            acceptorCfg.setThreadModel( threadModel );

            ((SocketSessionConfig)(acceptorCfg.getSessionConfig
())).setTcpNoDelay(
true );

            logger.debug("Port String : " + portString);
            logger.debug("Protocol Prpvider : " + protocolProvider);
            logger.debug("AcceptorConfig : " + acceptorCfg);
            logger.debug("tcpAcceptor : " + tcpAcceptor);

            tcpAcceptor = new SocketAcceptor();

            //try 3 times?
            for (int i=0;i<3;i++) {
                try {
                        tcpAcceptor.bind( new InetSocketAddress(
Integer.parseInt(portString) ), protocolProvider.getHandler(),
acceptorCfg );
                        break;
                } catch (java.net.BindException e) {
                        logger.error("Could not bind to address",e);
                }
            }


                        /*minaRegistry = new SimpleServiceRegistry();
                        Service service = new Service( "ldap",
TransportType.SOCKET, new
InetSocketAddress( Integer.parseInt(portString) ) );
                        */
                        logger.debug("LDAP listener started");

and here is my stop code

try
        {
            // we should unbind the service before we begin sending the
notice
            // of disconnect so new connections are not formed while we
process
            List writeFutures = new ArrayList();

            // If the socket has already been unbound as with a successful
            // GracefulShutdownRequest then this will complain that the
service
            // is not bound - this is ok because the GracefulShutdown
has already
            // sent notices to to the existing active sessions
            List sessions = null;
            try
            {
                sessions = new ArrayList(
tcpAcceptor.getManagedSessions( new InetSocketAddress( port ) ) );
            }
            catch ( IllegalArgumentException e )
            {
                logger.warn( "Seems like the LDAP service (" + port +
") has already been unbound." );
                return;
            }

            tcpAcceptor.unbind( new InetSocketAddress( port ) );
            if ( logger.isInfoEnabled() )
            {
                logger.info( "Unbind of an LDAP service (" + port + ") is
complete." );
                logger.info( "Sending notice of disconnect to existing
clients sessions." );
            }

            // Send Notification of Disconnection messages to all
connected clients.
            if ( sessions != null )
            {
                for ( Iterator i = sessions.iterator(); i.hasNext(); )
                {
                    IoSession session = ( IoSession ) i.next();
                    writeFutures.add( session.write(
NoticeOfDisconnect.UNAVAILABLE ) );
                }
            }

            // And close the connections when the NoDs are sent.
            Iterator sessionIt = sessions.iterator();
            for ( Iterator i = writeFutures.iterator(); i.hasNext(); )
            {
                WriteFuture future = ( WriteFuture ) i.next();
                future.join( 1000 );
                ( ( IoSession ) sessionIt.next() ).close();
            }
        }
        catch ( Exception e )
        {
                logger.warn( "Failed to sent NoD.", e );
        }

Both snippets were taken nearly verbatim from the apacheds class.

The issue only occurs if I have had clients connect to my server.  For
instance if I just start the server, stop it then start it again it
works just fine.  However if I start the server, run a search and then
stop it again this problem ocurrs.  As a side note, this server was
originally written against apacheds 0.9.8 and which ever version of
MINA that version came with and I never ran into this problem.  Any
help would be greatly appreciated.

Thanks!

Marc




--
what we call human nature is actually human habit
--
http://gleamynode.net/
--
PGP key fingerprints:
* E167 E6AF E73A CBCE EE41  4A29 544D DE48 FE95 4E7E
* B693 628E 6047 4F8F CFA4  455E 1C62 A7DC 0255 ECA6

Reply via email to