Mercury-IM/Smack
Mercury-IM/Smack
1
0
Fork 0
mirror of https://codeberg.org/Mercury-IM/Smack synced 2024-11-26 16:22:06 +01:00
Code Issues Releases Wiki Activity

Stops collecting data when the debugger gets closed

Browse source 
git-svn-id: http://svn.igniterealtime.org/svn/repos/smack/trunk@2216 b35dd754-fafc-0310-a699-88a17e54d16e
This commit is contained in:
Gaston Dombiak 2004-01-27 12:22:53 +00:00 committed by gdombiak
parent b1c2865ecd
commit 465100fdc6
1 changed files with 53 additions and 117 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

170
source/org/jivesoftware/smack/debugger/LiteDebugger.java
View file

@ -61,7 +61,7 @@ import javax.swing.*;
import org.jivesoftware.smack.*; import org.jivesoftware.smack.*;
import org.jivesoftware.smack.packet.*; import org.jivesoftware.smack.packet.*;
import org.jivesoftware.smack.util.StringUtils; import org.jivesoftware.smack.util.*;
/** /**
* The LiteDebugger is a very simple debugger that allows to debug sent, received and * The LiteDebugger is a very simple debugger that allows to debug sent, received and
@ -80,6 +80,8 @@ public class LiteDebugger implements SmackDebugger {
private Writer writer; private Writer writer;
private Reader reader; private Reader reader;
private ReaderListener readerListener;
private WriterListener writerListener;
public LiteDebugger(XMPPConnection connection, Writer writer, Reader reader) { public LiteDebugger(XMPPConnection connection, Writer writer, Reader reader) {
this.connection = connection; this.connection = connection;
@ -104,6 +106,13 @@ public class LiteDebugger implements SmackDebugger {
new JFrame( new JFrame(
"Smack Debug Window -- " + connection.getHost() + ":" + connection.getPort()); "Smack Debug Window -- " + connection.getHost() + ":" + connection.getPort());
// Add listener for window closing event
frame.addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent evt) {
rootWindowClosing(evt);
}
});
// We'll arrange the UI into four tabs. The first tab contains all data, the second // We'll arrange the UI into four tabs. The first tab contains all data, the second
// client generated XML, the third server generated XML, and the fourth is packet // client generated XML, the third server generated XML, and the fourth is packet
// data from the server as seen by Smack. // data from the server as seen by Smack.
@ -230,126 +239,41 @@ public class LiteDebugger implements SmackDebugger {
frame.setVisible(true); frame.setVisible(true);
// Create a special Reader that wraps the main Reader and logs data to the GUI. // Create a special Reader that wraps the main Reader and logs data to the GUI.
Reader debugReader = new Reader() { ObservableReader debugReader = new ObservableReader(reader);
readerListener = new ReaderListener() {
Reader myReader = reader; public void read(String str) {
int index = str.lastIndexOf(">");
public int read(char cbuf[], int off, int len) throws IOException { if (index != -1) {
int count = myReader.read(cbuf, off, len); receivedText1.append(str.substring(0, index + 1));
if (count > 0) { receivedText2.append(str.substring(0, index + 1));
String str = new String(cbuf, off, count); receivedText1.append(NEWLINE);
int index = str.lastIndexOf(">"); receivedText2.append(NEWLINE);
if (index != -1) { if (str.length() > index) {
receivedText1.append(str.substring(0, index + 1)); receivedText1.append(str.substring(index + 1));
receivedText2.append(str.substring(0, index + 1)); receivedText2.append(str.substring(index + 1));
receivedText1.append(NEWLINE); }
receivedText2.append(NEWLINE); }
if (str.length() > index) { else {
receivedText1.append(str.substring(index + 1)); receivedText1.append(str);
receivedText2.append(str.substring(index + 1)); receivedText2.append(str);
} }
} }
else { };
receivedText1.append(str); debugReader.addReaderListener(readerListener);
receivedText2.append(str);
}
}
return count;
}
public void close() throws IOException {
myReader.close();
}
public int read() throws IOException {
return myReader.read();
}
public int read(char cbuf[]) throws IOException {
return myReader.read(cbuf);
}
public long skip(long n) throws IOException {
return myReader.skip(n);
}
public boolean ready() throws IOException {
return myReader.ready();
}
public boolean markSupported() {
return myReader.markSupported();
}
public void mark(int readAheadLimit) throws IOException {
myReader.mark(readAheadLimit);
}
public void reset() throws IOException {
myReader.reset();
}
};
// Create a special Writer that wraps the main Writer and logs data to the GUI. // Create a special Writer that wraps the main Writer and logs data to the GUI.
Writer debugWriter = new Writer() { ObservableWriter debugWriter = new ObservableWriter(writer);
writerListener = new WriterListener() {
Writer myWriter = writer; public void write(String str) {
sentText1.append(str);
public void write(char cbuf[], int off, int len) throws IOException { sentText2.append(str);
myWriter.write(cbuf, off, len); if (str.endsWith(">")) {
String str = new String(cbuf, off, len); sentText1.append(NEWLINE);
sentText1.append(str); sentText2.append(NEWLINE);
sentText2.append(str); }
if (str.endsWith(">")) { }
sentText1.append(NEWLINE); };
sentText2.append(NEWLINE); debugWriter.addWriterListener(writerListener);
}
}
public void flush() throws IOException {
myWriter.flush();
}
public void close() throws IOException {
myWriter.close();
}
public void write(int c) throws IOException {
myWriter.write(c);
}
public void write(char cbuf[]) throws IOException {
myWriter.write(cbuf);
String str = new String(cbuf);
sentText1.append(str);
sentText2.append(str);
if (str.endsWith(">")) {
sentText1.append(NEWLINE);
sentText2.append(NEWLINE);
}
}
public void write(String str) throws IOException {
myWriter.write(str);
sentText1.append(str);
sentText2.append(str);
if (str.endsWith(">")) {
sentText1.append(NEWLINE);
sentText2.append(NEWLINE);
}
}
public void write(String str, int off, int len) throws IOException {
myWriter.write(str, off, len);
str = str.substring(off, off + len);
sentText1.append(str);
sentText2.append(str);
if (str.endsWith(">")) {
sentText1.append(NEWLINE);
sentText2.append(NEWLINE);
}
}
};
// Assign the reader/writer objects to use the debug versions. The packet reader // Assign the reader/writer objects to use the debug versions. The packet reader
// and writer will use the debug versions when they are created. // and writer will use the debug versions when they are created.
@ -369,6 +293,18 @@ public class LiteDebugger implements SmackDebugger {
}; };
} }
/**
* Notification that the root window is closing. Stop listening for received and
* transmitted packets.
*
* @param evt the event that indicates that the root window is closing
*/
public void rootWindowClosing(WindowEvent evt) {
connection.removePacketListener(listener);
((ObservableReader)reader).removeReaderListener(readerListener);
((ObservableWriter)writer).removeWriterListener(writerListener);
}
/** /**
* Listens for debug window popup dialog events. * Listens for debug window popup dialog events.
*/ */