frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
Code Issues Releases Wiki Activity

More defensive on closing tcp connections,

Browse Source 
and tidy up some lint
This commit is contained in:
dceejay 2015-04-19 12:13:45 +01:00
parent 9d809aa2ba
commit e206d2919e
1 changed files with 25 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
nodes/core/io/31-tcpin.js
View File

@ -59,17 +59,18 @@ module.exports = function(RED) {
data = data.toString(node.datatype); data = data.toString(node.datatype);
} }
if (node.stream) { if (node.stream) {
if ((node.datatype) === "utf8" && node.newline != "") { var msg;
if ((node.datatype) === "utf8" && node.newline !== "") {
buffer = buffer+data; buffer = buffer+data;
var parts = buffer.split(node.newline); var parts = buffer.split(node.newline);
for (var i = 0;i<parts.length-1;i+=1) { for (var i = 0;i<parts.length-1;i+=1) {
var msg = {topic:node.topic, payload:parts[i]}; msg = {topic:node.topic, payload:parts[i]};
msg._session = {type:"tcp",id:id}; msg._session = {type:"tcp",id:id};
node.send(msg); node.send(msg);
} }
buffer = parts[parts.length-1]; buffer = parts[parts.length-1];
} else { } else {
var msg = {topic:node.topic, payload:data}; msg = {topic:node.topic, payload:data};
msg._session = {type:"tcp",id:id}; msg._session = {type:"tcp",id:id};
node.send(msg); node.send(msg);
} }
@ -118,7 +119,7 @@ module.exports = function(RED) {
this.on('close', function(done) { this.on('close', function(done) {
node.done = done; node.done = done;
this.closing = true; this.closing = true;
client.end(); if (client) { client.end(); }
clearTimeout(reconnectTimeout); clearTimeout(reconnectTimeout);
if (!node.connected) { done(); } if (!node.connected) { done(); }
}); });
@ -135,17 +136,18 @@ module.exports = function(RED) {
data = data.toString(node.datatype); data = data.toString(node.datatype);
} }
if (node.stream) { if (node.stream) {
if ((typeof data) === "string" && node.newline != "") { var msg;
if ((typeof data) === "string" && node.newline !== "") {
buffer = buffer+data; buffer = buffer+data;
var parts = buffer.split(node.newline); var parts = buffer.split(node.newline);
for (var i = 0; i<parts.length-1; i+=1) { for (var i = 0; i<parts.length-1; i+=1) {
var msg = {topic:node.topic, payload:parts[i],ip:socket.remoteAddress,port:socket.remotePort}; msg = {topic:node.topic, payload:parts[i],ip:socket.remoteAddress,port:socket.remotePort,connected:true};
msg._session = {type:"tcp",id:id}; msg._session = {type:"tcp",id:id};
node.send(msg); node.send(msg);
} }
buffer = parts[parts.length-1]; buffer = parts[parts.length-1];
} else { } else {
var msg = {topic:node.topic, payload:data}; msg = {topic:node.topic, payload:data, connected:true};
msg._session = {type:"tcp",id:id}; msg._session = {type:"tcp",id:id};
node.send(msg); node.send(msg);
} }
@ -184,6 +186,7 @@ module.exports = function(RED) {
node.error('unable to listen on port '+node.port+' : '+err); node.error('unable to listen on port '+node.port+' : '+err);
} }
}); });
server.listen(node.port, function(err) { server.listen(node.port, function(err) {
if (err) { if (err) {
node.error('unable to listen on port '+node.port+' : '+err); node.error('unable to listen on port '+node.port+' : '+err);
@ -191,9 +194,11 @@ module.exports = function(RED) {
node.log('listening on port '+node.port); node.log('listening on port '+node.port);
node.on('close', function() { node.on('close', function() {
for (var c in connectionPool) { for (var c in connectionPool) {
if (connectionPool.hasOwnProperty(c)) {
connectionPool[c].end(); connectionPool[c].end();
connectionPool[c].unref(); connectionPool[c].unref();
} }
}
node.closing = true; node.closing = true;
server.close(); server.close();
node.log('stopped listening on port '+node.port); node.log('stopped listening on port '+node.port);
@ -266,7 +271,7 @@ module.exports = function(RED) {
} }
if (node.doend === true) { if (node.doend === true) {
end = true; end = true;
client.end(); if (client) { client.end(); }
} }
} }
}); });
@ -274,7 +279,7 @@ module.exports = function(RED) {
node.on("close", function(done) { node.on("close", function(done) {
node.done = done; node.done = done;
this.closing = true; this.closing = true;
client.end(); if (client) { client.end(); }
clearTimeout(reconnectTimeout); clearTimeout(reconnectTimeout);
if (!node.connected) { done(); } if (!node.connected) { done(); }
}); });
@ -349,9 +354,11 @@ module.exports = function(RED) {
node.log('listening on port '+node.port); node.log('listening on port '+node.port);
node.on('close', function() { node.on('close', function() {
for (var c in connectedSockets) { for (var c in connectedSockets) {
if (connectedSockets.hasOwnProperty(c)) {
connectedSockets[c].end(); connectedSockets[c].end();
connectedSockets[c].unref(); connectedSockets[c].unref();
} }
}
server.close(); server.close();
node.log('stopped listening on port '+node.port); node.log('stopped listening on port '+node.port);
}); });
@ -369,7 +376,7 @@ module.exports = function(RED) {
this.splitc = n.splitc; this.splitc = n.splitc;
if (this.out != "char") { this.splitc = Number(this.splitc); } if (this.out != "char") { this.splitc = Number(this.splitc); }
else { this.splitc.replace("\\n","\n").replace("\\r","\r").replace("\\t","\t").replace("\\e","\e").replace("\\f","\f").replace("\\0","\0"); } else { this.splitc.replace("\\n","\n").replace("\\r","\r").replace("\\t","\t").replace("\\e","\e").replace("\\f","\f").replace("\\0","\0"); } // jshint ignore:line
var buf; var buf;
if (this.out == "count") { buf = new Buffer(this.splitc); } if (this.out == "count") { buf = new Buffer(this.splitc); }
@ -424,7 +431,7 @@ module.exports = function(RED) {
var m = new Buffer(i+1); var m = new Buffer(i+1);
buf.copy(m,0,0,i+1); buf.copy(m,0,0,i+1);
node.send({"payload": m}); node.send({"payload": m});
client.end(); if (client) { client.end(); }
m = null; m = null;
}, node.splitc); }, node.splitc);
i = 0; i = 0;
@ -437,7 +444,7 @@ module.exports = function(RED) {
i += 1; i += 1;
if ( i >= node.serialConfig.count) { if ( i >= node.serialConfig.count) {
node.send({"payload": buf}); node.send({"payload": buf});
client.end(); if (client) { client.end(); }
i = 0; i = 0;
} }
} }
@ -449,7 +456,7 @@ module.exports = function(RED) {
var m = new Buffer(i); var m = new Buffer(i);
buf.copy(m,0,0,i); buf.copy(m,0,0,i);
node.send({"payload": m}); node.send({"payload": m});
client.end(); if (client) { client.end(); }
m = null; m = null;
i = 0; i = 0;
} }