coolaj86
/
telebit-relay.js
1
1
Fork 0
Code Issues 4 Pull Requests Releases Activity

fix server.close() bug

This commit is contained in:
AJ ONeal 2018-06-01 06:48:18 +00:00
parent c37147a012
commit 3fe62c6b02
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
telebitd.js
View File

@ -49,7 +49,7 @@ module.exports.create = function (state) {
} }
conn.once('data', function (firstChunk) { conn.once('data', function (firstChunk) {
console.log("[DynTcp] examining firstChunk", serviceport); if (state.debug) { console.log("[DynTcp]", serviceport, "examining firstChunk from", Packer.socketToId(conn)); }
conn.pause(); conn.pause();
conn.unshift(firstChunk); conn.unshift(firstChunk);
@ -78,7 +78,7 @@ module.exports.create = function (state) {
// pipeWs(servername, servicename, client, remote, serviceport) // pipeWs(servername, servicename, client, remote, serviceport)
// remote.clients is managed as part of the piping process // remote.clients is managed as part of the piping process
console.log("[DynTcp] piping to remote", serviceport); if (state.debug) { console.log("[DynTcp]", serviceport, "piping to remote"); }
pipeWs(null, 'tcp', conn, remote, serviceport) pipeWs(null, 'tcp', conn, remote, serviceport)
process.nextTick(function () { conn.resume(); }); process.nextTick(function () { conn.resume(); });
@ -256,8 +256,10 @@ module.exports.create = function (state) {
}); });
remote.ws = null; remote.ws = null;
remote.upgradeReq = null; remote.upgradeReq = null;
remote.serverPort = remote.server.address().port;
remote.server.close(function () { remote.server.close(function () {
console.log("[DynTcpConn] closing server for ", remote.server.address().port); console.log("[DynTcpConn] closing server for ", remote.serverPort);
remote.serverPort = null;
}); });
remote.server = null; remote.server = null;