diff --git a/example/unixSocket/basic/world-server.js b/example/unixSocket/basic/world-server.js index cd57127..7ad96e9 100644 --- a/example/unixSocket/basic/world-server.js +++ b/example/unixSocket/basic/world-server.js @@ -15,7 +15,7 @@ ipc.serve( ipc.server.on( 'app.message', 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( socket, 'app.message', diff --git a/lib/client.js b/lib/client.js index eb639a2..3cef496 100644 --- a/lib/client.js +++ b/lib/client.js @@ -115,6 +115,18 @@ function connect(){ 'data', function(data) { 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); var eCount = events.length; for(var i=0; i