vanitasvitae
/
Smack
mirror of https://github.com/vanitasvitae/Smack.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Keeps track of the number of packets read. 

git-svn-id: http://svn.igniterealtime.org/svn/repos/smack/trunk@2152 b35dd754-fafc-0310-a699-88a17e54d16e
This commit is contained in:
Matt Tucker 2003-10-21 17:39:04 +00:00 committed by mtucker
parent 63e1d822a5
commit 88eb8090e6
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
source/org/jivesoftware/smack/PacketReader.java
View File

@ -95,6 +95,8 @@ class PacketReader {
private String connectionID = null; private String connectionID = null;
private Object connectionIDLock = new Object(); private Object connectionIDLock = new Object();
private int packetsRead = 0;
protected PacketReader(XMPPConnection connection) { protected PacketReader(XMPPConnection connection) {
this.connection = connection; this.connection = connection;
@ -169,6 +171,15 @@ class PacketReader {
} }
} }
/**
* Returns the number of packets read by the packet reader.
*
* @return the number of packets read by the packet reader.
*/
public int getPacketsRead() {
return packetsRead;
}
/** /**
* Starts the packet reader thread and returns once a connection to the server * Starts the packet reader thread and returns once a connection to the server
* has been established. A connection will be attempted for a maximum of five * has been established. A connection will be attempted for a maximum of five
@ -331,6 +342,9 @@ class PacketReader {
return; return;
} }
// Increment the number of packets read.
packetsRead++;
// Remove all null values from the collectors list. // Remove all null values from the collectors list.
synchronized (collectors) { synchronized (collectors) {
for (int i=collectors.size()-1; i>=0; i--) { for (int i=collectors.size()-1; i>=0; i--) {
@ -358,7 +372,7 @@ class PacketReader {
* @return an IQ object. * @return an IQ object.
* @throws Exception if an exception occurs while parsing the packet. * @throws Exception if an exception occurs while parsing the packet.
*/ */
private Packet parseIQ(XmlPullParser parser) throws Exception { private IQ parseIQ(XmlPullParser parser) throws Exception {
IQ iqPacket = null; IQ iqPacket = null;
String id = parser.getAttributeValue("", "id"); String id = parser.getAttributeValue("", "id");
@ -621,7 +635,7 @@ class PacketReader {
* Parses a message packet. * Parses a message packet.
* *
* @param parser the XML parser, positioned at the start of a message packet. * @param parser the XML parser, positioned at the start of a message packet.
* @return a Message object. * @return a Message packet.
* @throws Exception if an exception occurs while parsing the packet. * @throws Exception if an exception occurs while parsing the packet.
*/ */
private Packet parseMessage(XmlPullParser parser) throws Exception { private Packet parseMessage(XmlPullParser parser) throws Exception {
@ -694,10 +708,10 @@ class PacketReader {
* Parses a presence packet. * Parses a presence packet.
* *
* @param parser the XML parser, positioned at the start of a presence packet. * @param parser the XML parser, positioned at the start of a presence packet.
* @return an Presence object. * @return a Presence packet.
* @throws Exception if an exception occurs while parsing the packet. * @throws Exception if an exception occurs while parsing the packet.
*/ */
private Packet parsePresence(XmlPullParser parser) throws Exception { private Presence parsePresence(XmlPullParser parser) throws Exception {
Presence.Type type = Presence.Type.fromString(parser.getAttributeValue("", "type")); Presence.Type type = Presence.Type.fromString(parser.getAttributeValue("", "type"));
Presence presence = new Presence(type); Presence presence = new Presence(type);
@ -913,4 +927,4 @@ class PacketReader {
packetListener = null; packetListener = null;
} }
} }
} }