1 files changed, 62 insertions, 0 deletions
diff --git a/test/parallel/test-http2-session-timeout.js b/test/parallel/test-http2-session-timeout.js
new file mode 100644
index 0000000000..0fa6a2c13c
--- /dev/null
+++ b/test/parallel/test-http2-session-timeout.js
@@ -0,0 +1,62 @@
+'use strict';
+
+const common = require('../common');
+if (!common.hasCrypto)
+  common.skip('missing crypto');
+const assert = require('assert');
+const http2 = require('http2');
+
+let requests = 0;
+const mustNotCall = () => {
+  assert.fail(`Timeout after ${requests} request(s)`);
+};
+
+const server = http2.createServer();
+// Disable server timeout until first request. We will set the timeout based on
+// how long the first request takes.
+server.timeout = 0;
+
+server.on('request', (req, res) => res.end());
+server.on('timeout', mustNotCall);
+
+server.listen(0, common.mustCall(() => {
+  const port = server.address().port;
+
+  const url = `http://localhost:${port}`;
+  const client = http2.connect(url);
+  let startTime = process.hrtime();
+  makeReq();
+
+  function makeReq() {
+    const request = client.request({
+      ':path': '/foobar',
+      ':method': 'GET',
+      ':scheme': 'http',
+      ':authority': `localhost:${port}`,
+    });
+    request.resume();
+    request.end();
+
+    requests += 1;
+
+    request.on('end', () => {
+      const diff = process.hrtime(startTime);
+      const milliseconds = (diff[0] * 1e3 + diff[1] / 1e6);
+      if (server.timeout === 0) {
+        // Set the timeout now. First connection will take significantly longer
+        // than subsequent connections, so using the duration of the first
+        // connection as the timeout should be robust. Double it anyway for good
+        // measure.
+        server.timeout = milliseconds * 2;
+        startTime = process.hrtime();
+        makeReq();
+      } else if (milliseconds < server.timeout * 2) {
+        makeReq();
+      } else {
+        server.removeListener('timeout', mustNotCall);
+        server.close();
+        client.close();
+      }
+    });
+  }
+}));