merge upstream 2025-02-03

packages/backend/src/boot/entry.ts

@@ -70,14 +70,22 @@ async function main() {
 	});
 	//#endregion
 
-	if (cluster.isPrimary || envOption.disableClustering) {
-		await masterMain();
+	if (!envOption.disableClustering) {
 		if (cluster.isPrimary) {
+			logger.info(`Start main process... pid: ${process.pid}`);
+			await masterMain();
 			ev.mount();
+		} else if (cluster.isWorker) {
+			logger.info(`Start worker process... pid: ${process.pid}`);
+			await workerMain();
+		} else {
+			throw new Error('Unknown process type');
 		}
-	}
-	if (cluster.isWorker) {
-		await workerMain();
+	} else {
+		// 非clusterの場合はMasterのみが起動するため、Workerの処理は行わない(cluster.isWorker === trueの状態でこのブロックに来ることはない)
+		logger.info(`Start main process... pid: ${process.pid}`);
+		await masterMain();
+		ev.mount();
 	}
 
 	readyRef.value = true;

packages/backend/src/boot/master.ts

@@ -97,20 +97,20 @@ export async function masterMain() {
 		});
 	}
 
-	if (envOption.disableClustering) {
+	bootLogger.info(
+		`mode: [disableClustering: ${envOption.disableClustering}, onlyServer: ${envOption.onlyServer}, onlyQueue: ${envOption.onlyQueue}]`,
+	);
+
+	if (!envOption.disableClustering) {
+		// clusterモジュール有効時
+
 		if (envOption.onlyServer) {
-			await server();
+			// onlyServer かつ enableCluster な場合、メインプロセスはforkのみに制限する(listenしない)。
+			// ワーカープロセス側でlistenすると、メインプロセスでポートへの着信を受け入れてワーカープロセスへの分配を行う動作をする。
+			// そのため、メインプロセスでも直接listenするとポートの競合が発生して起動に失敗してしまう。
+			// see: https://nodejs.org/api/cluster.html#cluster
 		} else if (envOption.onlyQueue) {
 			await jobQueue();
-		} else {
-			await server();
-			await jobQueue();
-		}
-	} else {
-		if (envOption.onlyServer) {
-			// nop
-		} else if (envOption.onlyQueue) {
-			// nop
 		} else {
 			await server();
 		}
@@ -121,6 +121,17 @@ export async function masterMain() {
 		}
 
 		await spawnWorkers(config.clusterLimit);
+	} else {
+		// clusterモジュール無効時
+
+		if (envOption.onlyServer) {
+			await server();
+		} else if (envOption.onlyQueue) {
+			await jobQueue();
+		} else {
+			await server();
+			await jobQueue();
+		}
 	}
 
 	if (envOption.onlyQueue) {