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

added support for infinate retries

Browse source
This commit is contained in:
Brandon Nozaki Miller 2014-08-31 10:50:34 -07:00
parent 5b9f13dfb6
commit 8ccf29be46
2 changed files with 9 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
example/unixSocket/basic/hello-client.js
View file

@ -8,7 +8,8 @@ var ipc=require('../../../node-ipc');
* *************************************/ * *************************************/
ipc.config.id = 'hello'; ipc.config.id = 'hello';
ipc.config.retry= 1500; ipc.config.maxRetries = 10;
ipc.config.retry = 100;
ipc.connectTo( ipc.connectTo(
'world', 'world',

4
lib/client.js
View file

@ -81,11 +81,13 @@ function connect(){
client.log('connection closed'.notice ,client.id.variable , client.path.variable); client.log('connection closed'.notice ,client.id.variable , client.path.variable);
if(client.stopRetrying || client.retriesRemaining<1){ if(client.stopRetrying || client.retriesRemaining<1){
if(client.config.maxRetries){
client.log(client.config.id.variable,'exceeded connection rety amount of'.warn,client.config.stopRetrying, " or stopRetrying flag set."); client.log(client.config.id.variable,'exceeded connection rety amount of'.warn,client.config.stopRetrying, " or stopRetrying flag set.");
client.socket.destroy(); client.socket.destroy();
client=undefined; client=undefined;
return; return;
} }
}
client.isRetrying=true; client.isRetrying=true;
@ -99,7 +101,7 @@ function connect(){
setTimeout( setTimeout(
function(){ function(){
if(!client.isRetrying) if(!client.isRetrying)
client.retriesRemaining=ipc.config.maxRetries; client.retriesRemaining=client.config.maxRetries;
}, },
100 100
) )