@@ -150,7 +150,7 @@ var boot = () => {
150
150
bootP = false
151
151
return console . log ( 'ledger client boot error: ' + ex . toString ( ) + '\n' + ex . stack )
152
152
}
153
- if ( client . sync ( callback ) === true ) run ( random . randomInt ( { min : 1 , max : 10 } ) * msecs . minute )
153
+ if ( client . sync ( callback ) === true ) run ( random . randomInt ( { min : msecs . minute , max : 10 * msecs . minute } ) )
154
154
getBalance ( )
155
155
156
156
bootP = false
@@ -374,7 +374,7 @@ var initialize = (onoff) => {
374
374
} catch ( ex ) {
375
375
return console . log ( 'ledger client creation error: ' + ex . toString ( ) + '\n' + ex . stack )
376
376
}
377
- if ( client . sync ( callback ) === true ) run ( random . randomInt ( { min : 1 , max : 10 } ) * msecs . minute )
377
+ if ( client . sync ( callback ) === true ) run ( random . randomInt ( { min : msecs . minute , max : 10 * msecs . minute } ) )
378
378
cacheRuleSet ( state . ruleset )
379
379
380
380
// Make sure bravery props are up-to-date with user settings
@@ -850,7 +850,7 @@ var callback = (err, result, delayTime) => {
850
850
console . log ( 'ledger client error(1): ' + JSON . stringify ( err , null , 2 ) + ( err . stack ? ( '\n' + err . stack ) : '' ) )
851
851
if ( ! client ) return
852
852
853
- if ( typeof delayTime === 'undefined' ) delayTime = random . randomInt ( { min : 1 * msecs . minute , max : 10 * msecs . minute } )
853
+ if ( typeof delayTime === 'undefined' ) delayTime = random . randomInt ( { min : msecs . minute , max : 10 * msecs . minute } )
854
854
}
855
855
856
856
if ( ! result ) return run ( delayTime )
@@ -863,7 +863,8 @@ var callback = (err, result, delayTime) => {
863
863
}
864
864
cacheRuleSet ( result . ruleset )
865
865
866
- syncWriter ( pathName ( statePath ) , result , ( ) => { run ( delayTime ) } )
866
+ syncWriter ( pathName ( statePath ) , result , ( ) => { } )
867
+ run ( delayTime )
867
868
}
868
869
869
870
var roundtrip = ( params , options , callback ) => {
@@ -937,7 +938,7 @@ var roundtrip = (params, options, callback) => {
937
938
var runTimeoutId = false
938
939
939
940
var run = ( delayTime ) => {
940
- // if (clientOptions.verboseP) console.log('\nledger client run: clientP=' + (!!client) + ' delayTime=' + delayTime)
941
+ if ( clientOptions . verboseP ) console . log ( '\nledger client run: clientP=' + ( ! ! client ) + ' delayTime=' + delayTime )
941
942
942
943
if ( ( typeof delayTime === 'undefined' ) || ( ! client ) ) return
943
944
@@ -967,13 +968,13 @@ var run = (delayTime) => {
967
968
} catch ( ex ) {
968
969
delayTime = false
969
970
}
970
- if ( delayTime === false ) delayTime = random . randomInt ( { min : 1 , max : 10 } ) * msecs . minute
971
+ if ( delayTime === false ) delayTime = random . randomInt ( { min : msecs . minute , max : 10 * msecs . minute } )
971
972
}
972
973
if ( delayTime > 0 ) {
973
974
if ( runTimeoutId ) return console . log ( '\ninterception' )
974
975
975
976
active = client
976
- if ( delayTime > msecs . day ) delayTime = msecs . day
977
+ if ( delayTime > ( 1 * msecs . hour ) ) delayTime = random . randomInt ( { min : 3 * msecs . minute , max : msecs . hour } )
977
978
978
979
runTimeoutId = setTimeout ( ( ) => {
979
980
runTimeoutId = false
@@ -1166,11 +1167,11 @@ var cacheReturnValue = () => {
1166
1167
* low-level utilities
1167
1168
*/
1168
1169
1169
- var syncP = { }
1170
+ var syncingP = { }
1170
1171
1171
1172
var syncWriter = ( path , obj , options , cb ) => {
1172
- if ( syncP [ path ] ) return
1173
- syncP [ path ] = true
1173
+ if ( syncingP [ path ] ) return
1174
+ syncingP [ path ] = true
1174
1175
1175
1176
if ( typeof options === 'function' ) {
1176
1177
cb = options
@@ -1179,7 +1180,7 @@ var syncWriter = (path, obj, options, cb) => {
1179
1180
options = underscore . defaults ( options || { } , { encoding : 'utf8' , mode : parseInt ( '644' , 8 ) } )
1180
1181
1181
1182
fs . writeFile ( path , JSON . stringify ( obj , null , 2 ) , options , ( err ) => {
1182
- syncP [ path ] = false
1183
+ delete syncingP [ path ]
1183
1184
1184
1185
if ( err ) console . log ( 'write error: ' + err . toString ( ) )
1185
1186
0 commit comments