summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-09-17 15:43:50 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-09-17 15:43:50 +0900
commit0dca6afa1f1d5d62dc9735cf7e5ec5ce12df34c6 (patch)
tree0c00b53d8c65d5a96f66bd76ead81db2dadc233e
parentfix test (diff)
downloadsharkey-0dca6afa1f1d5d62dc9735cf7e5ec5ce12df34c6.tar.gz
sharkey-0dca6afa1f1d5d62dc9735cf7e5ec5ce12df34c6.tar.bz2
sharkey-0dca6afa1f1d5d62dc9735cf7e5ec5ce12df34c6.zip
fix(backend): MK_ONLY_SERVERオプションを指定した際にクラッシュする問題を修正
Fix: #11811
-rw-r--r--CHANGELOG.md1
-rw-r--r--packages/backend/src/boot/master.ts33
2 files changed, 24 insertions, 10 deletions
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 34a2f88a9c..dacaee6923 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -72,6 +72,7 @@
- nodeinfo 2.1対応
- 自分へのメンション一覧を取得する際のパフォーマンスを向上
- Docker環境でjemallocを使用することでメモリ使用量を削減
+- Fix: MK_ONLY_SERVERオプションを指定した際にクラッシュする問題を修正
- Fix: ノート検索 `notes/search` にてhostを指定した際に検索結果に反映されるように
- Fix: 一部のfeatured noteを照会できない問題を修正
- Fix: muteがapiからのuser list timeline取得で機能しない問題を修正
diff --git a/packages/backend/src/boot/master.ts b/packages/backend/src/boot/master.ts
index 0bf23c770b..a45ea2bb8f 100644
--- a/packages/backend/src/boot/master.ts
+++ b/packages/backend/src/boot/master.ts
@@ -68,21 +68,34 @@ export async function masterMain() {
process.exit(1);
}
- if (envOption.onlyServer) {
- await server();
- } else if (envOption.onlyQueue) {
- await jobQueue();
- } else {
- await server();
- }
-
bootLogger.succ('Misskey initialized');
- if (!envOption.disableClustering) {
+ if (envOption.disableClustering) {
+ if (envOption.onlyServer) {
+ await server();
+ } else if (envOption.onlyQueue) {
+ await jobQueue();
+ } else {
+ await server();
+ await jobQueue();
+ }
+ } else {
+ if (envOption.onlyServer) {
+ // nop
+ } else if (envOption.onlyQueue) {
+ // nop
+ } else {
+ await server();
+ }
+
await spawnWorkers(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);
+ }
}
function showEnvironment(): void {