Re: [xSocket-develop] Memory problems while using xSocket as a server

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

Hi Kasper,

thank you very much for your detailed report. 

I run your code by using JProfiler. JProfiler shows similar graphics as you reported. This is caused by the selector approach/periodic checks. Internally xSockets uses a selector call with timeout -> selector.select(1000). This means the select will be called each second. Internally java classes such as sun.nio.ch.SelectorImpl create temporary objects such as a KeyIterator object for each select loop.

If I trigger the gc run, I will observe that the instance count/size falls back to the initial value. 

cheers
Gregor 



> ----- Original Message -----
> From: Kasper Grubbe
> Sent: 04/28/10 04:27 PM
> To: xso...@li...
> Subject: [xSocket-develop] Memory problems while using xSocket as a server
> 
Hi, im experiencing a possible memoryleak when using xSocket.

I am running with the xSocket(core) with the following version:
 Implementation-Version=2.8.12 
 Implementation-Date=2010-04-19 09:26 MESZ

The amount of memory and live objects is just rising and rising even
with no connections at all. The NetBeans profiler only shows that it
is a HashMap iterator that is using more and more memory.
Try to use the following code (with a profiler that you like, i am
using NetBeans):
import org.xsocket.connection.*;

public class NextServer
{
 protected static IServer srv = null;

 public static void main(String[] args)
 {
 try
 {
 // http://xsocket.sourceforge.net/core/tutorial/V2/TutorialCore.htm
 srv = new Server("127.0.0.1", 1338, new xGuestSocketDataHandler());
 srv.run();
 }
 catch(Exception ex)
 {
 System.out.println(ex.getMessage());
 }
 }

 protected static void shutdownServer()
 {
 try
 {
 srv.close();
 }
 catch(Exception ex)
 {
 System.out.println(ex.getMessage());
 }
 }
}

And my xGuestSocketDataHandler that i am using as a connection handler:

import java.io.IOException;
import java.nio.BufferUnderflowException;
import java.nio.channels.ClosedChannelException;
import org.xsocket.*;
import org.xsocket.connection.*;

public class xGuestSocketDataHandler implements IDataHandler,
IConnectHandler, IDisconnectHandler
{
 public boolean onData(INonBlockingConnection nbc) throws
IOException, BufferUnderflowException, ClosedChannelException,
MaxReadSizeExceededException
 {
 try
 {
 String data = nbc.readStringByDelimiter("\r\n> ");

 if(data.trim().length() > 0)
 {
 System.out.println("Incoming data: " + data);

 String[] message = data.split(";");

 if(message.length == 2 && message[0].equalsIgnoreCase("auth"))
 {
 //IHandler newUserHandler = new
xUserSocketDataHandler(message[1],nbc);
 //nbc.setHandler(newUserHandler);
 }
 else if(message[0].equalsIgnoreCase("SHUTDOWN"))
 {
 NextServer.shutdownServer();
 }
 else
 {
 nbc.write("Authentication failed!");
 }
 }
 }
 catch(Exception ex)
 {
 System.out.println("onData: " + ex.getMessage());
 }

 return true;
 }

 public boolean onConnect(INonBlockingConnection nbc) throws
IOException, BufferUnderflowException, MaxReadSizeExceededException
 {
 try
 {
 nbc.write("K-THXBYE");
 System.out.println("onConnect");
 }
 catch(Exception ex)
 {
 System.out.println("onConnect: " + ex.getMessage());
 }

 return true;
 }

 public boolean onDisconnect(INonBlockingConnection nbc) throws IOException
 {
 try
 {
 System.out.println("onDisconnect");
 }
 catch(Exception ex)
 {
 System.out.println("onDisconnect: " + ex.getMessage());
 }

 return true;
 }
}

This is when the program is launched:
http://imgur.com/zyDrh.png

And after a couple of minutes (7-8 minutesl):
http://imgur.com/jm1M3.png

When 26 threads connects and writes to the server:
http://imgur.com/tcWfA.png

When the threads disconnects again:
http://imgur.com/boUv0.png (The number of KeyIterators are still rising)

Running after 30-40 minutes:
http://imgur.com/CWPD8.png

I don't believe that i am doing anything wrong. Am I? Is it a bug?


Best regards
--
Kasper Grubbe
Computer Science AP

Phone: (+45) 42 42 42 74
Mail: kas...@gm...

Kettegårds Allè 70,1,6115
2650 Hvidovre
Denmark

------------------------------------------------------------------------------
_______________________________________________
xSocket-develop mailing list
xSo...@li...
https://lists.sourceforge.net/lists/listinfo/xsocket-develop