aboutsummaryrefslogtreecommitdiff
path: root/node_modules/uglifyjs-webpack-plugin/dist/uglify/Runner.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/uglifyjs-webpack-plugin/dist/uglify/Runner.js')
-rw-r--r--node_modules/uglifyjs-webpack-plugin/dist/uglify/Runner.js136
1 files changed, 136 insertions, 0 deletions
diff --git a/node_modules/uglifyjs-webpack-plugin/dist/uglify/Runner.js b/node_modules/uglifyjs-webpack-plugin/dist/uglify/Runner.js
new file mode 100644
index 00000000..8bf50307
--- /dev/null
+++ b/node_modules/uglifyjs-webpack-plugin/dist/uglify/Runner.js
@@ -0,0 +1,136 @@
+'use strict';
+
+Object.defineProperty(exports, "__esModule", {
+ value: true
+});
+
+var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
+
+var _os = require('os');
+
+var _os2 = _interopRequireDefault(_os);
+
+var _cacache = require('cacache');
+
+var _cacache2 = _interopRequireDefault(_cacache);
+
+var _findCacheDir = require('find-cache-dir');
+
+var _findCacheDir2 = _interopRequireDefault(_findCacheDir);
+
+var _workerFarm = require('worker-farm');
+
+var _workerFarm2 = _interopRequireDefault(_workerFarm);
+
+var _serializeJavascript = require('serialize-javascript');
+
+var _serializeJavascript2 = _interopRequireDefault(_serializeJavascript);
+
+var _minify = require('./minify');
+
+var _minify2 = _interopRequireDefault(_minify);
+
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+var workerFile = require.resolve('./worker');
+
+try {
+ // run test
+ workerFile = require.resolve('../../dist/uglify/worker');
+} catch (e) {} // eslint-disable-line no-empty
+
+var Runner = function () {
+ function Runner() {
+ var options = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
+
+ _classCallCheck(this, Runner);
+
+ var cache = options.cache,
+ parallel = options.parallel;
+
+ this.cacheDir = cache === true ? (0, _findCacheDir2.default)({ name: 'uglifyjs-webpack-plugin' }) : cache;
+ // In some cases cpus() returns undefined
+ // https://github.com/nodejs/node/issues/19022
+ var cpus = _os2.default.cpus() || { length: 1 };
+ this.maxConcurrentWorkers = parallel === true ? cpus.length - 1 : Math.min(Number(parallel) || 0, cpus.length - 1);
+ }
+
+ _createClass(Runner, [{
+ key: 'runTasks',
+ value: function runTasks(tasks, callback) {
+ var _this = this;
+
+ /* istanbul ignore if */
+ if (!tasks.length) {
+ callback(null, []);
+ return;
+ }
+
+ if (this.maxConcurrentWorkers > 1) {
+ var workerOptions = process.platform === 'win32' ? { maxConcurrentWorkers: this.maxConcurrentWorkers, maxConcurrentCallsPerWorker: 1 } : { maxConcurrentWorkers: this.maxConcurrentWorkers };
+ this.workers = (0, _workerFarm2.default)(workerOptions, workerFile);
+ this.boundWorkers = function (options, cb) {
+ return _this.workers((0, _serializeJavascript2.default)(options), cb);
+ };
+ } else {
+ this.boundWorkers = function (options, cb) {
+ try {
+ cb(null, (0, _minify2.default)(options));
+ } catch (error) {
+ cb(error);
+ }
+ };
+ }
+
+ var toRun = tasks.length;
+ var results = [];
+ var step = function step(index, data) {
+ toRun -= 1;
+ results[index] = data;
+
+ if (!toRun) {
+ callback(null, results);
+ }
+ };
+
+ tasks.forEach(function (task, index) {
+ var enqueue = function enqueue() {
+ _this.boundWorkers(task, function (error, data) {
+ var result = error ? { error } : data;
+ var done = function done() {
+ return step(index, result);
+ };
+
+ if (_this.cacheDir && !result.error) {
+ _cacache2.default.put(_this.cacheDir, (0, _serializeJavascript2.default)(task.cacheKeys), JSON.stringify(data)).then(done, done);
+ } else {
+ done();
+ }
+ });
+ };
+
+ if (_this.cacheDir) {
+ _cacache2.default.get(_this.cacheDir, (0, _serializeJavascript2.default)(task.cacheKeys)).then(function (_ref) {
+ var data = _ref.data;
+ return step(index, JSON.parse(data));
+ }, enqueue);
+ } else {
+ enqueue();
+ }
+ });
+ }
+ }, {
+ key: 'exit',
+ value: function exit() {
+ if (this.workers) {
+ _workerFarm2.default.end(this.workers);
+ }
+ }
+ }]);
+
+ return Runner;
+}();
+
+exports.default = Runner; \ No newline at end of file