bitinflow/server
1
0
Fork 0
mirror of https://github.com/bitinflow/server.git synced 2026-03-13 13:35:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup if server close throws

Browse Source
This commit is contained in:
Roman Shtylman
2013-11-26 18:20:53 -05:00
parent 10e75c348c
commit bb5ad1b0f4
1 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
proxy.js
View File

@@ -40,15 +40,20 @@ var Proxy = function(opt, cb) {
function maybe_tcp_close() { function maybe_tcp_close() {
clearTimeout(conn_timeout); clearTimeout(conn_timeout);
conn_timeout = setTimeout(function() { conn_timeout = setTimeout(function() {
client_server.close();
clearTimeout(conn_timeout); // sometimes the server is already closed but the event has not fired?
try {
clearTimeout(conn_timeout);
client_server.close();
} catch (err) {
cleanup();
}
}, 5000); }, 5000);
} }
maybe_tcp_close(); maybe_tcp_close();
// no longer accepting connections for this id function cleanup() {
client_server.on('close', function() {
debug('closed tcp socket for client(%s)', id); debug('closed tcp socket for client(%s)', id);
clearTimeout(conn_timeout); clearTimeout(conn_timeout);
@@ -59,7 +64,10 @@ var Proxy = function(opt, cb) {
}); });
self.emit('end'); self.emit('end');
}); }
// no longer accepting connections for this id
client_server.on('close', cleanup);
// new tcp connection from lt client // new tcp connection from lt client
client_server.on('connection', function(socket) { client_server.on('connection', function(socket) {