Re: [xSocket-develop] suspendRead() and resumeRead() cause program hang?

[Gregor R. <gre...@go...>]

 Hello fchen,

thanks for your investigation. I'm going to cross check this. I saw that
your bug fix is based on xSocket V1.2.x. For maintenance reasons I'm going
to fix the bug.

Currently I try to reproduce our reported bug on xSocket 2.0 (The dispatcher
has been reimplemented by V2.0). The final version of xSocket 2.0 will be
released in 1-2 weeks.

Gregor


2008/4/22 fulichen <ful...@du...>:

>  Hello Gregor,
>
> Thanks for your response, but we find suspendRead() and resumeRead() will
> cause program hang, is it a bug (maybe there is race condition)? or how can
> we fix our test?
>
> The test program is following, and the test environment Java version
> 1.6.0_03 on Windows Vista.
> TestClient result hanging  a while after start (but not each TestClient
> test, try some times will get hang)
>
> =================================
> public class TestClient implements IDataHandler
> {
>  //-------------------------------
>  static public void main(String[] args)throws IOException,
> InterruptedException
>  {
>   TestClient c = new TestClient();
>   NonBlockingConnection nbc = new NonBlockingConnection("127.0.0.1", 1000,
> c);
>   Thread.sleep(100000000);
>  }
>  public boolean onData(INonBlockingConnection connection)throws
> IOException
>  {
>   System.out.println("onData enter");
>   try
>   {
>    connection.suspendRead(); // here call to suspendRead
>    int available = connection.available();
>    System.out.println("onData available = " + available);
>    byte[] data = connection.readBytesByLength(available);
>   }
>   finally
>   {
>    connection.resumeRead(); // call resumeRead here
>    System.out.println("onData exit");
>   }
>   return true;
>  }
> }
> =================================
> public class TestServer
> {
>  //-------------------------------
>  static public void main(String[] args)throws IOException
>  {
>   TestServer s = new TestServer();
>   s.doServer();
>  }
>  void doServer() throws IOException
>  {
>   ServerSocket ssck = new ServerSocket(1000);
>   Socket sck = ssck.accept();
>   OutputStream out = new BufferedOutputStream(sck.getOutputStream());
>   for (int i = 0; i < 100000000; i++)
>   {
>    String s = "Message " + i + "\r\n";
>    //1.write out a string
>    out.write(s.getBytes());
>    //2.write out bytes length
>    ByteBuffer buffer = ByteBuffer.allocate(4);
>    buffer.putInt(i);
>    buffer.rewind();
>    out.write(buffer.getInt());
>    //3.write out bytes
>    byte[] data = new byte[i];
>    out.write(data);
>    out.flush();
>   }
>  }
> }
> ========================================
> TestClient result
> onData enter
> onData available = 10027
> onData exit
> onData enter
> onData available = 16
> onData exit
> onData enter
> onData available = 3752
> onData exit
> onData enter
> onData available = 10044
> onData exit
> onData enter
> onData available = 3752
> onData exit
> ----- Original Message ----- From: <gre...@we...>
> To: "fulichen" <ful...@du...>
> Sent: Monday, April 21, 2008 7:21 PM
> Subject: Re: [xSocket-develop] OutOfMemory exception
>
> Hi fchen,
>
> by calling the <connection>.suspendRead() you can stop reading the socket.
> Reading will be resumed by calling the <connection>.reaumeRead() method. For
> an example see
> http://xsocket.svn.sourceforge.net/viewvc/xsocket/xsocket/core/trunk/src/test/java/org/xsocket/connection/LimitedReadTest.java?view=markup
>
> Gregor
>
>
> > -----Ursprgliche Nachricht-----
> > Von: "fulichen" <ful...@du...>
> > Gesendet: 21.04.08 12:35:09
> > An: <xso...@li...>
> > Betreff: [xSocket-develop] OutOfMemory exception
>
> Our application need to handle many many connection,
> > and the data need time to process,
> > because xSocket Dispatcher read data when it is avialable,
> > our application often run out of memory.
> >
> > How we limit Dispatcher data reading, or what can we do to prevent
> > OutOfMemoryException?
> >
> > fchen-----------------------------------------------------------------
> > -------- This SF.net email is sponsored by the 2008 JavaOne(SM)
> > Conference Don't miss this year's exciting event. There's still time
> > to save $100. Use priority code J8TL2D2. http://ad.doubleclick.net/
> > clk;198757673;13503038;p?http://java.sun.com/javaone__________________
> > _____________________________ xSocket-develop mailing list xSocket-
> > de...@li... https://lists.sourceforge.net/lists/
> >
> > listinfo/xsocket-develop
>
>
>
> --
> Gregor Roth
>
> -------------------------------------------------------------------------
> This SF.net email is sponsored by the 2008 JavaOne(SM) Conference
> Don't miss this year's exciting event. There's still time to save $100.
> Use priority code J8TL2D2.
>
> http://ad.doubleclick.net/clk;198757673;13503038;p?http://java.sun.com/javaone
> _______________________________________________
> xSocket-develop mailing list
> xSo...@li...
> https://lists.sourceforge.net/lists/listinfo/xsocket-develop
>
>