Use monotonically increasing time for timeout - fixes porsager#316

porsager · porsager · commit 04644c001374 · 2022-04-16T01:05:06.000+02:00
diff --git a/src/connection.js b/src/connection.js
@@ -359,7 +359,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function reconnect() {
-    setTimeout(connect, closedDate ? closedDate + delay - Date.now() : 0)
+    setTimeout(connect, closedDate ? closedDate + delay - Number(process.hrtime.bigint() / 1000000n) : 0)
   }
 
   function connected() {
@@ -446,7 +446,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
       return reconnect()
 
     !hadError && (query || sent.length) && error(Errors.connection('CONNECTION_CLOSED', options, socket))
-    closedDate = Date.now()
+    closedDate = Number(process.hrtime.bigint() / 1000000n)
     hadError && options.shared.retries++
     delay = (typeof backoff === 'function' ? backoff(options.shared.retries) : backoff) * 1000
     onclose(connection)

Original file line number	Diff line number	Diff line change
`@@ -359,7 +359,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`359`	`359`	`}`
`360`	`360`
`361`	`361`	`function reconnect() {`
`362`		`- setTimeout(connect, closedDate ? closedDate + delay - Date.now() : 0)`
	`362`	`+ setTimeout(connect, closedDate ? closedDate + delay - Number(process.hrtime.bigint() / 1000000n) : 0)`
`363`	`363`	`}`
`364`	`364`
`365`	`365`	`function connected() {`
`@@ -446,7 +446,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`446`	`446`	`return reconnect()`
`447`	`447`
`448`	`448`	`!hadError && (query \|\| sent.length) && error(Errors.connection('CONNECTION_CLOSED', options, socket))`
`449`		`- closedDate = Date.now()`
	`449`	`+ closedDate = Number(process.hrtime.bigint() / 1000000n)`
`450`	`450`	`hadError && options.shared.retries++`
`451`	`451`	`delay = (typeof backoff === 'function' ? backoff(options.shared.retries) : backoff) * 1000`
`452`	`452`	`onclose(connection)`