memory creeps up

[vasion]

I have implemented a very small and simple socket server which takes xml
messages and if the message is from the local server, it is sent to
everybody else. It works, but memory crept up to 32% of 512MB with only one
user connected. When i started it, it used up 16%. i close the channels on
disconnect, so i have no idea what i am doing wrong. 

Handler


import java.util.logging.Level;
import java.util.logging.Logger;
import java.net.InetSocketAddress;
import org.jboss.netty.channel.ChannelStateEvent;
import org.jboss.netty.buffer.ChannelBuffer;
import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelPipelineCoverage;
import org.jboss.netty.channel.ExceptionEvent;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.channel.SimpleChannelUpstreamHandler;
import org.jboss.netty.channel.group.ChannelGroup;
import org.jboss.netty.channel.group.DefaultChannelGroup;
/**

*handler for RadioPopuliServer

 *
 **/

@ChannelPipelineCoverage("all")

public class RadioPopuliHandler extends SimpleChannelUpstreamHandler {

	private static final Logger logger =
Logger.getLogger(RadioPopuliHandler.class.getName());
	public ChannelGroup allchannels = new DefaultChannelGroup();
        private InetSocketAddress address;
        private String msg;
        private ChannelBuffer chanbuf;

@Override
	public void channelOpen(ChannelHandlerContext ctx, ChannelStateEvent e)
throws Exception {
                    allchannels.add(e.getChannel());
			}


@Override
    public void messageReceived(
            ChannelHandlerContext ctx, MessageEvent e) {
        // Send back the received message to the remote peer
            
                //

                address = (InetSocketAddress)(e.getRemoteAddress());
                if(address.getAddress().isLoopbackAddress()){
                    allchannels.write(e.getMessage());
                }
    }



@Override
    public void exceptionCaught(
            ChannelHandlerContext ctx, ExceptionEvent e) {
        // Close the connection when an exception is raised.
        logger.log(
                Level.WARNING,
                "Unexpected exception from downstream.",
                e.getCause());
        e.getChannel().close();

    }

@Override
    public void channelDisconnected(ChannelHandlerContext ctx,
ChannelStateEvent e){
        allchannels.remove(e.getChannel());
    }

}

Server

import java.net.InetSocketAddress;
import java.util.concurrent.Executors;

import org.jboss.netty.bootstrap.ServerBootstrap;
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;



public class RadioPopuliServer {
      public static void main(String[] args) throws Exception {
	// Configure the server.
    	  ServerBootstrap bootstrap = new ServerBootstrap(
              	new NioServerSocketChannelFactory(
                      	Executors.newCachedThreadPool(),
                      	Executors.newCachedThreadPool()));
 // Set up the default event pipeline.

         
        RadioPopuliHandler handler = new RadioPopuliHandler();



        bootstrap.getPipeline().addLast("handler", handler);
// Bind and start to accept incoming connections.

        bootstrap.bind(new InetSocketAddress(8080));
    }
}





-- 
View this message in context: http://netty-forums-and-mailing-lists.685743.n2.nabble.com/memory-creeps-up-tp5230889p5230889.html
Sent from the Netty User Group mailing list archive at Nabble.com.