blob: b3a9f76ef4ec3f25c8a99a392192fec5b4b53dc2 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
'use strict';
const common = require('../common');
const assert = require('assert');
const { executionAsyncResource, createHook } = require('async_hooks');
const { createServer, get } = require('http');
const sym = Symbol('cls');
// Tests continuation local storage with the executionAsyncResource API
assert.ok(executionAsyncResource());
createHook({
init(asyncId, type, triggerAsyncId, resource) {
const cr = executionAsyncResource();
resource[sym] = cr[sym];
}
}).enable();
const server = createServer(function(req, res) {
executionAsyncResource()[sym] = { state: req.url };
setTimeout(function() {
const { state } = executionAsyncResource()[sym];
res.setHeader('content-type', 'application/json');
res.end(JSON.stringify({ state }));
}, 10);
});
function test(n) {
get(`http://localhost:${server.address().port}/${n}`, common.mustCall(function(res) {
res.setEncoding('utf8');
let body = '';
res.on('data', function(chunk) {
body += chunk;
});
res.on('end', common.mustCall(function() {
assert.deepStrictEqual(JSON.parse(body), { state: `/${n}` });
}));
}));
}
server.listen(0, common.mustCall(function() {
server.unref();
for (let i = 0; i < 10; i++) {
test(i);
}
}));
|
