machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

move lazy tx deletion into main loop

Browse Source
This commit is contained in:
Mononaut 2023-03-24 09:48:08 +09:00
parent 1fd85b729d
commit 28de93d0ff
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
backend/src/api/mempool.ts
View File

@ -38,7 +38,6 @@ class Mempool {
constructor() { constructor() {
setInterval(this.updateTxPerSecond.bind(this), 1000); setInterval(this.updateTxPerSecond.bind(this), 1000);
setInterval(this.deleteExpiredTransactions.bind(this), 20000);
} }
/** /**
@ -256,7 +255,7 @@ class Mempool {
} }
} }
private deleteExpiredTransactions() { public deleteExpiredTransactions() {
const now = new Date().getTime(); const now = new Date().getTime();
for (const tx in this.mempoolCache) { for (const tx in this.mempoolCache) {
const lazyDeleteAt = this.mempoolCache[tx].deleteAfter; const lazyDeleteAt = this.mempoolCache[tx].deleteAfter;

1
backend/src/index.ts
View File

@ -178,6 +178,7 @@ class Server {
logger.debug(msg); logger.debug(msg);
} }
} }
memPool.deleteExpiredTransactions();
await blocks.$updateBlocks(); await blocks.$updateBlocks();
await memPool.$updateMempool(); await memPool.$updateMempool();
indexer.$run(); indexer.$run();