1a1f99af37
Previously an error thrown in the `analyzeFn` would cause the ngcc process to exit immediately without removing the lockfile, and potentially before the unlocker process had been successfully spawned resulting in the lockfile being orphaned and left behind. Now we catch these errors and remove the lockfile as needed. PR Close #37739
41 lines
1.6 KiB
TypeScript
41 lines
1.6 KiB
TypeScript
/**
|
|
* @license
|
|
* Copyright Google LLC All Rights Reserved.
|
|
*
|
|
* Use of this source code is governed by an MIT-style license that can be
|
|
* found in the LICENSE file at https://angular.io/license
|
|
*/
|
|
import {FileSystem} from '../../../../src/ngtsc/file_system';
|
|
import {AsyncLocker} from '../../locking/async_locker';
|
|
import {Logger} from '../../logging/logger';
|
|
import {FileWriter} from '../../writing/file_writer';
|
|
import {PackageJsonUpdater} from '../../writing/package_json_updater';
|
|
import {AnalyzeEntryPointsFn, CreateCompileFn, Executor} from '../api';
|
|
import {CreateTaskCompletedCallback} from '../tasks/api';
|
|
|
|
import {ClusterMaster} from './master';
|
|
|
|
/**
|
|
* An `Executor` that processes tasks in parallel (on multiple processes) and completes
|
|
* asynchronously.
|
|
*/
|
|
export class ClusterExecutor implements Executor {
|
|
constructor(
|
|
private workerCount: number, private fileSystem: FileSystem, private logger: Logger,
|
|
private fileWriter: FileWriter, private pkgJsonUpdater: PackageJsonUpdater,
|
|
private lockFile: AsyncLocker,
|
|
private createTaskCompletedCallback: CreateTaskCompletedCallback) {}
|
|
|
|
async execute(analyzeEntryPoints: AnalyzeEntryPointsFn, _createCompileFn: CreateCompileFn):
|
|
Promise<void> {
|
|
return this.lockFile.lock(async () => {
|
|
this.logger.debug(
|
|
`Running ngcc on ${this.constructor.name} (using ${this.workerCount} worker processes).`);
|
|
const master = new ClusterMaster(
|
|
this.workerCount, this.fileSystem, this.logger, this.fileWriter, this.pkgJsonUpdater,
|
|
analyzeEntryPoints, this.createTaskCompletedCallback);
|
|
return await master.run();
|
|
});
|
|
}
|
|
}
|