Comparing version 0.9.14 to 0.9.15
@@ -18,3 +18,3 @@ var ipc=require('../../../node-ipc'); | ||
function(data,socket){ | ||
ipc.log('got a message from'.debug, (data.id).variable, (data.message).data); | ||
//ipc.log('got a message from'.debug, (data.id).variable, (data.message).data); | ||
ipc.server.emit( | ||
@@ -21,0 +21,0 @@ socket, |
@@ -118,2 +118,14 @@ var net = require('net'), | ||
client.log('## recieved events ##'.rainbow); | ||
if(!this.ipcBuffer) | ||
this.ipcBuffer=''; | ||
data=(this.ipcBuffer+=data); | ||
if(data.slice(-1)!=eventParser.delimiter){ | ||
client.log('Socket buffer size exceeded consider smaller messages or a larger buffer.'.warn, 'Implementing software buffer expansion for this message.'.notice); | ||
return; | ||
} | ||
this.ipcBuffer=''; | ||
var events = eventParser.parse(data); | ||
@@ -120,0 +132,0 @@ var eCount = events.length; |
@@ -169,2 +169,14 @@ var net = require('net'), | ||
function(data,UDPSocket){ | ||
if(!this.ipcBuffer) | ||
this.ipcBuffer=''; | ||
data=(this.ipcBuffer+=data); | ||
if(data.slice(-1)!=eventParser.delimiter){ | ||
server.log('Socket buffer size exceeded, consider smaller messages or a larger buffer.'.warn, 'Implementing software buffer expansion for this message.'.notice); | ||
return; | ||
} | ||
this.ipcBuffer=''; | ||
data=eventParser.parse(data); | ||
@@ -171,0 +183,0 @@ var sock=((server.udp4 || server.udp6)? UDPSocket : socket); |
{ | ||
"name": "node-ipc", | ||
"version": "0.9.14", | ||
"version": "0.9.15", | ||
"description": "A nodejs module for local and remote Inter Process Communication (IPC), Neural Networking, and able to facilitate machine learning.", | ||
@@ -5,0 +5,0 @@ "main": "node-ipc.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
61634
1291