vanitasvitae/Smack
1
0
Fork 0
mirror of https://github.com/vanitasvitae/Smack.git synced 2024-11-25 05:22:06 +01:00
Code Issues Releases Wiki Activity

Add javadoc to and fix typo in XMPPTCPConnection

Browse source
This commit is contained in:
Florian Schmaus 2015-01-15 16:11:49 +01:00
parent 3582de0654
commit ed84b4a8b3
1 changed files with 13 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
smack-tcp/src/main/java/org/jivesoftware/smack/tcp/XMPPTCPConnection.java
View file

@ -147,8 +147,12 @@ public class XMPPTCPConnection extends AbstractXMPPConnection {
*/
private boolean disconnectedButResumeable = false;
// socketClosed is used concurrent
// by XMPPTCPConnection, PacketReader, PacketWriter
/**
* Flag to indicate if the socket was closed intentionally by Smack.
* <p>
* This boolean flag is used concurrently, therefore it is marked volatile.
* </p>
*/
private volatile boolean socketClosed = false;
private boolean usingTLS = false;
@ -209,6 +213,11 @@ public class XMPPTCPConnection extends AbstractXMPPConnection {
*/
private boolean useSm = useSmDefault;
private boolean useSmResumption = useSmResumptionDefault;
/**
* The counter that the server sends the client about it's current height. For example, if the server sends
* {@code <a h='42'/>}, then this will be set to 42 (while also handling the {@link #unacknowledgedStanzas} queue).
*/
private long serverHandledStanzasCount = 0;
/**
@ -221,6 +230,7 @@ public class XMPPTCPConnection extends AbstractXMPPConnection {
* </p>
*/
private long clientHandledStanzasCount = 0;
private BlockingQueue<Packet> unacknowledgedStanzas;
/**
@ -1043,7 +1053,7 @@ public class XMPPTCPConnection extends AbstractXMPPConnection {
}
smServerMaxResumptimTime = enabled.getMaxResumptionTime();
} else {
// Mark this a aon-resumable stream by setting smSessionId to null
// Mark this a non-resumable stream by setting smSessionId to null
smSessionId = null;
}
clientHandledStanzasCount = 0;