kopia lustrzana https://github.com/c9/core
better cleanup after destroying reconnect socket
rodzic
00e9ced6ea
commit
86ac0ec42b
|
@ -50,6 +50,9 @@ var connectClient = module.exports = function(connectEio, options) {
|
|||
});
|
||||
|
||||
eioSocket.on("message", function handshakeReply(msg) {
|
||||
if (reconnectSocket.destroying) return;
|
||||
if (reconnectSocket.socket && reconnectSocket.socket != eioSocket)
|
||||
return console.error("reconenct for detached socket");
|
||||
try {
|
||||
msg = JSON.parse(msg);
|
||||
} catch (e) {}
|
||||
|
@ -75,11 +78,17 @@ var connectClient = module.exports = function(connectEio, options) {
|
|||
});
|
||||
|
||||
eioSocket.on("error", function(e) {
|
||||
if (reconnectSocket.destroying) return;
|
||||
if (reconnectSocket.socket && reconnectSocket.socket != eioSocket)
|
||||
return console.error("reconenct for detached socket");
|
||||
console.error("Socket error; reconnecting:", e);
|
||||
eioSocket.close();
|
||||
reconnect();
|
||||
});
|
||||
eioSocket.on("close", function(e) {
|
||||
if (reconnectSocket.destroying) return;
|
||||
if (reconnectSocket.socket && reconnectSocket.socket != eioSocket)
|
||||
return console.error("reconenct for detached socket");
|
||||
console.error("Socket close; reconnecting:", e);
|
||||
reconnect();
|
||||
});
|
||||
|
|
|
@ -345,7 +345,8 @@ define(function(require, exports, module) {
|
|||
});
|
||||
plugin.on("unload", function(){
|
||||
loaded = false;
|
||||
|
||||
if (connection && connection.socket)
|
||||
connection.socket.destroying = true;
|
||||
if (consumer)
|
||||
consumer.disconnect();
|
||||
if (connection)
|
||||
|
|
Ładowanie…
Reference in New Issue