Troplo/node-ipc
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Wiki Activity

Merge pull request #12 from RIAEvangelist/brandon

Browse source 
issue #11 and logging objects
This commit is contained in:
Brandon Nozaki Miller 2014-03-03 15:53:34 -08:00
commit 86b241eb36
5 changed files with 28 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
example/unixSocket/basic/world-server.js
View file

@ -15,7 +15,7 @@ ipc.serve(
ipc.server.on( ipc.server.on(
'app.message', 'app.message',
function(data,socket){ 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( ipc.server.emit(
socket, socket,
'app.message', 'app.message',

12
lib/client.js
View file

@ -115,6 +115,18 @@ function connect(){
'data', 'data',
function(data) { function(data) {
client.log('## recieved events ##'.rainbow); 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 events = eventParser.parse(data);
var eCount = events.length; var eCount = events.length;
for(var i=0; i<eCount; i++){ for(var i=0; i<eCount; i++){

12
lib/socketServer.js
View file

@ -166,6 +166,18 @@ function init(path,config,log,port){
socket.on( socket.on(
'data', 'data',
function(data,UDPSocket){ 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); data=eventParser.parse(data);
var sock=((server.udp4 || server.udp6)? UDPSocket : socket); var sock=((server.udp4 || server.udp6)? UDPSocket : socket);

3
node-ipc.js
View file

@ -1,4 +1,5 @@
var os = require('os'), var os = require('os'),
util = require('util'),
colors = require('colors'), colors = require('colors'),
pubsub = require('event-pubsub'), pubsub = require('event-pubsub'),
eventParser = require('./lib/eventParser.js'), eventParser = require('./lib/eventParser.js'),
@ -52,7 +53,7 @@ function log(){
if(typeof args[i] != 'object') if(typeof args[i] != 'object')
continue; continue;
args[i]=JSON.stringify(args[i]); args[i]=util.inspect(args[i],{colors:true});
} }
console.log( console.log(

2
package.json
View file

@ -1,6 +1,6 @@
{ {
"name": "node-ipc", "name": "node-ipc",
"version": "0.9.13", "version": "0.9.15",
"description": "A nodejs module for local and remote Inter Process Communication (IPC), Neural Networking, and able to facilitate machine learning.", "description": "A nodejs module for local and remote Inter Process Communication (IPC), Neural Networking, and able to facilitate machine learning.",
"main": "node-ipc.js", "main": "node-ipc.js",
"directories": { "directories": {