Skip to content

Commit 7f5dd5c

Browse files
committed
remove parallel iteration logic.
1 parent 67d8a7b commit 7f5dd5c

File tree

8 files changed

+40
-450
lines changed

8 files changed

+40
-450
lines changed

lib/runner/extensions/event.command.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -148,6 +148,7 @@ module.exports = {
148148
init: function (done) {
149149
var run = this;
150150

151+
console.log('event init');
151152
// if this run object already has a host, we do not need to create one.
152153
if (run.host) {
153154
return done();

lib/runner/extensions/http-request.command.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ var _ = require('lodash'),
1818

1919
module.exports = {
2020
init: function (done) {
21+
console.log('httprequest init');
2122
// Request timeouts are applied by the requester, so add them to requester options (if any).
2223

2324
// create a requester pool

lib/runner/extensions/item.command.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,7 @@ getResponseJSON = function (response) {
8383
*/
8484
module.exports = {
8585
init: function (done) {
86+
console.log('item init');
8687
// @todo - code item global timeout and delay here
8788
done();
8889
},

lib/runner/extensions/parallel.command.js

Lines changed: 0 additions & 185 deletions
This file was deleted.

lib/runner/extensions/request.command.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ var _ = require('lodash'),
55

66
module.exports = {
77
init: function (done) {
8+
console.log('request init');
89
done();
910
},
1011

lib/runner/extensions/waterfall.command.js

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -31,18 +31,16 @@ module.exports = {
3131
this.waterfall = state.cursor; // copy the location object to instance for quick access
3232

3333
// queue the iteration command on start
34-
if (!this.areIterationsParallelized) {
35-
this.queue('waterfall', {
36-
coords: this.waterfall.current(),
37-
static: true,
38-
start: true
39-
});
40-
}
34+
this.queue('waterfall', {
35+
coords: this.waterfall.current(),
36+
static: true,
37+
start: true
38+
});
4139

4240
// clear the variable that is supposed to store item name and id lookup hash for easy setNextRequest
4341
this.snrHash = null; // we populate it in the first SNR call
4442

45-
return done();
43+
done();
4644
},
4745

4846
triggers: ['beforeIteration', 'iteration'],

0 commit comments

Comments
 (0)