graphite/Sharkey
1
0
Fork 0
mirror of https://git.joinsharkey.org/Sharkey/Sharkey.git synced 2024-11-26 20:03:10 +02:00
Code Issues Projects Releases Packages Wiki Activity

クラスタ数を制限するオプションを追加

Browse source
This commit is contained in:
syuilo 2018-07-28 03:55:41 +09:00
parent 5c6f24dc39
commit e4bf0392af
3 changed files with 11 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
.config/example.yml
View file

@ -131,3 +131,6 @@ drive:
# Ghost account is an account used for the purpose of delegating # Ghost account is an account used for the purpose of delegating
# followers when putting users in the list. # followers when putting users in the list.
# ghost: user-id-of-your-ghost-account # ghost: user-id-of-your-ghost-account
# Clustering
# clusterLimit: 1

2
src/config/types.ts
View file

@ -92,6 +92,8 @@ export type Source = {
}; };
google_maps_api_key: string; google_maps_api_key: string;
clusterLimit?: number;
}; };
/** /**

10
src/index.ts
View file

@ -66,7 +66,7 @@ async function masterMain() {
Logger.succ('Misskey initialized'); Logger.succ('Misskey initialized');
spawnWorkers(() => { spawnWorkers(config.clusterLimit, () => {
Logger.succ('All workers started'); Logger.succ('All workers started');
Logger.info(`Now listening on port ${config.port} on ${config.url}`); Logger.info(`Now listening on port ${config.port} on ${config.url}`);
}); });
@ -137,14 +137,16 @@ async function init(): Promise<Config> {
return config; return config;
} }
function spawnWorkers(onComplete: Function) { function spawnWorkers(limit: number, onComplete: Function) {
// Count the machine's CPUs // Count the machine's CPUs
const cpuCount = os.cpus().length; const cpuCount = os.cpus().length;
const progress = new ProgressBar(cpuCount, 'Starting workers'); const count = limit || cpuCount;
const progress = new ProgressBar(count, 'Starting workers');
// Create a worker for each CPU // Create a worker for each CPU
for (let i = 0; i < cpuCount; i++) { for (let i = 0; i < count; i++) {
const worker = cluster.fork(); const worker = cluster.fork();
worker.on('message', message => { worker.on('message', message => {
if (message === 'ready') { if (message === 'ready') {