Sorry, I just realized that this class is the full test. Can you
create a JIRA and attach this test into it?
During week-end there is not that much people around the project, and
a mail cvna be easily missed. JIRA don't get lost buried by hundreds
of mails ...
On Sun, Jun 1, 2008 at 11:35 AM, Emmanuel Lecharny <[EMAIL PROTECTED]> wrote:
> Hi Owen,
>
> do you have a full working test demonstrating the problem?
>
> It would be best to create a JIRA, and attach the test.
>
> Thanks !
>
> On Fri, May 30, 2008 at 6:49 PM, Owen Gu <[EMAIL PROTECTED]> wrote:
>> Please try following testing code, you will find if the NioProcessor counts
>> are 100, when the server accept and close more than 100 connections, there
>> will have 100 NioSocketSession instance live forever. Can anyone tells me
>> why, is this a mina 2.0-m1 bug?
>>
>> import java.net.InetSocketAddress;
>>
>> import org.apache.mina.common.IdleStatus;
>> import org.apache.mina.common.IoHandler;
>> import org.apache.mina.common.IoSession;
>> import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
>>
>> public class Transport
>> {
>> private static class Hanlder implements IoHandler
>> {
>> public void exceptionCaught(IoSession session, Throwable cause)
>> throws Exception
>> {
>> session.close();
>> }
>>
>> public void messageReceived(IoSession session, Object message)
>> throws Exception
>> {
>> }
>>
>> public void messageSent(IoSession session, Object message) throws
>> Exception
>> {
>> }
>>
>> public void sessionClosed(IoSession session) throws Exception
>> {
>> session.close();
>> System.out.println("sessionClosed");
>> }
>>
>> public void sessionCreated(IoSession session) throws Exception
>> {
>> session.getConfig().setBothIdleTime(1);
>> System.out.println("sessionCreated");
>> }
>>
>> public void sessionIdle(IoSession session, IdleStatus status) throws
>> Exception
>> {
>> session.close();
>> }
>>
>> public void sessionOpened(IoSession session) throws Exception
>> {
>> System.out.println("sessionOpened");
>> session.close();
>> }
>> }
>>
>> public static void main(String[] arg)
>> {
>> try
>> {
>> NioSocketAcceptor acceptor = new NioSocketAcceptor(100);
>> acceptor.setReuseAddress(true);
>> acceptor.getSessionConfig().setReuseAddress(false);
>> acceptor.getSessionConfig().setReceiveBufferSize(1024);
>> acceptor.getSessionConfig().setSendBufferSize(1024);
>> acceptor.getSessionConfig().setTcpNoDelay(true);
>> acceptor.getSessionConfig().setSoLinger(-1);
>> acceptor.setBacklog(50);
>> acceptor.setHandler(new Hanlder());
>> acceptor.bind(new InetSocketAddress("0.0.0.0", 51127));
>> }
>> catch (Exception ex)
>> {
>> }
>> }
>> }
>>
>
>
>
> --
> Regards,
> Cordialement,
> Emmanuel Lécharny
> www.iktek.com
>
--
Regards,
Cordialement,
Emmanuel Lécharny
www.iktek.com
