modified buffer size messages
This commit is contained in:
parent
c9eb6aaf44
commit
2765c700dc
3 changed files with 3 additions and 5 deletions
|
@ -13,8 +13,6 @@ function init(config,log){
|
||||||
}
|
}
|
||||||
new pubsub(client);
|
new pubsub(client);
|
||||||
|
|
||||||
console.log(this)
|
|
||||||
|
|
||||||
return client;
|
return client;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -131,7 +129,7 @@ function connect(){
|
||||||
data=(this.ipcBuffer+=data);
|
data=(this.ipcBuffer+=data);
|
||||||
|
|
||||||
if(data.slice(-1)!=eventParser.delimiter){
|
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);
|
server.log('Implementing larger buffer for this socket message. You may want to consider smaller messages'.notice);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -173,7 +173,7 @@ function init(path,config,log,port){
|
||||||
data=(this.ipcBuffer+=data);
|
data=(this.ipcBuffer+=data);
|
||||||
|
|
||||||
if(data.slice(-1)!=eventParser.delimiter){
|
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);
|
server.log('Implementing larger buffer for this socket message. You may want to consider smaller messages'.notice);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
{
|
{
|
||||||
"name": "node-ipc",
|
"name": "node-ipc",
|
||||||
"version": "1.1.8",
|
"version": "1.1.9",
|
||||||
"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": {
|
||||||
|
|
Loading…
Reference in a new issue