@@ -30,22 +30,19 @@ function run() {
3030}
3131
3232test ( function serverKeepAliveTimeoutWithPipeline ( cb ) {
33- let socket ;
34- let timeoutCount = 0 ;
3533 let requestCount = 0 ;
3634 process . on ( 'exit' , function ( ) {
37- assert . strictEqual ( timeoutCount , 1 ) ;
3835 assert . strictEqual ( requestCount , 3 ) ;
3936 } ) ;
4037 const server = https . createServer ( serverOptions , ( req , res ) => {
41- socket = req . socket ;
4238 requestCount ++ ;
4339 res . end ( ) ;
4440 } ) ;
45- server . setTimeout ( 500 , ( socket ) => {
46- timeoutCount ++ ;
41+ server . setTimeout ( 500 , common . mustCall ( ( socket ) => {
4742 socket . destroy ( ) ;
48- } ) ;
43+ server . close ( ) ;
44+ cb ( ) ;
45+ } ) ) ;
4946 server . keepAliveTimeout = 50 ;
5047 server . listen ( 0 , common . mustCall ( ( ) => {
5148 const options = {
@@ -58,32 +55,22 @@ test(function serverKeepAliveTimeoutWithPipeline(cb) {
5855 c . write ( 'GET /2 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
5956 c . write ( 'GET /3 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
6057 } ) ;
61- const interval = setInterval ( ( ) => {
62- if ( socket && socket . destroyed && requestCount === 3 ) {
63- clearInterval ( interval ) ;
64- server . close ( ) ;
65- cb ( ) ;
66- }
67- } , 1 ) ;
6858 } ) ) ;
6959} ) ;
7060
7161test ( function serverNoEndKeepAliveTimeoutWithPipeline ( cb ) {
72- let socket ;
73- let timeoutCount = 0 ;
7462 let requestCount = 0 ;
7563 process . on ( 'exit' , ( ) => {
76- assert . strictEqual ( timeoutCount , 1 ) ;
7764 assert . strictEqual ( requestCount , 3 ) ;
7865 } ) ;
7966 const server = https . createServer ( serverOptions , ( req , res ) => {
80- socket = req . socket ;
8167 requestCount ++ ;
8268 } ) ;
83- server . setTimeout ( 500 , ( socket ) => {
84- timeoutCount ++ ;
69+ server . setTimeout ( 500 , common . mustCall ( ( socket ) => {
8570 socket . destroy ( ) ;
86- } ) ;
71+ server . close ( ) ;
72+ cb ( ) ;
73+ } ) ) ;
8774 server . keepAliveTimeout = 50 ;
8875 server . listen ( 0 , common . mustCall ( ( ) => {
8976 const options = {
@@ -96,12 +83,5 @@ test(function serverNoEndKeepAliveTimeoutWithPipeline(cb) {
9683 c . write ( 'GET /2 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
9784 c . write ( 'GET /3 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
9885 } ) ;
99- const interval = setInterval ( ( ) => {
100- if ( socket && socket . destroyed && requestCount === 3 ) {
101- clearInterval ( interval ) ;
102- server . close ( ) ;
103- cb ( ) ;
104- }
105- } , 1 ) ;
10686 } ) ) ;
10787} ) ;
0 commit comments