@@ -68,21 +68,34 @@ export async function masterMain() {
process.exit(1);
}
if (envOption.onlyServer){
awaitserver();
}elseif (envOption.onlyQueue){
awaitjobQueue();
}else{
awaitserver();
}
bootLogger.succ('Misskey initialized');
if (!envOption.disableClustering){
if (envOption.disableClustering){
if (envOption.onlyServer){
awaitserver();
}elseif (envOption.onlyQueue){
awaitjobQueue();
}else{
awaitserver();
awaitjobQueue();
}
}else{
if (envOption.onlyServer){
// nop
}elseif (envOption.onlyQueue){
// nop
}else{
awaitserver();
}
awaitspawnWorkers(config.clusterLimit);
}
bootLogger.succ(config.socket?`Now listening on socket ${config.socket} on ${config.url}`:`Now listening on port ${config.port} on ${config.url}`,null,true);
if (envOption.onlyQueue){
bootLogger.succ('Queue started',null,true);
}else{
bootLogger.succ(config.socket?`Now listening on socket ${config.socket} on ${config.url}`:`Now listening on port ${config.port} on ${config.url}`,null,true);