✌️
This commit is contained in:
		
							parent
							
								
									1d6c0e1c6f
								
							
						
					
					
						commit
						01f60c829d
					
				
					 1 changed files with 8 additions and 3 deletions
				
			
		
							
								
								
									
										11
									
								
								src/index.ts
									
										
									
									
									
								
							
							
						
						
									
										11
									
								
								src/index.ts
									
										
									
									
									
								
							| 
						 | 
				
			
			@ -26,27 +26,28 @@ import { Config } from './config/types';
 | 
			
		|||
const clusterLog = debug('misskey:cluster');
 | 
			
		||||
const ev = new Xev();
 | 
			
		||||
 | 
			
		||||
process.title = 'Misskey';
 | 
			
		||||
 | 
			
		||||
if (process.env.NODE_ENV != 'production') {
 | 
			
		||||
	process.env.DEBUG = 'misskey:*';
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
const pkg = require('../package.json');
 | 
			
		||||
 | 
			
		||||
//#region Command line argument definitions
 | 
			
		||||
program
 | 
			
		||||
	.version(pkg.version)
 | 
			
		||||
	.option('--no-daemons', 'Disable daemon processes (for debbuging)')
 | 
			
		||||
	.option('--disable-clustering', 'Disable clustering')
 | 
			
		||||
	.parse(process.argv);
 | 
			
		||||
//#endregion
 | 
			
		||||
 | 
			
		||||
// Start app
 | 
			
		||||
main();
 | 
			
		||||
 | 
			
		||||
/**
 | 
			
		||||
 * Init process
 | 
			
		||||
 */
 | 
			
		||||
function main() {
 | 
			
		||||
	process.title = `Misskey (${ cluster.isMaster ? 'master' : 'worker' })`;
 | 
			
		||||
 | 
			
		||||
	if (cluster.isMaster || program.disableClustering) {
 | 
			
		||||
		masterMain();
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -186,6 +187,8 @@ function spawnWorkers(limit: number) {
 | 
			
		|||
	});
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
//#region Events
 | 
			
		||||
 | 
			
		||||
// Listen new workers
 | 
			
		||||
cluster.on('fork', worker => {
 | 
			
		||||
	clusterLog(`Process forked: [${worker.id}]`);
 | 
			
		||||
| 
						 | 
				
			
			@ -216,3 +219,5 @@ process.on('uncaughtException', err => {
 | 
			
		|||
process.on('exit', code => {
 | 
			
		||||
	Logger.info(`The process is going to exit with code ${code}`);
 | 
			
		||||
});
 | 
			
		||||
 | 
			
		||||
//#endregion
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue