diff --git a/main.js b/main.js index 9cf1116..cebdb69 100644 --- a/main.js +++ b/main.js @@ -157,8 +157,13 @@ var recieve_buffer = new Buffer.alloc(0); var recieve_get = false; var recieve_size = 0; -function recieve_ordered(data, callback) +function recieve_ordered(data, recieve, callback) { + // Recieve helper global varibles + var recieve_buffer = recieve.buffer; + var recieve_get = recieve.get; + var recieve_size = recieve.size; + // Convert the data into a buffer data = toBuffer(data); @@ -314,11 +319,18 @@ function socket_init(socket, ondata) console.log("Connection from "+socket.localAddress); + // Create the recieve ordered memory model + var recieve_ordered_memory = { + buffer: new Buffer.alloc(0), + get: false, + size: 0 + } + // Wait for data sock.sock.on('data', function(data) { // Recieve data in order - recieve_ordered(data, function(data) + recieve_ordered(data, recieve_ordered_memory, function(data) { //console.log(data);