h4ckx0r/socket.io-client-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

improve manager disconnection and cleanup

Browse Source
This commit is contained in:
nkzawa
2016-02-01 01:03:49 +09:00
parent 1fd635bb47
commit 48420a6c6f
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/io/socket/client/Manager.java
View File

@@ -490,15 +490,22 @@ public class Manager extends Emitter {
On.Handle sub; On.Handle sub;
while ((sub = this.subs.poll()) != null) sub.destroy(); while ((sub = this.subs.poll()) != null) sub.destroy();
this.packetBuffer.clear();
this.encoding = false;
this.lastPing = null; this.lastPing = null;
this.decoder.destroy();
} }
/*package*/ void close() { /*package*/ void close() {
if (this.readyState != ReadyState.OPEN) { logger.fine("disconnect");
this.cleanup();
}
this.skipReconnect = true; this.skipReconnect = true;
this.reconnecting = false; this.reconnecting = false;
if (this.readyState != ReadyState.OPEN) {
// `onclose` will not fire because
// an open event never happened
this.cleanup();
}
this.backoff.reset(); this.backoff.reset();
this.readyState = ReadyState.CLOSED; this.readyState = ReadyState.CLOSED;
if (this.engine != null) { if (this.engine != null) {
@@ -507,7 +514,7 @@ public class Manager extends Emitter {
} }
private void onclose(String reason) { private void onclose(String reason) {
logger.fine("close"); logger.fine("onclose");
this.cleanup(); this.cleanup();
this.backoff.reset(); this.backoff.reset();
this.readyState = ReadyState.CLOSED; this.readyState = ReadyState.CLOSED;