Commit 1109c4bb authored by Gaston Dombiak's avatar Gaston Dombiak Committed by gato

Added printing of traffic (commented out).

git-svn-id: http://svn.igniterealtime.org/svn/repos/openfire/trunk@7974 b35dd754-fafc-0310-a699-88a17e54d16e
parent 8f18cc5b
...@@ -13,21 +13,19 @@ package org.jivesoftware.openfire.nio; ...@@ -13,21 +13,19 @@ package org.jivesoftware.openfire.nio;
import org.apache.mina.common.IdleStatus; import org.apache.mina.common.IdleStatus;
import org.apache.mina.common.IoHandlerAdapter; import org.apache.mina.common.IoHandlerAdapter;
import org.apache.mina.common.IoSession; import org.apache.mina.common.IoSession;
import org.apache.mina.common.ByteBuffer;
import org.apache.mina.filter.codec.ProtocolDecoderException; import org.apache.mina.filter.codec.ProtocolDecoderException;
import org.dom4j.io.XMPPPacketReader; import org.dom4j.io.XMPPPacketReader;
import org.jivesoftware.util.Log;
import org.jivesoftware.openfire.Connection; import org.jivesoftware.openfire.Connection;
import org.jivesoftware.openfire.net.MXParser; import org.jivesoftware.openfire.net.MXParser;
import org.jivesoftware.openfire.net.ServerTrafficCounter; import org.jivesoftware.openfire.net.ServerTrafficCounter;
import org.jivesoftware.openfire.net.StanzaHandler; import org.jivesoftware.openfire.net.StanzaHandler;
import org.jivesoftware.util.Log;
import org.xmlpull.v1.XmlPullParserException; import org.xmlpull.v1.XmlPullParserException;
import org.xmlpull.v1.XmlPullParserFactory; import org.xmlpull.v1.XmlPullParserFactory;
import java.io.IOException; import java.io.IOException;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.nio.charset.Charset;
/** /**
* A ConnectionHandler is responsible for creating new sessions, destroying sessions and delivering * A ConnectionHandler is responsible for creating new sessions, destroying sessions and delivering
...@@ -128,6 +126,7 @@ public abstract class ConnectionHandler extends IoHandlerAdapter { ...@@ -128,6 +126,7 @@ public abstract class ConnectionHandler extends IoHandlerAdapter {
} }
// Update counter of read btyes // Update counter of read btyes
updateReadBytesCounter(session); updateReadBytesCounter(session);
//System.out.println("RCVD: " + message);
// Let the stanza handler process the received stanza // Let the stanza handler process the received stanza
try { try {
handler.process((String) message, parser); handler.process((String) message, parser);
...@@ -142,6 +141,7 @@ public abstract class ConnectionHandler extends IoHandlerAdapter { ...@@ -142,6 +141,7 @@ public abstract class ConnectionHandler extends IoHandlerAdapter {
super.messageSent(session, message); super.messageSent(session, message);
// Update counter of written btyes // Update counter of written btyes
updateWrittenBytesCounter(session); updateWrittenBytesCounter(session);
//System.out.println("SENT: " + Charset.forName("UTF-8").decode(((ByteBuffer)message).buf()));
} }
abstract NIOConnection createNIOConnection(IoSession session); abstract NIOConnection createNIOConnection(IoSession session);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment