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

ensure tcp node creates a buffer of size 1 at least

Browse Source
This commit is contained in:
Dave Conway-Jones 2016-04-10 12:21:56 +01:00
parent 1c9b5dfd00
commit 913b09570c
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -396,7 +396,10 @@ module.exports = function(RED) {
else { this.splitc = this.splitc.replace("\\n",0x0A).replace("\\r",0x0D).replace("\\t",0x09).replace("\\e",0x1B).replace("\\f",0x0C).replace("\\0",0x00); } // jshint ignore:line else { this.splitc = this.splitc.replace("\\n",0x0A).replace("\\r",0x0D).replace("\\t",0x09).replace("\\e",0x1B).replace("\\f",0x0C).replace("\\0",0x00); } // jshint ignore:line
var buf; var buf;
if (this.out == "count") { buf = new Buffer(this.splitc); } if (this.out == "count") {
if (this.splitc === 0) { buf = new Buffer(1); }
else { buf = new Buffer(this.splitc); }
}
else { buf = new Buffer(65536); } // set it to 64k... hopefully big enough for most TCP packets.... but only hopefully else { buf = new Buffer(65536); } // set it to 64k... hopefully big enough for most TCP packets.... but only hopefully
this.connected = false; this.connected = false;
@ -437,7 +440,7 @@ module.exports = function(RED) {
} }
else { else {
for (var j = 0; j < data.length; j++ ) { for (var j = 0; j < data.length; j++ ) {
if (node.out === "time") { if (node.out === "time") {
// do the timer thing // do the timer thing
if (node.tout) { if (node.tout) {
i += 1; i += 1;
@ -523,7 +526,6 @@ module.exports = function(RED) {
this.on("close", function(done) { this.on("close", function(done) {
node.done = done; node.done = done;
if (client) { if (client) {
buf = null;
client.destroy(); client.destroy();
} }
node.status({}); node.status({});