Keep-alive connection reuse stalls up to ~500ms on an idle event loop (possible regression in 8.8.0) #5600

import assert from 'node:assert'
import http from 'node:http'
import { test } from 'node:test'
import { Pool } from 'undici'

const REQUESTS = 6
const SERVER_DELAY_MS = 10
const MAX_TOTAL_MS = 400

test('reusing an idle keep-alive socket must not stall', async (t) => {
  const server = http.createServer((req, res) => {
    setTimeout(() => {
      res.writeHead(200, { 'content-length': 2 })
      res.end('ok')
    }, SERVER_DELAY_MS)
  })

  await new Promise((resolve) => server.listen(0, resolve))

  const pool = new Pool(`http://127.0.0.1:${server.address().port}`, { connections: 1 })

  t.after(async () => {
    await pool.close()
    server.close()
  })

  const durations = []
  const start = Date.now()

  for (let i = 0; i < REQUESTS; i++) {
    const requestStart = Date.now()
    const res = await pool.request({ path: '/', method: 'GET' })
    await res.body.text()
    durations.push(Date.now() - requestStart)
  }

  const total = Date.now() - start

  t.diagnostic(`per-request: ${durations.map((d) => `${d}ms`).join(', ')}`)
  t.diagnostic(`total: ${total}ms`)

  assert.ok(
    total < MAX_TOTAL_MS,
    `${REQUESTS} sequential requests took ${total}ms (per-request: ${durations.join('ms, ')}ms). ` +
      `The server replies in ${SERVER_DELAY_MS}ms, so this should be well under ${MAX_TOTAL_MS}ms.`
  )
})