Skip to content
This repository was archived by the owner on Feb 18, 2021. It is now read-only.

Commit 4852664

Browse files
author
Joshua T Corbin
committed
test/peer-churn: add endpoint delay
1 parent b760595 commit 4852664

File tree

1 file changed

+17
-10
lines changed

1 file changed

+17
-10
lines changed

test/peer-churn.js

Lines changed: 17 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -30,14 +30,16 @@ var allocCluster = require('./lib/test-cluster.js');
3030
var CollapsedAssert = require('./lib/collapsed-assert.js');
3131

3232
/* eslint-disable no-multi-spaces */
33-
var PERIOD = 100;
34-
var REQUEST_TIMEOUT = 2 * PERIOD;
35-
var REQUEST_FACTOR = 1;
36-
var SETTLE_PERIODS = 10;
37-
var CLUSTER_SIZE = 10;
38-
var CHURN_FACTOR = 0.5;
39-
var K_VALUE = 5;
40-
var SERVICE_SIZE = 10;
33+
var PERIOD = 100;
34+
var REQUEST_TIMEOUT = 2 * PERIOD;
35+
var REQUEST_FACTOR = 1;
36+
var SETTLE_PERIODS = 10;
37+
var CLUSTER_SIZE = 10;
38+
var CHURN_FACTOR = 0.5;
39+
var K_VALUE = 5;
40+
var SERVICE_SIZE = 10;
41+
var ENDPOINT_DELAY = 0.5 * PERIOD;
42+
var ENDPOINT_DELAY_FUZZ = 0.50;
4143

4244
function fuzzedPeriods(N) {
4345
return 1.05 * N * PERIOD;
@@ -285,8 +287,13 @@ function createRemotes(cluster, N, opts, cb) {
285287
}
286288

287289
function who(req, res) {
288-
res.headers.as = 'raw';
289-
res.sendOk('', req.channel.hostPort);
290+
var delay = ENDPOINT_DELAY + 1 + (0.5 - Math.random()) * ENDPOINT_DELAY_FUZZ;
291+
timers.setTimeout(thenRespond, delay);
292+
293+
function thenRespond() {
294+
res.headers.as = 'raw';
295+
res.sendOk(delay.toString(), req.channel.hostPort);
296+
}
290297
}
291298

292299
function checkExitsTo(cluster, serviceName, cohort, desc, assert) {

0 commit comments

Comments
 (0)