Gecko [ c.stage.kornherr.net ]

Name	Size	Permission	Date
api	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
cache	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
compat	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
cookies	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
core	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
fetch	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
fileapi	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
handler	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
interceptor	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
llhttp	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
mock	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
node	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
websocket	[ DIR ]	drwxr-xr-x	2024-07-10 10:55
agent.js	4.51 KB	-rw-r--r--	2023-10-14 10:49
balanced-pool.js	5.13 KB	-rw-r--r--	2023-10-14 10:49
client.js	60.06 KB	-rw-r--r--	2023-10-14 10:49
dispatcher-base.js	4.48 KB	-rw-r--r--	2023-10-14 10:49
dispatcher.js	300 B	-rw-r--r--	2023-10-14 10:49
global.js	860 B	-rw-r--r--	2023-10-14 10:49
pool-base.js	4.45 KB	-rw-r--r--	2023-10-14 10:49
pool-stats.js	552 B	-rw-r--r--	2023-10-14 10:49
pool.js	2.47 KB	-rw-r--r--	2023-10-14 10:49
proxy-agent.js	5.23 KB	-rw-r--r--	2023-10-14 10:49
timers.js	1.83 KB	-rw-r--r--	2023-10-14 10:49

Rename

'use strict'

let fastNow = Date.now()
let fastNowTimeout

const fastTimers = []

function onTimeout () {
  fastNow = Date.now()

let len = fastTimers.length
  let idx = 0
  while (idx < len) {
    const timer = fastTimers[idx]

if (timer.state === 0) {
      timer.state = fastNow + timer.delay
    } else if (timer.state > 0 && fastNow >= timer.state) {
      timer.state = -1
      timer.callback(timer.opaque)
    }

if (timer.state === -1) {
      timer.state = -2
      if (idx !== len - 1) {
        fastTimers[idx] = fastTimers.pop()
      } else {
        fastTimers.pop()
      }
      len -= 1
    } else {
      idx += 1
    }
  }

if (fastTimers.length > 0) {
    refreshTimeout()
  }
}

function refreshTimeout () {
  if (fastNowTimeout && fastNowTimeout.refresh) {
    fastNowTimeout.refresh()
  } else {
    clearTimeout(fastNowTimeout)
    fastNowTimeout = setTimeout(onTimeout, 1e3)
    if (fastNowTimeout.unref) {
      fastNowTimeout.unref()
    }
  }
}

class Timeout {
  constructor (callback, delay, opaque) {
    this.callback = callback
    this.delay = delay
    this.opaque = opaque

//  -2 not in timer list
    //  -1 in timer list but inactive
    //   0 in timer list waiting for time
    // > 0 in timer list waiting for time to expire
    this.state = -2

this.refresh()
  }

refresh () {
    if (this.state === -2) {
      fastTimers.push(this)
      if (!fastNowTimeout || fastTimers.length === 1) {
        refreshTimeout()
      }
    }

this.state = 0
  }

clear () {
    this.state = -1
  }
}

module.exports = {
  setTimeout (callback, delay, opaque) {
    return delay < 1e3
      ? setTimeout(callback, delay, opaque)
      : new Timeout(callback, delay, opaque)
  },
  clearTimeout (timeout) {
    if (timeout instanceof Timeout) {
      timeout.clear()
    } else {
      clearTimeout(timeout)
    }
  }
}