File tree 2 files changed +5
-7
lines changed
2 files changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -1272,15 +1272,13 @@ export class HyperionMaster {
1272
1272
1273
1273
private pauseReaders ( ) {
1274
1274
if ( ! this . readingPaused ) {
1275
- hLog ( 'sending PAUSE command to readers...' ) ;
1276
1275
this . sendToRole ( 'reader' , { event : 'pause' } ) ;
1277
1276
this . readingPaused = true ;
1278
1277
}
1279
1278
}
1280
1279
1281
1280
private resumeReaders ( ) {
1282
1281
if ( this . readingPaused ) {
1283
- hLog ( 'sending RESUME command to readers...' ) ;
1284
1282
this . sendToRole ( 'reader' , { event : 'resume' } ) ;
1285
1283
this . readingPaused = false ;
1286
1284
}
@@ -1308,9 +1306,9 @@ export class HyperionMaster {
1308
1306
qlimit = this . conf . scaling . block_queue_limit ;
1309
1307
}
1310
1308
1311
- if ( size / qlimit > 0.5 ) {
1312
- hLog ( queue , size , ( ( size / qlimit ) * 100 ) . toFixed ( 2 ) + "%" ) ;
1313
- }
1309
+ // if (size / qlimit > 0.5) {
1310
+ // hLog(queue, size, ((size / qlimit) * 100).toFixed(2) + "%");
1311
+ // }
1314
1312
1315
1313
// pause readers if queues are above the max_limit
1316
1314
if ( size >= qlimit ) {
Original file line number Diff line number Diff line change @@ -490,7 +490,7 @@ export default class StateReader extends HyperionWorker {
490
490
request . start_block_num = parseInt ( first_block > 0 ? first_block . toString ( ) : '1' , 10 ) ;
491
491
request . end_block_num = parseInt ( last_block . toString ( ) , 10 ) ;
492
492
const reqType = 'get_blocks_request_' + this . shipRev ;
493
- hLog ( `Reader ${ process . env . worker_id } sending ${ reqType } from: ${ request . start_block_num } to: ${ request . end_block_num } ` ) ;
493
+ debugLog ( `Reader ${ process . env . worker_id } sending ${ reqType } from: ${ request . start_block_num } to: ${ request . end_block_num } ` ) ;
494
494
this . send ( [ reqType , request ] ) ;
495
495
}
496
496
@@ -504,7 +504,7 @@ export default class StateReader extends HyperionWorker {
504
504
this . local_block_num = request . start_block_num - 1 ;
505
505
request . end_block_num = parseInt ( last , 10 ) ;
506
506
const reqType = 'get_blocks_request_' + this . shipRev ;
507
- hLog ( `Reader ${ process . env . worker_id } sending ${ reqType } from: ${ request . start_block_num } to: ${ request . end_block_num } ` ) ;
507
+ debugLog ( `Reader ${ process . env . worker_id } sending ${ reqType } from: ${ request . start_block_num } to: ${ request . end_block_num } ` ) ;
508
508
this . send ( [ reqType , request ] ) ;
509
509
}
510
510
You can’t perform that action at this time.
0 commit comments