test: add test for Http2ServerResponse#[writableCorked,cork,uncork] · nodejs/node@d4a2ae0 · GitHub

nodejs / node Public

• Notifications You must be signed in to change notification settings
• Fork 36.6k
• Star 120k

• Code
• Issues 637
• Pull requests 746
• Actions
• Projects
• Security and quality
• Insights

Additional navigation options

Commit d4a2ae0

Browse filesBrowse the repository at this point in the historyBrowse files

rexagod

authored and

codebytere

committed

test: add test for Http2ServerResponse#[writableCorked,cork,uncork]

PR-URL: #33956 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: James M Snell <jasnell@gmail.com>

1 parent d61de30 commit d4a2ae0
Copy full SHA for d4a2ae0

1 file changed

+54Lines changed: 54 additions & 0 deletions

File tree

Expand file treeCollapse file tree

Open diff view settings

Filter options

• test/parallel
  • test-http2-res-corked.js

Expand file treeCollapse file tree

Open diff view settings

Collapse file

‎test/parallel/test-http2-res-corked.js‎

Copy file name to clipboard

+54Lines changed: 54 additions & 0 deletions

Original file line number	Diff line number	Diff line change
@@ -0,0 +1,54 @@
	1	+ 'use strict';
	2	+ const common = require('../common');
	3	+ if (!common.hasCrypto) { common.skip('missing crypto'); }
	4	+
	5	+ // Test for Http2ServerResponse#[writableCorked,cork,uncork]
	6	+
	7	+ const { strictEqual } = require('assert');
	8	+ const http2 = require('http2');
	9	+
	10	+ {
	11	+ let corksLeft = 0;
	12	+ const server = http2.createServer(common.mustCall((req, res) => {
	13	+ strictEqual(res.writableCorked, corksLeft);
	14	+ res.write(Buffer.from('1'.repeat(1024)));
	15	+ res.cork();
	16	+ corksLeft++;
	17	+ strictEqual(res.writableCorked, corksLeft);
	18	+ res.write(Buffer.from('1'.repeat(1024)));
	19	+ res.cork();
	20	+ corksLeft++;
	21	+ strictEqual(res.writableCorked, corksLeft);
	22	+ res.write(Buffer.from('1'.repeat(1024)));
	23	+ res.cork();
	24	+ corksLeft++;
	25	+ strictEqual(res.writableCorked, corksLeft);
	26	+ res.write(Buffer.from('1'.repeat(1024)));
	27	+ res.cork();
	28	+ corksLeft++;
	29	+ strictEqual(res.writableCorked, corksLeft);
	30	+ res.uncork();
	31	+ corksLeft--;
	32	+ strictEqual(res.writableCorked, corksLeft);
	33	+ res.uncork();
	34	+ corksLeft--;
	35	+ strictEqual(res.writableCorked, corksLeft);
	36	+ res.uncork();
	37	+ corksLeft--;
	38	+ strictEqual(res.writableCorked, corksLeft);
	39	+ res.uncork();
	40	+ corksLeft--;
	41	+ strictEqual(res.writableCorked, corksLeft);
	42	+ res.end();
	43	+ }));
	44	+ server.listen(0, common.mustCall(() => {
	45	+ const URL = `http://localhost:${server.address().port}`;
	46	+ const client = http2.connect(URL);
	47	+ const req = client.request();
	48	+ req.on('data', common.mustCall(2));
	49	+ req.on('end', common.mustCall(() => {
	50	+ server.close();
	51	+ client.close();
	52	+ }));
	53	+ }));
	54	+ }

0 commit comments

Comments

0 (0)