make groups of dependencyCount to do async by group

This commit is contained in:
Jonathan Rainville 2018-06-20 11:15:47 -04:00
parent 9574562602
commit 4298e18655
2 changed files with 45 additions and 7 deletions

View File

@ -261,8 +261,42 @@ class ContractsManager {
}); });
} }
callback(); callback();
},
function setDependencyCount(callback) {
let className;
function getDependencyCount(contractName, cycleDetector) {
if (!self.contractDependencies[contractName] || !self.contractDependencies[contractName].length) {
self.contracts[contractName].dependencyCount = 0;
return 0;
} }
], function (err, _result) { if (self.contracts[contractName].dependencyCount) {
// Already have that count
return self.contracts[contractName].dependencyCount;
}
let total = self.contractDependencies[contractName].length;
self.contractDependencies[contractName].some(dependencyName => {
if (cycleDetector.indexOf(dependencyName) > -1) {
// We are in a cycle because of the dependency, set both to Infinity
self.contracts[dependencyName].dependencyCount = Infinity;
total = Infinity;
return true;
}
cycleDetector.push(dependencyName);
total += getDependencyCount(dependencyName, cycleDetector);
});
self.contracts[contractName].dependencyCount = total;
return total;
}
let cycleDetector;
for (className in self.contracts) {
cycleDetector = [];
getDependencyCount(className, cycleDetector);
}
callback();
}
], function (err) {
if (err) { if (err) {
self.compileError = true; self.compileError = true;
self.events.emit("status", __("Compile/Build error")); self.events.emit("status", __("Compile/Build error"));

View File

@ -1,4 +1,5 @@
let async = require('async'); let async = require('async');
const _ = require('underscore');
class DeployManager { class DeployManager {
constructor(options) { constructor(options) {
@ -31,12 +32,15 @@ class DeployManager {
self.logger.info(__("deploying contracts")); self.logger.info(__("deploying contracts"));
self.events.emit("deploy:beforeAll"); self.events.emit("deploy:beforeAll");
async.eachOfSeries(contracts, const contractsPerDependencyCount = _.groupBy(contracts, 'dependencyCount');
function (contract, key, callback) { async.eachSeries(contractsPerDependencyCount,
function (parallelGroups, callback) {
async.each(parallelGroups, (contract, eachCb) => {
contract._gasLimit = self.gasLimit; contract._gasLimit = self.gasLimit;
self.events.request('deploy:contract', contract, (err) => { self.events.request('deploy:contract', contract, (err) => {
callback(err); eachCb(err);
}); });
}, callback);
}, },
function (err, _results) { function (err, _results) {
if (err) { if (err) {