diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2018-08-14 07:51:45 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-08-14 07:51:45 +0900 |
| commit | 0702d0974b7608b4e59c3f2af97bc9842e6bd086 (patch) | |
| tree | 27d3a6ad4bbfdfa69fdc8eab072b4ddfe46df3a2 /src/daemons | |
| parent | Merge #2182 (diff) | |
| parent | Resolve #2176 (diff) | |
| download | sharkey-0702d0974b7608b4e59c3f2af97bc9842e6bd086.tar.gz sharkey-0702d0974b7608b4e59c3f2af97bc9842e6bd086.tar.bz2 sharkey-0702d0974b7608b4e59c3f2af97bc9842e6bd086.zip | |
Merge pull request #2199 from syuilo/patch-2176
Resolve #2176
Diffstat (limited to 'src/daemons')
| -rw-r--r-- | src/daemons/notes-stats.ts | 7 | ||||
| -rw-r--r-- | src/daemons/server-stats.ts | 7 |
2 files changed, 8 insertions, 6 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 => { diff --git a/src/daemons/server-stats.ts b/src/daemons/server-stats.ts index 0c0a72f747..b435c12e55 100644 --- a/src/daemons/server-stats.ts +++ b/src/daemons/server-stats.ts @@ -2,6 +2,7 @@ import * as os from 'os'; import * as sysUtils from 'systeminformation'; import * as diskusage from 'diskusage'; import Xev from 'xev'; +import Queue from '../misc/queue'; const osUtils = require('os-utils'); const ev = new Xev(); @@ -12,10 +13,10 @@ const interval = 1000; * Report server stats regularly */ export default function() { - const log: any[] = []; + const log = new Queue<any>(); ev.on('requestServerStatsLog', id => { - ev.emit('serverStatsLog:' + id, log); + ev.emit('serverStatsLog:' + id, log.toArray()); }); async function tick() { @@ -36,7 +37,7 @@ export default function() { }; ev.emit('serverStats', stats); log.push(stats); - if (log.length > 50) log.shift(); + if (log.length > 50) log.pop(); } tick(); |