| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -15,6 +15,10 @@ const cert = fixtures.readKey('agent2-cert.pem'); | |||
| 15 | 15 | let serverTlsSocket; | |
| 16 | 16 | const tlsServer = tls.createServer({ cert, key }, (socket) => { | |
| 17 | 17 | serverTlsSocket = socket; | |
| 18 | + socket.on('data', (chunk) => { | ||
| 19 | + assert.strictEqual(chunk[0], 46); | ||
| 20 | + socket.write('.'); | ||
| 21 | + }); | ||
| 18 | 22 | socket.on('close', dec); | |
| 19 | 23 | }); | |
| 20 | 24 | ||
@@ -25,10 +29,10 @@ let netSocketCloseEmitted = false; | |||
| 25 | 29 | const netServer = net.createServer((socket) => { | |
| 26 | 30 | netSocket = socket; | |
| 27 | 31 | tlsServer.emit('connection', socket); | |
| 28 | - socket.on('close', () => { | ||
| 32 | + socket.on('close', common.mustCall(() => { | ||
| 29 | 33 | netSocketCloseEmitted = true; | |
| 30 | 34 | assert.strictEqual(serverTlsSocket.destroyed, true); | |
| 31 | - }); | ||
| 35 | + })); | ||
| 32 | 36 | }).listen(0, common.mustCall(() => { | |
| 33 | 37 | connectClient(netServer); | |
| 34 | 38 | })); | |
@@ -45,24 +49,20 @@ function connectClient(server) { | |||
| 45 | 49 | rejectUnauthorized: false | |
| 46 | 50 | }); | |
| 47 | 51 | ||
| 48 | - clientTlsSocket.write('foo', 'utf8', common.mustCall(() => { | ||
| 49 | - assert(netSocket); | ||
| 50 | - netSocket.setTimeout(common.platformTimeout(10), common.mustCall(() => { | ||
| 51 | - assert(serverTlsSocket); | ||
| 52 | + clientTlsSocket.write('.'); | ||
| 52 | 53 | ||
| 53 | - netSocket.destroy(); | ||
| 54 | - assert.strictEqual(netSocket.destroyed, true); | ||
| 54 | + clientTlsSocket.on('data', (chunk) => { | ||
| 55 | + assert.strictEqual(chunk[0], 46); | ||
| 55 | 56 | ||
| 56 | - setImmediate(() => { | ||
| 57 | - // Close callbacks are executed after `setImmediate()` callbacks. | ||
| 58 | - assert.strictEqual(netSocketCloseEmitted, false); | ||
| 59 | - assert.strictEqual(serverTlsSocket.destroyed, false); | ||
| 60 | - setImmediate(() => { | ||
| 61 | - assert.strictEqual(netSocketCloseEmitted, true); | ||
| 62 | - }); | ||
| 63 | - }); | ||
| 64 | - })); | ||
| 65 | - })); | ||
| 57 | + netSocket.destroy(); | ||
| 58 | + assert.strictEqual(netSocket.destroyed, true); | ||
| 59 | + | ||
| 60 | + setImmediate(() => { | ||
| 61 | + // Close callbacks are executed after `setImmediate()` callbacks. | ||
| 62 | + assert.strictEqual(netSocketCloseEmitted, false); | ||
| 63 | + assert.strictEqual(serverTlsSocket.destroyed, false); | ||
| 64 | + }); | ||
| 65 | + }); | ||
| 66 | 66 | ||
| 67 | 67 | clientTlsSocket.on('close', dec); | |
| 68 | 68 | } | |
| Back | FazBrowse Home | New Git URL |
0 commit comments