1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
8 * @class FunctionSequence to invoke steps in sequence
10 * @param {string} name Name of the function.
11 * @param {Array.<function>} steps Array of functions to invoke in parallel.
12 * @param {Object} logger Logger object.
13 * @param {function()} callback Callback to invoke on success.
14 * @param {function(string)} failureCallback Callback to invoke on failure.
17 function FunctionParallel(name, steps, logger, callback, failureCallback) {
18 // Private variables hidden in closure
19 this.currentStepIdx_ = -1;
22 this.callback_ = callback;
23 this.failureCallback_ = failureCallback;
27 this.remaining = this.steps_.length;
29 this.nextStep = this.nextStep_.bind(this);
30 this.onError = this.onError_.bind(this);
31 this.apply = this.start.bind(this);
36 * Error handling function, which fires error callback.
38 * @param {string} err Error message.
41 FunctionParallel.prototype.onError_ = function(err) {
44 this.failureCallback_(err);
49 * Advances to next step. This method should not be used externally. In external
50 * cases should be used nextStep function, which is defined in closure and thus
51 * has access to internal variables of functionsequence.
55 FunctionParallel.prototype.nextStep_ = function() {
56 if (--this.remaining == 0 && !this.failed_) {
62 * This function should be called only once on start, so start all the children
64 * @param {...} var_args Arguments to be passed to all the steps.
66 FunctionParallel.prototype.start = function(var_args) {
67 this.logger.vlog('Starting [' + this.steps_.length + '] parallel tasks ' +
68 'with ' + arguments.length + ' argument(s)');
69 if (this.logger.verbose) {
70 for (var j = 0; j < arguments.length; j++) {
71 this.logger.vlog(arguments[j]);
74 for (var i = 0; i < this.steps_.length; i++) {
75 this.logger.vlog('Attempting to start step [' + this.steps_[i].name + ']');
77 this.steps_[i].apply(this, arguments);
79 this.onError(e.toString());