summaryrefslogtreecommitdiff
path: root/src/daemons/notes-stats.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2018-08-14 07:51:45 +0900
committerGitHub <noreply@github.com>2018-08-14 07:51:45 +0900
commit0702d0974b7608b4e59c3f2af97bc9842e6bd086 (patch)
tree27d3a6ad4bbfdfa69fdc8eab072b4ddfe46df3a2 /src/daemons/notes-stats.ts
parentMerge #2182 (diff)
parentResolve #2176 (diff)
downloadmisskey-0702d0974b7608b4e59c3f2af97bc9842e6bd086.tar.gz
misskey-0702d0974b7608b4e59c3f2af97bc9842e6bd086.tar.bz2
misskey-0702d0974b7608b4e59c3f2af97bc9842e6bd086.zip
Merge pull request #2199 from syuilo/patch-2176
Resolve #2176
Diffstat (limited to 'src/daemons/notes-stats.ts')
-rw-r--r--src/daemons/notes-stats.ts7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/daemons/notes-stats.ts b/src/daemons/notes-stats.ts
index 136ccb60c2..3bc0269dde 100644
--- a/src/daemons/notes-stats.ts
+++ b/src/daemons/notes-stats.ts
@@ -1,21 +1,22 @@
import * as childProcess from 'child_process';
import Xev from 'xev';
+import Queue from '../misc/queue';
const ev = new Xev();
export default function() {
- const log: any[] = [];
+ const log = new Queue<any>();
const p = childProcess.fork(__dirname + '/notes-stats-child.js');
p.on('message', stats => {
ev.emit('notesStats', stats);
log.push(stats);
- if (log.length > 100) log.shift();
+ if (log.length > 100) log.pop();
});
ev.on('requestNotesStatsLog', id => {
- ev.emit('notesStatsLog:' + id, log);
+ ev.emit('notesStatsLog:' + id, log.toArray());
});
process.on('exit', code => {