@ -20,24 +20,20 @@ function run() {
}
}
test ( function serverEndKeepAliveTimeoutWithPipeline ( cb ) {
test ( function serverEndKeepAliveTimeoutWithPipeline ( cb ) {
let socket ;
let destroyedSockets = 0 ;
let timeoutCount = 0 ;
let requestCount = 0 ;
let requestCount = 0 ;
process . on ( 'exit' , ( ) => {
process . on ( 'exit' , ( ) => {
assert . strictEqual ( timeoutCount , 1 ) ;
assert . strictEqual ( requestCount , 3 ) ;
assert . strictEqual ( requestCount , 3 ) ;
assert . strictEqual ( destroyedSockets , 1 ) ;
} ) ;
} ) ;
const server = http . createServer ( ( req , res ) => {
const server = http . createServer ( ( req , res ) => {
socket = req . socket ;
requestCount ++ ;
requestCount ++ ;
res . end ( ) ;
res . end ( ) ;
} ) ;
} ) ;
server . setTimeout ( 200 , ( socket ) => {
server . setTimeout ( 500 , common . mustCall ( ( socket ) => {
timeoutCount ++ ;
// End this test and call `run()` for the next test (if any).
socket . destroy ( ) ;
socket . destroy ( ) ;
} ) ;
server . close ( ) ;
cb ( ) ;
} ) ) ;
server . keepAliveTimeout = 50 ;
server . keepAliveTimeout = 50 ;
server . listen ( 0 , common . mustCall ( ( ) => {
server . listen ( 0 , common . mustCall ( ( ) => {
const options = {
const options = {
@ -49,32 +45,23 @@ test(function serverEndKeepAliveTimeoutWithPipeline(cb) {
c . write ( 'GET /2 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
c . write ( 'GET /2 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
c . write ( 'GET /3 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
c . write ( 'GET /3 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
} ) ;
} ) ;
setTimeout ( ( ) => {
server . close ( ) ;
if ( socket . destroyed ) destroyedSockets ++ ;
cb ( ) ;
} , 1000 ) ;
} ) ) ;
} ) ) ;
} ) ;
} ) ;
test ( function serverNoEndKeepAliveTimeoutWithPipeline ( cb ) {
test ( function serverNoEndKeepAliveTimeoutWithPipeline ( cb ) {
let socket ;
let destroyedSockets = 0 ;
let timeoutCount = 0 ;
let requestCount = 0 ;
let requestCount = 0 ;
process . on ( 'exit' , ( ) => {
process . on ( 'exit' , ( ) => {
assert . strictEqual ( timeoutCount , 1 ) ;
assert . strictEqual ( requestCount , 3 ) ;
assert . strictEqual ( requestCount , 3 ) ;
assert . strictEqual ( destroyedSockets , 1 ) ;
} ) ;
} ) ;
const server = http . createServer ( ( req , res ) => {
const server = http . createServer ( ( req , res ) => {
socket = req . socket ;
requestCount ++ ;
requestCount ++ ;
} ) ;
} ) ;
server . setTimeout ( 200 , ( socket ) => {
server . setTimeout ( 500 , common . mustCall ( ( socket ) => {
timeoutCount ++ ;
// End this test and call `run()` for the next test (if any).
socket . destroy ( ) ;
socket . destroy ( ) ;
} ) ;
server . close ( ) ;
cb ( ) ;
} ) ) ;
server . keepAliveTimeout = 50 ;
server . keepAliveTimeout = 50 ;
server . listen ( 0 , common . mustCall ( ( ) => {
server . listen ( 0 , common . mustCall ( ( ) => {
const options = {
const options = {
@ -86,10 +73,5 @@ test(function serverNoEndKeepAliveTimeoutWithPipeline(cb) {
c . write ( 'GET /2 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
c . write ( 'GET /2 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
c . write ( 'GET /3 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
c . write ( 'GET /3 HTTP/1.1\r\nHost: localhost\r\n\r\n' ) ;
} ) ;
} ) ;
setTimeout ( ( ) => {
server . close ( ) ;
if ( socket . destroyed ) destroyedSockets ++ ;
cb ( ) ;
} , 1000 ) ;
} ) ) ;
} ) ) ;
} ) ;
} ) ;