From b66cba0766999ddc4d030ec166ce9cfa4ccb8336 Mon Sep 17 00:00:00 2001
From: James M Snell <jasnell@gmail.com>
Date: Fri, 10 Aug 2018 14:28:26 -0700
Subject: [PATCH] test: add test-http2-large-file sequential test

Refs: https://github.com/nodejs/node/issues/19141

Backport-PR-URL: https://github.com/nodejs/node/pull/22850
PR-URL: https://github.com/nodejs/node/pull/22254
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
Reviewed-By: George Adams <george.adams@uk.ibm.com>
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
---
 test/sequential/test-http2-large-file.js | 39 ++++++++++++++++++++++++
 1 file changed, 39 insertions(+)
 create mode 100644 test/sequential/test-http2-large-file.js

diff --git a/test/sequential/test-http2-large-file.js b/test/sequential/test-http2-large-file.js
new file mode 100644
index 00000000000000..d1a44e8d6be53c
--- /dev/null
+++ b/test/sequential/test-http2-large-file.js
@@ -0,0 +1,39 @@
+'use strict';
+
+// Test to ensure sending a large stream with a large initial window size works
+// See: https://github.com/nodejs/node/issues/19141
+
+const common = require('../common');
+if (!common.hasCrypto)
+  common.skip('missing crypto');
+
+const http2 = require('http2');
+
+const server = http2.createServer({ settings: { initialWindowSize: 6553500 } });
+server.on('stream', (stream) => {
+  stream.resume();
+  stream.respond();
+  stream.end('ok');
+});
+
+server.listen(0, common.mustCall(() => {
+  let remaining = 1e8;
+  const chunk = 1e6;
+  const client = http2.connect(`http://localhost:${server.address().port}`,
+                               { settings: { initialWindowSize: 6553500 } });
+  const request = client.request({ ':method': 'POST' });
+  function writeChunk() {
+    if (remaining > 0) {
+      remaining -= chunk;
+      request.write(Buffer.alloc(chunk, 'a'), writeChunk);
+    } else {
+      request.end();
+    }
+  }
+  writeChunk();
+  request.on('close', common.mustCall(() => {
+    client.close();
+    server.close();
+  }));
+  request.resume();
+}));