ikan Uploader :
Directory : /proc/self/root/home/ubuntu/node-v16.18.1/test/parallel/
Upload File : |
| Current File : //proc/self/root/home/ubuntu/node-v16.18.1/test/parallel/test-http2-pack-end-stream-flag.js |
'use strict';
const common = require('../common');
if (!common.hasCrypto)
common.skip('missing crypto');
const assert = require('assert');
const http2 = require('http2');
const { PerformanceObserver } = require('perf_hooks');
const server = http2.createServer();
server.on('stream', (stream, headers) => {
stream.respond({
'content-type': 'text/html',
':status': 200
});
switch (headers[':path']) {
case '/singleEnd':
stream.end('OK');
break;
case '/sequentialEnd':
stream.write('OK');
stream.end();
break;
case '/delayedEnd':
stream.write('OK', () => stream.end());
break;
}
});
function testRequest(path, targetFrameCount, callback) {
const obs = new PerformanceObserver(
common.mustCallAtLeast((list, observer) => {
const entries = list.getEntries();
for (let n = 0; n < entries.length; n++) {
const entry = entries[n];
if (entry.name !== 'Http2Session') continue;
if (entry.detail.type !== 'client') continue;
assert.strictEqual(entry.detail.framesReceived, targetFrameCount);
observer.disconnect();
callback();
}
}));
obs.observe({ type: 'http2' });
const client =
http2.connect(`http://localhost:${server.address().port}`, () => {
const req = client.request({ ':path': path });
req.resume();
req.end();
req.on('end', () => client.close());
});
}
// SETTINGS => SETTINGS => HEADERS => DATA
const MIN_FRAME_COUNT = 4;
server.listen(0, () => {
testRequest('/singleEnd', MIN_FRAME_COUNT, () => {
testRequest('/sequentialEnd', MIN_FRAME_COUNT, () => {
testRequest('/delayedEnd', MIN_FRAME_COUNT + 1, () => {
server.close();
});
});
});
});
Kontol Shell Bypass