pezkuwichain/pezkuwi-telemetry
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-telemetry.git synced 2026-06-10 17:11:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Throttle updates from syncing nodes

Browse Source
This commit is contained in:
maciejhirsz
2018-07-25 18:24:51 +02:00
parent 5283561eac
commit 33c0acb21e
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/backend/src/Node.ts
+11 -1
View File
@@ -43,6 +43,7 @@ export default class Node {
private blockTimes: Array<number> = new Array(BLOCK_TIME_HISTORY);
private lastBlockAt: Maybe<Date> = null;
private pingStart = 0 as Types.Timestamp;
private throttle = false;
constructor(
ip: string,
@@ -260,7 +261,16 @@ export default class Node {
this.blockTimes[height % BLOCK_TIME_HISTORY] = blockTime;
this.blockTime = blockTime;
this.events.emit('block');
if (blockTime > 100) {
this.events.emit('block');
} else if (!this.throttle) {
this.throttle = true;
setTimeout(() => {
this.events.emit('block');
this.throttle = false;
}, 1000);
}
}
}